<font size="1">版权声明：本文为博主原创文章，未经博主允许不得转载。https://blog.csdn.net/qq_36523638/article/details/84571304</font>

Spring+mybatis动态切换数据源

这是基于mybatis的动态切换数据源

数据源连接池使用的为Druid

bean工厂使用的是mybatis的SqlSessionFactoryBean

1、配置第一个数据源：

#配置第一个数据源(具体配置视情况而定)：
<bean id="dataSourceA" class="com.alibaba.druid.pool.DruidDataSource" init-method="init" destroy-method="close">
        <property name="driverClassName" value="${jdbc.driver}"/>
        <property name="url" value="${jdbc.url}"/>
        <property name="username" value="${jdbc.username}"/>
        <property name="password" value="${jdbc.password}"/>
        <!--<property name="filters" value="stat,log4j"/>-->
        <property name="maxActive" value="20"/>
        <property name="initialSize" value="1"/>
        <property name="maxWait" value="60000"/>
        <property name="minIdle" value="1"/>
        <property name="timeBetweenEvictionRunsMillis" value="3000"/>
        <property name="minEvictableIdleTimeMillis" value="300000"/>
        <property name="validationQuery" value="SELECT 'x' FROM DUAL"/>
        <property name="testWhileIdle" value="true"/>
        <property name="testOnBorrow" value="false"/>
        <property name="testOnReturn" value="false"/>
        <property name="poolPreparedStatements" value="true"/>
        <property name="maxPoolPreparedStatementPerConnectionSize" value="20"/>
    </bean>

2、配置第二个数据源：

#配置第二个数据源(具体配置视情况而定)：
<bean id="dataSourceB" class="com.alibaba.druid.pool.DruidDataSource" init-method="init" destroy-method="close">
        <property name="driverClassName" value="${jdbc.driver}"/>
        <property name="url" value="${jdbc.url}"/>
        <property name="username" value="${jdbc.username}"/>
        <property name="password" value="${jdbc.password}"/>
    </bean>

#配置第三个数据源
#配置第四个数据源
...
...
#可以配置多个数据源，只要不超出连接池的限制就可以

3、配置动态的数据源（关键）这里的开关：MultipleDataSource在第5步说明

 <bean id="multipleDataSource" class="包名.MultipleDataSource">
        <!-- 这里可以设置一个默认的数据源 >
        <property name="defaultTargetDataSource" ref="dataSource" />
        <property name="targetDataSources">
            <map>
                <entry key="dataSourceA" value-ref="dataSourceA" />
                <entry key="dataSourceB" value-ref="dataSourceB" />
            </map>
        </property>
    </bean>

4、然后在配置sqlSessionFactory的配置文件中添加属性：

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

添加完后是这样：

<bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
        <property name="dataSource" ref="multipleDataSource"/>
        <一些插件的配置>
        ...
        </>
</bean>

5、包名.MultipleDataSource(动态切换开关)：

public class MultipleDataSource extends AbstractRoutingDataSource {

    private static final ThreadLocal<String> dataSourceKey = new InheritableThreadLocal<String>();

    public static void setDataSourceKey(String dataSource) {
        dataSourceKey.set(dataSource);
    }

    @Override
    protected Object determineCurrentLookupKey() {
        return dataSourceKey.get();
    }

    public static void removeDataSourceKey() {
        dataSourceKey.remove();
    }
}

6、最后自己写一个切面AOP来做数据源的切换：

/**
 * 数据源切换AOP
 */
@Aspect
@Order(Ordered.LOWEST_PRECEDENCE-1)
@Component
public class MultipleDataSourceInterceptor {
    /**
     * 拦截器对所有的业务实现类请求之前进行数据源切换 特别注意,由于用到了多数据源,Mapper的调用最好只在*ServiceImpl,不然调用到非默认数据源的表时,会报表不存在的异常
     *
     * @throws
     */
    @Pointcut("execution(* com..*Impl.*(..)) || execution(* com..*Mapper.*(..))")
    public void log(){
    }
    @Before("log()")
    public void setDataSoruce(JoinPoint joinPoint)
            throws Throwable {
        //int i=8;
        //int j=i/0;
        Class<?> clazz = joinPoint.getTarget().getClass();
        String className = clazz.getName();
        if (ClassUtils.isAssignable(clazz, Proxy.class)) {
            className = joinPoint.getSignature().getDeclaringTypeName();
        }

        // 对包名含有serverwpms的设置为wpms数据源,否则默认为后台的数据源
        if (className.contains(".serverwpms.")) {
                MultipleDataSource.setDataSourceKey("dataSourceA");
        }else if (className.contains(".server.") || className.contains(".mapper.")) {
                MultipleDataSource.setDataSourceKey("dataSourceB");
        }
    }

    /**
     * 当操作完成时,释放当前的数据源 如果不释放,频繁点击时会发生数据源冲突,本是另一个数据源的表,结果跑到另外一个数据源去,报表不存在
     *
     * @param joinPoint
     * @throws Throwable
     */
    @After("log()")
    public void removeDataSoruce(JoinPoint joinPoint)
            throws Throwable {
        MultipleDataSource.removeDataSourceKey();
    }
}

aop在springmvc的配置文件中定义下：

    <!-- 定义aspect类 -->
    <bean name="multipleDataSourceInterceptor" class="包名.MultipleDataSourceInterceptor"/>

<font size="4" color="red"> ----到这，系统中如果没有用到事务，多数据源的配置就完成了，aop会根据你想要的需求去动态切换数据源，如果用到事务的话，仅仅到这是不够的</font>

查阅资料说事务管理器是从connection级别来处理的，尤其是非常方便的DataSourceTransactionManager管理器，方法上用一个@Transactional注解就可以完成事务管理。

DataSourceTransactionManager管理器会对connection进行缓存（大概是这个意思），导致我们的aop MultipleDataSourceInterceptor虽然将数据源A的字符串切换为了数据源B，但是根本上的connection是并没有切换回来的，这时候如果本该对数据源A操作的sql去操作数据源B了，会报表不存在的错误。

<font size = "4" color="blue">这时候应该怎么解决呢，其实主要是事务管理器执行的优先级比我们的aop优先级高罢了，每次都是事务管理器先执行，然后aop才去切换数据源，发现并没有切换过来，手动设置下aop的优先级高于事务管理器就好了,而事务管理器的优先级默认为Order(1),也就是我之前所见过的最高的优先级了</font>

<font size="5" color="green"></font>

上面<font size="5" color="red">@Order(Ordered.LOWEST_PRECEDENCE-1)</font>为关键，意思是给aop定一个优先级，这个优先级为多少呢， Ordered.LOWEST_PRECEDENCE为最低的order,大家都知道，Order越低，优先级越高，事务管理器默认优先级为1，这个aop的order比最低的Order还要小一个单位，代表优先级是最高的。

注：事务管理器我是这么配置的：

<!-- 配置事务管理器，注意这里的dataSource和SqlSessionFactoryBean的dataSource要一致，不然事务就没有作用了 -->
    <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <property name="dataSource" ref="multipleDataSource"/>
    </bean>

    <!-- 用注解来实现事务管理 -->
    <tx:annotation-driven transaction-manager="transactionManager"/>