正文

SpringMVC配置多个数据源

IP云
IP云V管理员/5 阅读
06/18
提示：扫一扫查出行
【扫一扫了解最新限行尾号】
复制提示

多数据源，说白了，就是多数据库。

想要实现多数据库查询，只需简单四步即可实现！ 但这种实现方式有缺点，不能够实时切换数据库。有时间我会补一篇，通过AOP实现数据库切换的博客，通过aop+注解实现比较好。

第一步： 配置 jdbc.properties；

# MySQL
#============================================================================
jdbc.mysql.driver=com.mysql.jdbc.Driver
jdbc.mysql.url=jdbc:mysql://127.0.0.1:3306/test?useUnicode=true&characterEncoding=UTF-8&allowMultiQueries=true
jdbc.mysql.username=root
jdbc.mysql.password=root # MS SQL Server (JTDS)
#============================================================================
jdbc.sqlserver.driver=net.sourceforge.jtds.jdbc.Driver
jdbc.sqlserver.url=jdbc:jtds:sqlserver://127.0.0.1:1433/test
jdbc.sqlserver.username=sa
jdbc.sqlserver.password=sa # 通用配置
#============================================================================
jdbc.initialSize=5
jdbc.minIdle=5
jdbc.maxIdle=20
jdbc.maxActive=100
jdbc.maxWait=100000

第二步：配置 spring-mybatis.xml；

<!-- 多数据源配置 -->
<bean id="sqlServerDataSource" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
<property name="driverClassName" value="${jdbc.sqlserver.driver}"/>
<property name="url" value="${jdbc.sqlserver.url}"/>
<property name="username" value="${jdbc.sqlserver.username}"/>
<property name="password" value="${jdbc.sqlserver.password}"/>
<property name="initialSize" value="${jdbc.initialSize}"/>
<property name="minIdle" value="${jdbc.minIdle}"/>
<property name="maxIdle" value="${jdbc.maxIdle}"/>
<property name="maxActive" value="${jdbc.maxActive}"/>
<property name="maxWait" value="${jdbc.maxWait}"/>
<property name="defaultAutoCommit" value="${jdbc.defaultAutoCommit}"/>
<property name="removeAbandoned" value="${jdbc.removeAbandoned}"/>
<property name="removeAbandonedTimeout" value="${jdbc.removeAbandonedTimeout}"/>
<property name="testWhileIdle" value="${jdbc.testWhileIdle}"/>
<property name="timeBetweenEvictionRunsMillis" value="${jdbc.timeBetweenEvictionRunsMillis}"/>
<property name="numTestsPerEvictionRun" value="${jdbc.numTestsPerEvictionRun}"/>
<property name="minEvictableIdleTimeMillis" value="${jdbc.minEvictableIdleTimeMillis}"/>
</bean>
<bean id="mySqlDataSource" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
<property name="driverClassName" value="${jdbc.mysql.driver}"/>
<property name="url" value="${jdbc.mysql.url}"/>
<property name="username" value="${jdbc.mysql.username}"/>
<property name="password" value="${jdbc.mysql.password}"/>
<property name="initialSize" value="${jdbc.initialSize}"/>
<property name="minIdle" value="${jdbc.minIdle}"/>
<property name="maxIdle" value="${jdbc.maxIdle}"/>
<property name="maxActive" value="${jdbc.maxActive}"/>
<property name="maxWait" value="${jdbc.maxWait}"/>
<property name="defaultAutoCommit" value="${jdbc.defaultAutoCommit}"/>
<property name="removeAbandoned" value="${jdbc.removeAbandoned}"/>
<property name="removeAbandonedTimeout" value="${jdbc.removeAbandonedTimeout}"/>
<property name="testWhileIdle" value="${jdbc.testWhileIdle}"/>
<property name="timeBetweenEvictionRunsMillis" value="${jdbc.timeBetweenEvictionRunsMillis}"/>
<property name="numTestsPerEvictionRun" value="${jdbc.numTestsPerEvictionRun}"/>
<property name="minEvictableIdleTimeMillis" value="${jdbc.minEvictableIdleTimeMillis}"/>
</bean>

<bean id="dataSource" class="xx.xxx.DynamicDataSource"><!--注意： 这里写选择数据源的类地址 下面跟着给出-->
<property name="defaultTargetDataSource" ref="mySqlDataSource"/><!-- 设置默认为此mySqlDataSource数据源-->
<property name="targetDataSources">
<map>
<entry key="mySqlDataSource" value-ref="mySqlDataSource"/>
<entry key="sqlServerDataSource" value-ref="sqlServerDataSource"/>
</map>
</property>
</bean>

第三步：添加数据源的类；（借助ThreadLocal类，通过ThreadLocal类传递数据源的参数）

import org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource;
/*
* 配置多数据源
*/ public class DynamicDataSource extends AbstractRoutingDataSource{ public static final String mySqlDataSource= "mySqlDataSource"; public static final String sqlServerDataSource = "sqlServerDataSource";
//本地线程，获取当前正在执行的currentThread
public static final ThreadLocal<String> contextHolder = new ThreadLocal<String>(); public static void setCustomerType(String customerType) { contextHolder.set(customerType); } public static String getCustomerType() {
return contextHolder.get();
} public static void clearCustomerType() {
contextHolder.remove();
} @Override
protected Object determineCurrentLookupKey() {
return getCustomerType();
}
}

最后一步：使用；

public void findOrder(){
List<PayOrder> list = new ArrayList<>();
DynamicDataSource.clearCustomerType();//重点： 实际操作证明，切换的时候最好清空一下
DynamicDataSource.setCustomerType(DynamicDataSource.sqlServerDataSource）;//切换数据源，设置后 就OK了。可以随时切换过来（在controller层切换）
list =mapper.findByUid("-14663");
System.out.println(list);

DynamicDataSource.clearCustomerType();//
DynamicDataSource.setCustomerType(DynamicDataSource.sqlServerDataSource）;//切换回主数据源

}