Spring动态配置多数据源的简介
发布网友
发布时间：2022-04-23 14:36
共1个回答
热心网友
时间：2022-04-07 23:55
Spring配置多数据源的方式和具体使用过程。
Spring对于多数据源，以数据库表为参照，大体上可以分成两大类情况：
一是，表级上的跨数据库。即，对于不同的数据库却有相同的表（表名和表结构完全相同）。
二是，非表级上的跨数据库。即，多个数据源不存在相同的表。
Spring2.x的版本中采用Proxy模式，就是我们在方案中实现一个虚拟的数据源，并且用它来封装数据源选择逻辑，这样就可以有效地将数据源选择逻辑从Client中分离出来。Client提供选择所需的上下文（因为这是Client所知道的），由虚拟的DataSource根据Client提供的上下文来实现数据源的选择。 具体的实现就是，虚拟的DataSource仅需继承AbstractRoutingDataSource实现determineCurrentLookupKey（）在其中封装数据源的选择逻辑。
一、动态配置多数据源
1. 数据源的名称常量类：
package com.frogking.datasource;
public class DataSourceConst {
public static final String Admin=Admin;
public static final String User = User;
}
2. 建立一个获得和设置上下文环境的类，主要负责改变上下文数据源的名称： package com.frogking.datasource;
public class DataSourceContextHolder {
private static final ThreadLocal contextHolder =
new ThreadLocal(); // 线程本地环境
// 设置数据源类型
public static void setDataSourceType(String dataSourceType) {
contextHolder.set(dataSourceType);
}
// 获取数据源类型
public static String getDataSourceType() {
return (String) contextHolder.get();
}
// 清除数据源类型
public static void clearDataSourceType () {
contextHolder.remove();
}
}
3. 建立动态数据源类，注意，这个类必须继承AbstractRoutingDataSource，且实现方法determineCurrentLookupKey，该方法返回一个Object，一般是返回字符串： package com.frogking.datasource;
publicclass DynamicDataSource extends AbstractRoutingDataSource {
@Override
protected Object determineCurrentLookupKey() {
// 在进行DAO操作前，通过上下文环境变量，获得数据源的类型
return DataSourceContextHolder. getDataSourceType();
}
}
4. 编写spring的配置文件配置多个数据源
<!-- 数据源相同的内容 -->
<bean class=org.springframework.jdbc.datasource.DriverManagerDataSource id=parentDataSource>
<property name=driverClassName>
<value>com.mysql.jdbc.Driver</value>
</property>
<property name=username>
<value>root</value>
</property>
<property name=password>
<value>1234</value>
</property>
</bean>
<!-- 以下配置各个数据源的特性 -->
<!-- 数据库test -->
<bean parent=parentDataSource id=adminDataSource>
<property name=url>
<value>jdbc:mysql://localhost:3306/test</value>
</property>
</bean>
<!-- 不同的数据库test2 -->
<bean parent=parentDataSource id=userDataSource>
<property name=url>
<value>jdbc:mysql://localhost:3306/test2</value>
</property>
</bean>
<!-- end 配置各个数据源的特性 -->
5. 编写spring配置文件配置多数据源映射关系
<bean class=com.frogking.datasource.DynamicDataSource id=dataSource>
<property name=targetDataSources>
<map key-type=java.lang.String>
<entry value-ref= adminDataSource key=Admin></entry>
<entry value-ref= userDataSource key=User></entry>
</map>
</property>
<property name=defaultTargetDataSource ref=adminDataSource >
</property>
</bean>
在这个配置中第一个property属性配置目标数据源，<map key-type=java.lang.String>中的key-type必须要和静态键值对照类DataSourceConst中的值的类型相 同；<entry key=User value-ref=userDataSource/>中key的值必须要和静态键值对照类中的值相同，如果有多个值，可以配置多个< entry>标签。第二个property属性配置默认的数据源。
6. 配置hibernate，和普通的hibernate、spring结合的配置一样：
<!-- sessionFactory的配置 -->
<BEAN class=org.springframework.orm.hibernate3.LocalSessionFactoryBean id=sessionFactory>
<property name=dataSource>
<REF local=dataSource> </REF>
</property>
<!-- 实体类资源映射 -->
<property name=mappingResources>
<LIST>
<VALUE>com/frogking/entity/User.hbm.xml </VALUE>
<VALUE>com/frogking/entity/Admin.hbm.xml</VALUE> </LIST>
</property>
<!-- 为sessionFactory 配置Hibernate属性 -->
<property name=hibernateProperties>
<PROPS>
<PROP key=hibernate.dialect> org.hibernate.dialect.MySQLDialect
</PROP>
<PROP key=hibernate.show_sql>true</PROP> <PROP key=hibernate.connection.autocommit>false</PROP> <PROP key=hibernate.cache.use_query_cache>false</PROP> <PROP key=hibernate.max_fetch_depth>2</PROP> <PROP key=hibernate.bytecode.use_reflection_optimizer>true</PROP>
</PROPS>
</property>
</BEAN>
<!-- 为配置sessionFactory -->
<BEAN class=com.frogking..LoginHibernateDao id=loginDao>
<property name=sessionFactory>
<REF local=sessionFactory> </REF>
</property>
</BEAN>
