Spring实现多数据源动态切换

1、在applicationContext.xml中配置

<bean id="dataSource1" class="com.alibaba.druid.pool.DruidDataSource" init-method="init" destroy-method="close"> 
		<property name="driverClassName" value="oracle.jdbc.OracleDriver" />
	    <!-- 基本属性 url、user、password -->
		<property name="url" value="jdbc:oracle:thin:@127.0.0.1:1521:test" />
		<property name="username" value="test" />
		<property name="password" value="test" />
		  
		<!-- 配置初始化大小、最小、最大 -->
		<property name="initialSize" value="10" />
		<property name="minIdle" value="5" />
		<property name="maxActive" value="60" />
	 
		<!-- 配置获取连接等待超时的时间 -->
		<property name="maxWait" value="60000" />
	 
		<!-- 配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位是毫秒 -->
		<property name="timeBetweenEvictionRunsMillis" value="60000" />
	 
		<!-- 配置一个连接在池中最小生存的时间，单位是毫秒 -->
		<property name="minEvictableIdleTimeMillis" value="300000" />
	  
		<property name="validationQuery" value="select 1 from dual" />
		<property name="testWhileIdle" value="true" />
		<property name="testOnBorrow" value="false" />
		<property name="testOnReturn" value="false" />
	 
		<!-- 打开PSCache，并且指定每个连接上PSCache的大小 -->
		<property name="poolPreparedStatements" value="true" />
		<property name="maxPoolPreparedStatementPerConnectionSize" value="20" />
	</bean>
	
	<bean id="dataSource2" class="com.alibaba.druid.pool.DruidDataSource" init-method="init" destroy-method="close"> 
		<property name="driverClassName" value="oracle.jdbc.OracleDriver" />
	    <!-- 基本属性 url、user、password -->
		<property name="url" value="jdbc:oracle:thin:@127.0.0.1:1521:orcl" />
		<property name="username" value="orcl" />
		<property name="password" value="orcl" />
		  
		<!-- 配置初始化大小、最小、最大 -->
		<property name="initialSize" value="10" />
		<property name="minIdle" value="5" />
		<property name="maxActive" value="60" />
	 
		<!-- 配置获取连接等待超时的时间 -->
		<property name="maxWait" value="60000" />
	 
		<!-- 配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位是毫秒 -->
		<property name="timeBetweenEvictionRunsMillis" value="60000" />
	 
		<!-- 配置一个连接在池中最小生存的时间，单位是毫秒 -->
		<property name="minEvictableIdleTimeMillis" value="300000" />
	  
		<property name="validationQuery" value="select 1 from dual" />
		<property name="testWhileIdle" value="true" />
		<property name="testOnBorrow" value="false" />
		<property name="testOnReturn" value="false" />
	 
		<!-- 打开PSCache，并且指定每个连接上PSCache的大小 -->
		<property name="poolPreparedStatements" value="true" />
		<property name="maxPoolPreparedStatementPerConnectionSize" value="20" />
	</bean>
	
	<!-- 指定DynamicDataSource类-->
	<bean id="dynamicDataSource" class="com.zlz.utils.db.DynamicDataSource" >  
        <!-- 通过key-value的形式来关联数据源 -->  
        <property name="targetDataSources">  
            <map key-type="java.lang.String">  
                <entry value-ref="bisDataSource" key="dataSource1"></entry>  
                <entry value-ref="fssDataSource" key="dataSource2"></entry> 
            </map>  
        </property>  
        <property name="defaultTargetDataSource" ref="dataSource1" >  
        </property>  
    </bean>   
           

2、定义自定义的DynamicDataSource类

package com.zlz.utils.db;

import org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource;

public class DynamicDataSource extends AbstractRoutingDataSource {
	
	//核心方法
	@Override
	protected Object determineCurrentLookupKey() {
		return JdbcContextHolder.getJdbcType();
	}
}
           

3、定义工具类，实现切换

public class JdbcContextHolder 
{
	//本地线程
	private static final ThreadLocal<String> contextHolder = new ThreadLocal<String>();

	public static void setJdbcType(String jdbcType)
	{
		contextHolder.set(jdbcType);
	}

	public static String getJdbcType() 
	{
		//获取内容上下文配置
		return (String) contextHolder.get();
	}

	public static void clearJdbcType() 
	{
		//移除内容上下文配置
		contextHolder.remove();
	}
}
           

4、在切换数据源的时候调用

JdbcContextHolder.setJdbcType("dataSource2");
           

<span style="font-family: Arial, Helvetica, sans-serif;">不能在事务中切换数据源，同一事务中，该方法无法实现多数据源的切换，如果要使用事务，那么在controller中进行数据源的切换。</span>