标签：
Spring单数据源直接在<bean id="dataSource">下配置数据源的各种连接参数。但动态数据源需要配置个各个数据源例如ds1、ds2等。然后在dataSource中动态根据传递过来的参数动态调用不同的数据源。
1、当进行访问时，首先通过DbContextHolder.setDbType("ds1");设置需要使用的数据源。DbContextHolder就是一个用来存储数据源信息的类，其中通过ThreadLocal来记录数据源信息。
2、DynamicDataSource类集成Spring的AbstractRoutingDataSource类，通过determineCurrentLookupKey方法来获取数据源类型，如果没有对应的数据源则使用defaultTargetDataSource配置。
注意：当设置了数据源之后会一直使用该数据源进行连接，除非使用 DbContextHolder.setDbType重新设置数据源或使用DbContextHolder.clearDbType()清除，清除后使用defaultTargetDataSource进行连接。
1、配置文件
properties
ds1.driverClassName=oracle.jdbc.OracleDriver ds1.url=jdbc:oracle:thin:@localhost:1521:ORCL ds1.username=SSM ds1.password=SSM ds2.driverClassName=oracle.jdbc.OracleDriver ds2.url=jdbc:oracle:thin:@10.27.192.43:1522:ORCL ds2.username=FRAMEWORK_DEV ds2.password=123456
xml
<bean id="dataSource" class="com.cnpc.framework.db.DynamicDataSource"> <property name="targetDataSources"> <map key-type="java.lang.String"> <entry key="ds1" value-ref="ds1" /> <entry key="ds2" value-ref="ds2" /> </map> </property> <property name="defaultTargetDataSource" ref="ds1" /> </bean> <bean id="ds1" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close"> <property name="driverClassName" value="${ds1.driverClassName}" /> <property name="url" value="${ds1.url}" /> <property name="username" value="${ds1.username}" /> <property name="password" value="${ds1.password}" /> </bean> <bean id="ds2" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close"> <property name="driverClassName" value="${ds2.driverClassName}" /> <property name="url" value="${ds2.url}" /> <property name="username" value="${ds2.username}" /> <property name="password" value="${ds2.password}" /> </bean>
2、Java文件
com.cnpc.framework.db.DynamicDataSource 源码
public class DynamicDataSource extends AbstractRoutingDataSource { /** * 取得当前使用那个数据源。 */ @Override protected Object determineCurrentLookupKey() { return DbContextHolder.getDbType(); } public Logger getParentLogger() { // TODO Auto-generated method stub return null; } }
DbContextHolder 源码
public class DbContextHolder { private static final ThreadLocal<String> contextHolder = new ThreadLocal<String>(); /** * 设置当前数据库。 * @param dbType */ public static void setDbType(String dbType) { contextHolder.set(dbType); } /** * 取得当前数据源。 * @return */ public static String getDbType() { String str = (String) contextHolder.get(); return str; } /** * 清除上下文数据 */ public static void clearDbType() { contextHolder.remove(); } }
3、测试Code
public ModelAndView list(HttpServletRequest request, HttpServletResponse response) throws Exception { DbContextHolder.setDbType("ds1"); List<DemoSysUser> list1 = demoSysUserService.getAll(); System.out.println(DbContextHolder.getDbType() + ".list.size()=" + list1.size()); DbContextHolder.setDbType("ds2"); List<DemoSysUser> list2 = demoSysUserService.getAll(); System.out.println(DbContextHolder.getDbType() + ".list.size()=" + list2.size()); DbContextHolder.clearDbType(); List<DemoSysUser> list = demoSysUserService.getAll(); ModelAndView mv = this.getAutoView().addObject("sysUserList", list); return mv; }
标签：
原文地址：http://www.cnblogs.com/mkojpijh09080/p/5216950.html
