SSM多数据源配置（MySQL+Oracle）

柔光的暖阳◎ 2023-06-18 14:58 3阅读 0赞

## 背景 ##

> 最近在写一个小项目时，项目数据库是MySQL。但是项目中需要获取另外一个数据库的数据以便使用，并且另一个数据库是Oracle。所以就需要在项目中配置多数据源。下面就简单介绍下SSM框架是如何配置多数据源的。

## 原理 ##

> MyBatis在创建SqlSession时，动态的使用不同的DataSource，这样就可以动态的使用不同的数据源。如何动态的使用不同的dataSource。在Spring框架中，提供了一个类AbstractRoutingDataSource：路由选择。该类AbstractRoutingDataSource继承AbstractDataSource，AbstractDataSource又实现了DataSource，因此，可以使用AbstractRoutingDataSource来完成我们的需求。AbstractRoutingDataSource中有一个determineTargetDataSource()方法，该方法是用来决定目标数据源的；而determineTargetDataSource()方法中通过determineCurrentLookupKey()方法来决定lookupKey；然后使用封装好了的map集合resolvedDataSources，通过lookupKey为key值取得dataSource。因此这里最重要的就是determineCurrentLookupKey()方法获取key值，在这里Spring把这个方法抽象出来，交给我们来实现。

## 实现 ##

### 多数据源相关类 ###

### 数据源路由器AbstractRoutingDataSource ###

package com.xuchen.datasource;
    
    import org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource;
    
    /**
     * @author 小小渔夫
     * @description 动态数据源
     */
    public class DynamicDataSource extends AbstractRoutingDataSource {
    
        @Override
        protected Object determineCurrentLookupKey() {
            return DataSourceSwitch.getDataSourceType();
        }
    
    }

### 自定义类DataSourceSwitch ###

package com.xuchen.datasource;
    
    /**
     * @author 小小渔夫
     * @description: 自定义类：用来保存数据源标识，从而在实例化DynamicDataSource时来指定要使用的数据源实例
     */
    public class DataSourceSwitch {
    
        /**
         * 保存数据源类型线程安全容器
         */
        private static final ThreadLocal<String> contextHolder = new ThreadLocal<String>();
    
        /**
         * 设置数据源类型
         * @param dataSourceType 数据源类型
         */
        public static void setDataSourceType(String dataSourceType) {
            contextHolder.set(dataSourceType);
        }
    
        /**
         * 获取数据源类型
         * @return
         */
        public static String getDataSourceType() {
            return (String) contextHolder.get();
        }
    
        /**
         * 清空数据源类型
         */
        public static void clearDataSourceType() {
            contextHolder.remove();
        }
    
    }

### 数据源标识 ###

package com.xuchen.datasource;
    
    /**
     * @author 小小渔夫
     * @description 数据源标识
     */
    public class DataSourceDialect {
        public static final String ORACLE = "oracle";
        public static final String MYSQL = "mysql";
    }

### 配置文件 ###

**jdbc.properties**

# mysql数据库配置文件
    db.driverClass=com.mysql.jdbc.Driver
    db.url=jdbc:mysql://127.0.0.1:3306/xxx?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true
    db.username=root
    db.password=xxx
    
    # Oracle数据库配置文件
    ora.driverClass=oracle.jdbc.driver.OracleDriver
    ora.url=jdbc:oracle:thin:@(DESCRIPTION =(ADDRESS_LIST =(ADDRESS =(PROTOCOL = TCP)(HOST = xx.x.xx.x)(PORT = 1521)))(CONNECT_DATA =(SID = xxx)))
    ora.username=xxxx
    ora.password=xxxx

**spring-mybatis.xml**

<?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns="http://www.springframework.org/schema/beans"
           xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
           xmlns:context="http://www.springframework.org/schema/context" xmlns:tx="http://www.springframework.org/schema/tx"
           xsi:schemaLocation="http://www.springframework.org/schema/beans
                            http://www.springframework.org/schema/beans/spring-beans-3.1.xsd
                            http://www.springframework.org/schema/context
                            http://www.springframework.org/schema/context/spring-context-3.1.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd">
        
        <context:component-scan base-package="com.xuchen"/>
        
        <bean id="propertyConfigurer" class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
            <property name="location" value="classpath:jdbc.properties"/>
        </bean>
        
        <bean id="mysqlDataSources" class="com.alibaba.druid.pool.DruidDataSource"
              init-method="init" destroy-method="close">
            
            <property name="driverClassName" value="${db.driverClass}"/>
            <property name="url" value="${db.url}"/>
            <property name="username" value="${db.username}"/>
            <property name="password" value="${db.password}"/>
            
            <property name="initialSize" value="3"/>
            <property name="minIdle" value="3"/>
            <property name="maxActive" value="20"/>
            
            <property name="maxWait" value="60000"/>
            
            <property name="timeBetweenEvictionRunsMillis" value="60000"/>
            
            <property name="minEvictableIdleTimeMillis" value="300000"/>
            <property name="validationQuery" value="SELECT 'x'"/>
            <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"/>
            
            <property name="filters" value="stat"/>
        </bean>
        <bean id="oracleDataSources" class="com.alibaba.druid.pool.DruidDataSource"
              init-method="init" destroy-method="close">
            
            <property name="driverClassName" value="${ora.driverClass}"/>
            <property name="url" value="${ora.url}"/>
            <property name="username" value="${ora.username}"/>
            <property name="password" value="${ora.password}"/>
        </bean>
        
        <bean id="dynamicDataSource" class="com.xuchen.datasource.DynamicDataSource">
            <property name="defaultTargetDataSource" ref="mysqlDataSources"/>    
            <property name="targetDataSources">
                <map key-type="java.lang.String">
                    <entry key="MYSQL" value-ref="mysqlDataSources"/>
                    <entry key="ORACLE" value-ref="oracleDataSources"/>
                </map>
            </property>
        </bean>
        
        <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
            <property name="dataSource" ref="dynamicDataSource"/>
            
            <property name="mapperLocations" value="classpath:com/xuchen/mapper/*.xml"/>
        </bean>
        
        <bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
            <property name="basePackage" value="com.xuchen.dao"/>
            <property name="sqlSessionFactoryBeanName" value="sqlSessionFactory"/>
        </bean>
    
        
        <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
            <property name="dataSource" ref="dynamicDataSource"/>
        </bean>
        
        <tx:annotation-driven transaction-manager="transactionManager" />
    </beans>

### 使用 ###

//service层
    public Motor getMotorOrder(String sernr) {
           DataSourceSwitch.setDataSourceType("ORACLE");
           Motor motor = motorDao.getMotorBySer(sernr);
           DataSourceSwitch.clearDataSourceType();
           return motor;
     }