请教有关spring多数据库配置的问

1.解决方案：

property name="<.commonsvalue=" value="close".properties文件

2.配置多个数据库：

jdbcminEvictableIdleTimeMillis"driverClassName".maxActive}" /

password}".url}"${jdbc>.driver3600000"maxActive">${jdbc.driver}"

/username"${dbcp

</ value=".dbcpurl".BasicDataSource"

<value="bean id=".username}"

<value="

<>password"${dbcporg.dataSource"false" /

<property name=" destroy-method="3600000"

applicationproperty name=" class=",property name="

<value=">.apachevalue=" /property name=">

<${jdbcproperty name="property name=">.

1、首先配置多个datasource

<!-- 主数据库的数据据源 -->

<bean id="masterDataSource" class="org.apache.commons.dbcp.BasicDataSource"

destroy-method="close">

<property name="driverClassName" value="oracle.jdbc.OracleDriver" />

<property name="url" value="jdbc:oracle:thin:@192.168.10.11:1521:trew" />

<property name="username" value="poi" />

<property name="password" value="poi" />

</bean>

<!-- 备份库的数据据源 -->

<bean id="slaveDataSource" class="org.apache.commons.dbcp.BasicDataSource"

destroy-method="close">

<property name="driverClassName" value="oracle.jdbc.OracleDriver" />

<property name="url" value="jdbc:oracle:thin:@192.168.10.12:1521:trew" />

<property name="username" value="poi2" />

<property name="password" value="poi2" />

</bean>

2、写一个DynamicDataSource类继承AbstractRoutingDataSource，并实现determineCurrentLookupKey方法

?

public class DynamicDataSource extends AbstractRoutingDataSource {

@SuppressWarnings("unused")

private Log logger = LogFactory.getLog(getClass())

@Override

protected Object determineCurrentLookupKey() {

return DbContextHolder.getDbType()

}

}

public class DbContextHolder {

@SuppressWarnings("rawtypes")

private static final ThreadLocal contextHolder = new ThreadLocal()

@SuppressWarnings("unchecked")

public static void setDbType(String dbType) {

contextHolder.set(dbType)

}

public static String getDbType() {

return (String) contextHolder.get()

}

public static void clearDbType() {

contextHolder.remove()

}

}

3. 配置动态数据源

<!--将DynamicDataSource Bean加入到Spring的上下文xml配置文件中去，同时配置DynamicDataSource的targetDataSources(多数据源目标)属性的Map映射。-->

<bean id="dataSource" class="cn.com.core.datasource.DynamicDataSource">

<property name="targetDataSources">

<map key-type="java.lang.String">

<entry key="masterDataSource" value-ref="masterDataSource" />

<entry key="slaveDataSource" value-ref="slaveDataSource" />

</map>

</property>

<property name="defaultTargetDataSource" ref="masterDataSource"/>

</bean>

4.使用动态数据源(hibernate)

<bean id="sessionFactory"

class="org.springframework.orm.hibernate3.LocalSessionFactoryBean">

<property name="dataSource" ref="dataSource" />

<property name="lobHandler" ref="lobHandler"/>

<property name="eventListeners">

<map>

<entry key="post-insert">

<ref bean="logListener"/>

</entry>

<entry key="post-update">

<ref bean="logListener"/>

</entry>

<entry key="post-delete">

<ref bean="logListener"/>

</entry>

</map>

</property>

<property name="hibernateProperties">

<props>

<prop key="hibernate.dialect">

org.hibernate.dialect.Oracle10gDialect

<!-- org.hibernate.dialect.OracleDerbyDialect -->

</prop>

<prop key="hibernate.show_sql">true</prop>

<!-- <prop key="hibernate.generate_statistics">true</prop>-->

<prop key="hibernate.connection.release_mode">

auto

</prop>

<prop key="hibernate.autoReconnect">true</prop>

<!--

<prop key="hibernate.hbm2ddl.auto">update</prop>

-->

<prop key="hibernate.cache.use_second_level_cache">false</prop>

<prop key="hibernate.cache.provider_class">

org.hibernate.cache.EhCacheProvider

</prop>

<prop key="hibernate.cache.use_query_cache">false</prop>

</props>

</property>

</bean>

使用Hibernate时的事务管理配置示例：

<bean id="transactionManager" class="org.springframework.orm.hibernate3.HibernateTransactionManager">

<property name="sessionFactory" ref="sessionFactory" />

bean>

场景描述：有多个数据库，每个数据库可能分布在不同的mysql instance上面，有多个存储过程，每个存储过程可能分布在不同的数据库中，需要有两个配置文件。

1. mysql 数据库映射：

A.driverClassName=com.mysql.jdbc.Driver

A.url=jdbc:mysql://172.20.7.51:3308/blog

A.username=trappuser

A.password=Opera1!

B.driverClassName=com.mysql.jdbc.Driver

B.url=jdbc:mysql://localhost:3306/wedding

B.username=root

B.password=opera

上面定义的A、B为两个mysql instance的缩写。

2. 存储过程与mysql instance的映射关系：

SP_Get_User=A

GetStocks=B

定义两个模拟存储过程，第一个数据库“SP_Get_User“是在数据库A下面，第二个数据库”GetStocks“是在数据库B下面。

3. 建立自定义的sessionFactory

3.1 xml配置的datasource及sessionFactory如下：

<bean class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close" id="dataSource">

<property name="driverClassName" value="${database.driverClassName}"/>

<property name="url" value="${database.url}"/>

<property name="username" value="${database.username}"/>

<property name="password" value="${database.password}"/>

</bean>

<bean id="sessionFactory" class="org.springframework.orm.hibernate4.LocalSessionFactoryBean">

<property name="dataSource" ref="dataSource"/>

<property name="packagesToScan" value="com.xx.assetcommander">

</property>

<property name="hibernateProperties">

<props>

<prop key="hibernate.dialect">org.hibernate.dialect.MySQLDialect</prop>

<prop key="hibernate.show_sql">true</prop>

</props>

</property>

</bean>

此处我们定义的sessionFactory的类型为LocalSessionFactoryBean，它是一个工厂对象，与我们再需要的 SessionFactory不是一回事，我们需要的sessionfactory是org.hibernate.SessionFactory，这个对象可以被第一个sessionFactory的getObject()方法生成。

3.2 由于我们连接的是多个mysql instance， 不方便在xml中配置多个datasource和多个sessionFactory，故可以通过纯java的形式开发，可以使用map来存储存储过程与mysql database的关系，将存储过程的名字和数据库建议关系，这样通过存储过程的名称就能得到数据库的缩写名，通过数据库的缩写名能够找到对应的mysql instance，使用纯java开发的过程类似于xml配置，如下：

ds.setDriverClassName(getDriver())

ds.setUrl(getUrl())

ds.setUsername(getUsername())

ds.setPassword(getPassword())

LocalSessionFactoryBean sessionFactory = new LocalSessionFactoryBean()

sessionFactory.setDataSource(ds)

sessionFactory.setPackagesToScan("com.xx.assetcommander")

Properties params = new Properties()

params.setProperty("hibernate.dialect",

"org.hibernate.dialect.MySQLDialect")

params.setProperty("hibernate.show_sql", "true")

sessionFactory.setHibernateProperties(params)

当我们获得可以使用的LocalSessionFactoryBean时候，在调用getObject()获得SessionFactory之前，必须要调用afterPropertiesSet()方法，否则得到的sessionFactory为空。

public Session getDsBySp(String spName) throws IOException {

//get the corresponding mysql database shortname by sp name

String dbName = getDbForSP(str)

//get the corresponding mysql instance connection by mysql database shortname

LocalSessionFactoryBean fB = getDsByDb(dbName)

// don't forget this line or null will be returned when you call getObject() method.

fB.afterPropertiesSet()

return fB.getObject().openSession()

}

注：在tomcat启动时，如果没有配置任何datasource，会出现如下错误：

org.springframework.beans.factory.NoSuchBeanDefinitionException: No qualifying bean of type [javax.persistence.EntityManagerFactory] is defined

故需要配置默认的datasource.

这种方式需要做到不同的数据库instance直接业务的完全独立，不可以出现跨数据库的表join，否则处理难度会增加。

还有就是对于多数据库直接的事务管理如何去处理？

---