Чтение из нескольких Db с одинаковой единицей сохранения?
Мне нужна помощь в настройке нескольких соединений с несколькими db с использованием одного и того же блока Persistence.
Все они имеют одну и ту же схему. Поэтому я хочу использовать ту же единицу Persistence/DAO и т.д. И не хочу настраивать 10 EntityManagers, 10 Persistence xml и т.д. Есть ли способ сделать это? Вот моя текущая конфигурация:
<persistence-unit name="PersistenceUnit-c1" transaction-type="RESOURCE_LOCAL">
<properties>
<property name="hibernate.show_sql" value="${hibernate-show-sql}"/>
<property name="hibernate.dialect" value="org.hibernate.dialect.SybaseDialect" />
<property name="hibernate.c3p0.min_size" value="${hibernate-c3p0-min-size}" />
<property name="hibernate.c3p0.max_size" value="${hibernate-c3p0-max-size}" />
<property name="hibernate.c3p0.timeout" value="${hibernate-c3p0-timeout}" />
<property name="hibernate.c3p0.max_statements" value="${hibernate-c3p0-max-statements}" />
<property name="hibernate.c3p0.idle_test_period" value="${hibernate-c3p0-idle-test-periods}" />
</properties>
<class>com.domain.TktOrder</class>
<exclude-unlisted-classes/>
</persistence-unit>
Я также использую Spring/hibernate для настройки моего контекста:
<bean id="EntityManagerFactory"
class="org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean"
p:persistenceUnitName="PersistenceUnit-c1"
p:dataSource-ref="DataSource">
<property name="persistenceXmlLocation" value="classpath:META-INF/persistence.xml" />
<property name="jpaVendorAdapter">
<bean class="org.springframework.orm.jpa.vendor.HibernateJpaVendorAdapter"
p:showSql="${hibernate-show-sql}"
p:generateDdl="false"
p:databasePlatform="org.hibernate.dialect.SybaseDialect" />
</property>
<property name="loadTimeWeaver">
<bean class="org.springframework.instrument.classloading.InstrumentationLoadTimeWeaver" />
</property>
</bean>
<bean id="DataSource"
class="com.mchange.v2.c3p0.ComboPooledDataSource" destroy-method="close"
p:driverClass="net.sourceforge.jtds.jdbc.Driver"
p:jdbcUrl="jdbc:jtds:sybase://url.net:port;DatabaseName=db_1"
p:user="user"
p:password="password"
/>
и, наконец, я использую:
@PersistenceContext(unitName="PersistenceUnit-c1")
public void setEntityManager(EntityManager entityManager)
{
this.entityManager = entityManager;
}
чтобы ввести мой EntityManager в мой DAO
Как я могу расширить эту модель, чтобы иметь возможность использовать db1, затем изменить источник данных и выполнить снова для db2 и т.д.?
Большое спасибо за любую помощь заранее!
Ответы
Ответ 1
После нескольких попыток я нашел решение, похожее на счет.
Пожалуйста, сначала взгляните на это: dynamic-datasource-routing
Это использует несколько настраиваемых классов, которые вам понадобятся, а класс ключей - AbstractRoutingDataSource.
Это реконфигурирует мой источник данных bean следующим образом:
<bean id="dataSource" class="com.domain.etc.etc.recon.utils.RoutingDataSource">
<property name="targetDataSources">
<map key-type="com.domain.etc.etc.recon.utils.DbType">
<entry key="C1" value-ref="C1" />
<entry key="C2" value-ref="C2" />
</map>
</property>
<property name="defaultTargetDataSource" ref="C3" />
</bean>
Где соединение C1, C2 выглядит следующим образом:
<bean id="parentDataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource"
abstract="true">
<property name="driverClassName" value="net.sourceforge.jtds.jdbc.Driver" />
<property name="username" value="*******" />
<property name="password" value="*******" />
</bean>
<bean id="C1" parent="parentDataSource">
<property name="url"
value="jdbc:jtds:sybase://URL:PORT;DatabaseName=dbname" />
</bean>
<bean id="C2" parent="parentDataSource">
<property name="url"
value="jdbc:jtds:sybase://URL:PORT;DatabaseName=dbname2" />
</bean>
<bean id="C3" parent="parentDataSource">
<property name="url"
value="jdbc:jtds:sybase://URL:PORT;DatabaseName=dbname3" />
</bean>
вы можете вставить это в EntityManager, как в исходном Вопросе;
<bean id="EntityManagerFactory"
class="org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean"
p:persistenceUnitName="PersistenceUnit"
p:dataSource-ref="dataSource">
<property name="persistenceXmlLocation" value="classpath:META-INF/persistence-.xml" />
<property name="jpaVendorAdapter">
<bean class="org.springframework.orm.jpa.vendor.HibernateJpaVendorAdapter"
p:showSql="${hibernate-show-sql}"
p:generateDdl="false"
p:databasePlatform="org.hibernate.dialect.SybaseDialect" />
</property>
<property name="loadTimeWeaver">
<bean class="org.springframework.instrument.classloading.InstrumentationLoadTimeWeaver" />
</property>
</bean>
После этого вам нужно использовать собственную реализацию классов Java в приведенной выше ссылке, чтобы иметь возможность переключаться между источниками данных. Это не что иное, как переименование классов в те, которые более значимы для вас. Связывание Enum до C1, C2, C3 и т.д. И, наконец, указание на ваше собственное dao для выполнения работы.
Удачи!
Ответ 2
Это может быть прецедентом для Hibernate Shards. Мы начали оценивать его год назад, но затем отбросили его, потому что внезапно осколки не нужны в конце концов. Поэтому я не могу представить никакого реального опыта, но я думаю, что это стоит посмотреть.
Ответ 3
Hibernate Shard все еще развивается, если вам нужен HQL, тогда он не сработает для вас, поэтому, если вы можете уйти с запросом только критериев, вы должны быть в порядке.
