是否可以在 spring 中使用具有多个数据源的相同持久性单元?
例如。我有两个数据库。他们在不同的服务器上。一种仅用于写入操作(插入、更新、删除等),另一种仅用于读取操作。它们都使用相同的结构。那么我可以为它们都使用一个持久性单元吗?
我发现这个ReplicationDriver可以解决我的问题。我只定义了我的主服务器和从服务器,在代码方面我只定义了@Transaction(readOnly=true)。因此,当事务为readOnly=true时,管理器使用我的从属,其他情况根据连接器/j文档使用我的主控。现在使用这个tomcat时无法连接到我的数据库。我的意思是它只是等待什么都没有发生。这是我的 apache tomcat context.xml
<?xml version='1.0' encoding='utf-8'?>
<Context>
<WatchedResource>WEB-INF/web.xml</WatchedResource>
<Resource
auth="Container"
driverClassName="com.mysql.jdbc.ReplicationDriver"
maxActive="250"
maxIdle="100"
maxWait="30"
validationQuery="select 1"
name="mysql/test"
type="javax.sql.DataSource"
url="jdbc:mysql:replication://address=(host=master)(user=root)(password=mroot),address=(host=slave)(user=root)(password=sroot)/test?autoReconnect=true&useUnicode=true&characterEncoding=UTF8&failOverReadOnly=false&maxReconnects=10"
/>
</Context>
这是我的spring context.xml
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:jee="http://www.springframework.org/schema/jee"
xmlns:tx="http://www.springframework.org/schema/tx"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/jee http://www.springframework.org/schema/jee/spring-jee.xsd
http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd">
<bean class="org.springframework.orm.jpa.support.PersistenceAnnotationBeanPostProcessor" />
<tx:annotation-driven/>
<bean id="jpaVendorAdapter" class="org.springframework.orm.jpa.vendor.EclipseLinkJpaVendorAdapter"/>
<jee:jndi-lookup id="dataSource" jndi-name="mysql/test" expected-type="javax.sql.DataSource" />
<bean id="entityManagerFactory" class="org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean">
<property name="persistenceUnitName" value="test_pu" />
<property name="dataSource" ref="dataSource"/>
<property name="jpaVendorAdapter" ref="jpaVendorAdapter" />
</bean>
<bean id="transactionManager" class="org.springframework.orm.jpa.JpaTransactionManager">
<property name="entityManagerFactory" ref="entityManagerFactory"/>
</bean>
<bean class="org.springframework.dao.annotation.PersistenceExceptionTranslationPostProcessor"/>
</beans>
我怎么了?为什么tomcat无法连接到db?顺便使用eclipslink provider v2.4.0
更新
我不知道为什么,但是当我使用jdbc:mysql://address这种格式时,我的程序无法连接到数据库并给出以下异常
Caused by: java.lang.NullPointerException
at com.mysql.jdbc.NonRegisteringDriver.parseHostPortPair(NonRegisteringDriver.java:204)
at com.mysql.jdbc.ConnectionImpl.coreConnect(ConnectionImpl.java:2235)
at com.mysql.jdbc.ConnectionImpl.connectOneTryOnly(ConnectionImpl.java:2284).
但是当使用jdbc:mysql://host1,host2格式连接成功。如果我们使用第二个版本,我应该为每个连接使用相同的用户名和密码,但第一个版本我们可以定义不同的用户名和密码。根据 MySQL 连接器 J 文档
以下是连接到 MySQL 服务器的 JDBC URL 的另一种格式,这对于 IPv6 连接是强制性的,但也可以与 IPv4 一起使用(方括号 ([ ]) 中的项目是可选的):
jdbc:mysql://address=(key1=value)[(key2=value)]...[,address=(key3=value)[(key4=value)]...]...[/[数据库]]» [?propertyName1=propertyValue1[&propertyName2=propertyValue2]...]
这意味着这也适用于 IP4,但不起作用。有什么我想念我的配置的吗?