Grails 2 несколько динамических источников данных в сервисах

Ответ 1

Я работал над аналогичным проектом, где приложение должно извлекать список источников данных (строки подключения) из базы данных по умолчанию и подключаться к каждому источнику данных и выполнять операции с использованием заданий кварца.

Я реализовал его как, подключитесь к каждому источнику данных в приложении (а не из DataSorce.groovy) и напишите SQL скорее на языке HQL.

import groovy.sql.Sql

class SqlService{
    Sql getDbConnection(String connectionString, String dbUser, String dbPassword){
        def sql = Sql.newInstance(connectionString, dbUser, dbPassword, "driver_class")
        return sql
    }
}

Получите sql соединение из вышеуказанного кода и выполните SQL-запросы с помощью sql.execute "SQL STATEMENT" и закройте соединение sql. Здесь является документация класса sql.

Ответ 2

У меня есть два разных источника данных, работающих с Grails 2.3.11. Я использую 1 источник данных для моей базы данных H2, а другой для Oracle db. Мне пришлось использовать Hibernate 4 с Grails 2.3. В моем BuildConfig.groovy я указал зависимость от спящего режима 4:

runtime ":hibernate4:4.3.5.4"

В моем файле DataSource.groovy я использовал следующие настройки кэширования спящего режима:

hibernate {
    cache.use_second_level_cache = true
    cache.use_query_cache = false
    cache.region.factory_class = 'org.hibernate.cache.ehcache.SingletonEhCacheRegionFactory'
    singleSession = true // configure OSIV singleSession mode
}

(ПРИМЕЧАНИЕ: без настроек кэша я получал следующую ошибку CacheManager: "Еще один неназванный CacheManager уже существует в той же виртуальной машине". Там есть открытый отчет об ошибке на https://jira.grails.org/browse/GPCACHEEHCACHE-13, но как только я установил настройки, ошибка исчезла.)

тогда я определил свои источники данных:

environments {
    development {
        dataSource_oracle {
            pooled = true
            dialect = org.hibernate.dialect.Oracle10gDialect
            driverClassName = 'oracle.jdbc.OracleDriver'
            username = 'user'
            password = 'pass'
            url = 'jdbc:oracle:thin:@(serverName):(port):(SID)'
            dbCreate = 'validate'
        }
        dataSource {
            dbCreate = "update"
            url = "jdbc:h2:devDb;MVCC=TRUE;LOCK_TIMEOUT=10000;DB_CLOSE_ON_EXIT=FALSE"
            properties {
               jmxEnabled = true
               initialSize = 5
               maxActive = 50
               minIdle = 5
               maxIdle = 25
               maxWait = 10000
               maxAge = 10 * 60000
               timeBetweenEvictionRunsMillis = 5000
               minEvictableIdleTimeMillis = 60000
               validationQuery = "SELECT 1"
               validationQueryTimeout = 3
               validationInterval = 15000
               testOnBorrow = true
               testWhileIdle = true
               testOnReturn = false
               jdbcInterceptors = "ConnectionState"
               defaultTransactionIsolation = java.sql.Connection.TRANSACTION_READ_COMMITTED
            }
        }
    }
}

По умолчанию в моих классах домена используется db H2 и я указываю свой источник данных Oracle как:

class MyService {

    def dataSource_oracle
    static transactional = true

    def getMethod() {
        assert dataSource_oracle != null, "dataSource is null! Please check your configuration!"
        def sql = Sql.newInstance(dataSource_oracle)
        ...
    }
}

Выше, я разрешаю инъекции зависимостей предоставлять услугу источнику данных oracle, def dataSource_oracle. Если я хочу использовать источник данных H2, я объявляю источник данных как def dataSource и позволяю DI вводить другой источник данных.

Я не мог заставить эти два источника данных работать, как указано в документации, в http://grails.github.io/grails-doc/2.3.11/guide/conf.html#multipleDatasources. Объявляя источники данных как dataSource и dataSource_lookup, используя его как:

class DataService {
   static datasource = 'lookup'

   void someMethod(...) {
      …
   }
} 

но мне удалось заставить его работать с описанным выше решением.

Ответ 3

Вы можете добавить несколько источников данных в одно приложение и получить к ним доступ в сервисах.

Во-первых, вам нужно добавить основные источники данных в ресурсы .groovy.

сначала импортировать файл BasicDataSource

import org.apache.commons.dbcp.BasicDataSource;

Тогда

    switch (grails.util.GrailsUtil.environment) {
    case "development":
        firstDataSource( BasicDataSource ) {
            driverClassName = "net.sourceforge.jtds.jdbc.Driver"
            url = "jdbc:jtds:sqlserver://localhost:1433;DatabaseName=<Db_name>"
            username = "sa"
            password = "root"
            String SqlServerInstance = "SQLEXPRESS";
            url = url + ";" + SqlServerInstance;
        }
        break

    case "test":
        firstDataSource( BasicDataSource ) {

            driverClassName = "net.sourceforge.jtds.jdbc.Driver"
            url = "jdbc:jtds:sqlserver://localhost:1433;DatabaseName=<Db_name>"
            username = "sa"
            password = "root"
            String SqlServerInstance = "SQLEXPRESS";
            url = url + ";" + SqlServerInstance;            }
        break;

}

Таким же образом вы можете добавить больше источников данных, выше код предоставит вам еще один источник данных для доступа, кроме стандартного. Я использовал переключатель для настройки того же источника данных для разных сред, таким же образом можно добавить больше.

и в сервисе он может быть доступен в службах следующим образом:

BasicDataSource firstDataSource;
Connection con = firstDataSource.getConnection();

а затем можно использовать объект соединения.

Я думаю, что это должно помочь

Ответ 4

Используйте плагин для гралирования, который будет решать вашу проблему