我需要一些帮助,以使用同一持久性单元配置多个数据库的多个连接。
它们都具有相同的架构。因此,我想使用相同的持久性单元/ DAO等,而又不想设置10个EntityManager,10个持久性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等再次执行?
非常感谢您的任何提前帮助!
经过几次尝试,我发现了一个合适的解决方案。
首先请看一下: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来执行工作。
祝好运!