Java配置多資料來源完整程式碼（SSM框架mysql +sqlserver資料庫）

阿新 • • 發佈：2018-12-08

記錄說明：專案使用Spring+SpringMVC+Mybatis框架，專案之前一直在使用mysql資料庫，後因專案對接需要，配置多資料來源增加sqlserver資料庫。
梳理一下相關的檔案：
1、pom.xml檔案（使用的是maven管理工具）
2、DataSource 介面註解檔案
3、DataSourceAspect 類檔案
4、DynamicDataSourceHolder 類檔案
5、MultipleDataSource 類檔案
6、jdbc.properties 配置檔案
7、spring-mybatis.xml 配置檔案
以上檔案缺一不可！！

pom.xml檔案增加依賴jar

    <dependency>
        <groupId>net.sourceforge.jtds</groupId>
        <artifactId>jtds</artifactId>
        <version>1.2.4</version>
    </dependency>
    <dependency>
        <groupId>com.microsoft.sqlserver</groupId>
        <artifactId 
>sqljdbc4</artifactId>
        <version>2.0</version>
    </dependency>

jar包下載：https://download.csdn.net/download/qq_35393472/10671922

DataSource 介面註解檔案

import java.lang.annotation.Documented;
import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import 
 java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;

/**
 * 此處用於定義DataSource註解，通過註解的方式指定需要訪問的資料來源
 * @author:lujingyu
 * @data:2018年9月17日下午2:10:54
 */
@Documented
@Target({ElementType.TYPE, ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
public @interface DataSource {
    String value();
}

DataSourceAspect 類檔案

import java.lang.reflect.Method;
import org.aspectj.lang.JoinPoint;
import org.aspectj.lang.reflect.MethodSignature;

public class DataSourceAspect {
/**
      * 攔截目標方法，獲取由@DataSource指定的資料來源標識，設定到執行緒儲存中以便切換資料來源
      * 
      * @param point
      * @throws Exception
      */
     public void intercept(JoinPoint point) throws Exception {
         Class<?> target = point.getTarget().getClass();
         MethodSignature signature = (MethodSignature) point.getSignature();
         // 預設使用目標型別的註解，如果沒有則使用其實現介面的註解
         for (Class<?> clazz : target.getInterfaces()) {
             resolveDataSource(clazz, signature.getMethod());
         }
         resolveDataSource(target, signature.getMethod());
     }

     /**
      * 提取目標物件方法註解和型別註解中的資料來源標識
      * 
      * @param clazz
      * @param method
     */
     private void resolveDataSource(Class<?> clazz, Method method) {
         try {
             Class<?>[] types = method.getParameterTypes();
             // 預設使用型別註解
             if (clazz.isAnnotationPresent(DataSource.class)) {
                 DataSource source = clazz.getAnnotation(DataSource.class);
                 DynamicDataSourceHolder.setDataSource(source.value());
             }
             // 方法註解可以覆蓋型別註解
             Method m = clazz.getMethod(method.getName(), types);
             if (m != null && m.isAnnotationPresent(DataSource.class)) {
                 DataSource source = m.getAnnotation(DataSource.class);
                 DynamicDataSourceHolder.setDataSource(source.value());
             }
         } catch (Exception e) {
             System.out.println(clazz + ":" + e.getMessage());
         }
     }

}

DynamicDataSourceHolder 類檔案

public class DynamicDataSourceHolder {
    /**
     * 注意：資料來源標識儲存線上程變數中，避免多執行緒操作資料來源時互相干擾
     */
    private static final ThreadLocal<String> THREAD_DATA_SOURCE = new ThreadLocal<String>();

    public static String getDataSource() {
        return THREAD_DATA_SOURCE.get();
    }

    public static void setDataSource(String dataSource) {
        THREAD_DATA_SOURCE.set(dataSource);
    }

    public static void clearDataSource() {
        THREAD_DATA_SOURCE.remove();
    }
}

MultipleDataSource 類檔案
注意此檔案是要給spring-mybatis.xml檔案呼叫所需要的

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

/**
 * 多資料來源使用
 * @author:lujingyu
 * @data:2018年9月15日下午2:33:40
 */
public class MultipleDataSource extends AbstractRoutingDataSource {
    @Override
    protected Object determineCurrentLookupKey() {
        // 從自定義的位置獲取資料來源標識
        return DynamicDataSourceHolder.getDataSource();
    }
}

jdbc.properties 配置檔案
檔案說明：主要看兩個資料來源的配置應該都很簡單，通用配置根據自己的需要去使用，也可以都拿過來使用，但是如果你要修改，那麼spring-mybatis.xml配置的時候就要以此修改

#mysql資料來源  使用該資料庫查詢時候 請在ServiceImpl類中增加註解：@DataSource("dataSource")
jdbc.driverClassName=com.mysql.jdbc.Driver
jdbc.url=jdbc\:mysql\://192.168.0.167\:3306/online_db
jdbc.username=root
jdbc.password=123456

#sqlserver資料來源 使用該資料庫查詢時候 請在ServiceImpl類中增加註解：@DataSource("sqlServerDataSource")
jdbc.sqlserver.driver=net.sourceforge.jtds.jdbc.Driver
jdbc.sqlserver.url=jdbc:jtds:sqlserver://192.168.0.117:1433/test_db
jdbc.sqlserver.username=lujingyu
jdbc.sqlserver.password=123456

#通用配置
jdbc.initialSize=3 
jdbc.minIdle=2
jdbc.maxActive=60
jdbc.maxWait=60000
jdbc.timeBetweenEvictionRunsMillis=60000
jdbc.minEvictableIdleTimeMillis=30000
jdbc.validationQuery=SELECT 'x'
jdbc.testWhileIdle=true
jdbc.testOnBorrow=false
jdbc.testOnReturn=false
jdbc.poolPreparedStatements=true
jdbc.maxPoolPreparedStatementPerConnectionSize=20
jdbc.removeAbandoned=true
jdbc.removeAbandonedTimeout=120
jdbc.logAbandoned=false
jdbc.filters=stat

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:aop="http://www.springframework.org/schema/aop"
    xmlns:tx="http://www.springframework.org/schema/tx" xmlns:context="http://www.springframework.org/schema/context"
    xsi:schemaLocation="
            http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.0.xsd
            http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-4.0.xsd
            http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.0.xsd
            http://www.springframework.org/schema/jee http://www.springframework.org/schema/jee/spring-jee-4.0.xsd
            http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.0.xsd">
    <!-- 自動掃描(自動注入) -->
    <context:component-scan base-package="com.newcsp.*.service;com.newcsp.*.*.service" />
    <!-- 定時任務 -->
    <!-- <context:component-scan base-package="com.newcsp.common.timer"/> -->

    <bean id="log-filter" class="com.alibaba.druid.filter.logging.Log4jFilter">
        <property name="resultSetLogEnabled" value="true" />
    </bean>
    <!-- 重要！！！配置資料來源mysql的下面的property 根據你jdbc.properties檔案去配 -->
    <bean name="dataSource" class="com.alibaba.druid.pool.DruidDataSource"
        init-method="init" destroy-method="close">
        <property name="driverClassName" value="${jdbc.driverClassName}" />
        <property name="url" value="${jdbc.url}" />
        <property name="username" value="${jdbc.username}" />
        <property name="password" value="${jdbc.password}" />
        <property name="initialSize" value="${jdbc.initialSize}" />
        <property name="minIdle" value="${jdbc.minIdle}" />
        <property name="maxActive" value="${jdbc.maxActive}" />
        <property name="maxWait" value="${jdbc.maxWait}" />
        <property name="timeBetweenEvictionRunsMillis" value="${jdbc.timeBetweenEvictionRunsMillis}" />
        <property name="minEvictableIdleTimeMillis" value="${jdbc.minEvictableIdleTimeMillis}" />
        <property name="validationQuery" value="${jdbc.validationQuery}" />
        <property name="testWhileIdle" value="${jdbc.testWhileIdle}" />
        <property name="testOnBorrow" value="${jdbc.testOnBorrow}" />
        <property name="testOnReturn" value="${jdbc.testOnReturn}" />
        <property name="removeAbandoned" value="${jdbc.removeAbandoned}" />
        <property name="removeAbandonedTimeout" value="${jdbc.removeAbandonedTimeout}" />
        <!-- <property name="logAbandoned" value="${jdbc.logAbandoned}" /> -->
        <property name="filters" value="${jdbc.filters}" />
        <!-- 關閉abanded連線時輸出錯誤日誌 -->
        <property name="logAbandoned" value="true" />
        <property name="proxyFilters">
            <list>
                <ref bean="log-filter" />
            </list>
        </property>

        <!-- 監控資料庫 -->
        <!-- <property name="filters" value="stat" /> -->
        <!-- <property name="filters" value="mergeStat" /> -->
    </bean>
    <!--重要！！！！ sqlserver資料來源 可以用這個配置做參考 mysql的加了一些功能配置 -->
    <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="maxActive" value="${jdbc.maxActive}"/>
        <property name="maxWait" value="${jdbc.maxWait}"/>
        <property name="validationQuery" value="${jdbc.validationQuery}" />
        <property name="testWhileIdle" value="${jdbc.testWhileIdle}"/>
        <property name="testOnBorrow" value="${jdbc.testOnBorrow}" />
        <property name="testOnReturn" value="${jdbc.testOnReturn}" />
        <property name="removeAbandoned" value="${jdbc.removeAbandoned}"/>
        <property name="removeAbandonedTimeout" value="${jdbc.removeAbandonedTimeout}"/>
        <property name="timeBetweenEvictionRunsMillis" value="${jdbc.timeBetweenEvictionRunsMillis}"/>
        <property name="minEvictableIdleTimeMillis" value="${jdbc.minEvictableIdleTimeMillis}"/>
    </bean>

     <!-- 重要！！！ 此處的class呼叫的就是上面的一個類檔案 -->
    <bean id="multipleDataSource" class="com.newcsp.core.mybatis.MultipleDataSource">
        <!-- 指定預設的資料來源 -->
        <property name="defaultTargetDataSource" ref="dataSource"/>

        <property name="targetDataSources">
            <map> <!-- 兩個資料來源的名稱 -->
                <entry key="dataSource" value-ref="dataSource"/>
                <entry key="sqlServerDataSource" value-ref="sqlServerDataSource"/>
            </map>
        </property>
    </bean>

    <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
        <!--單資料來源使用 課忽略 -->
        <!-- <property name="dataSource" ref="dataSource" /> -->
        <!--重要！！！！多資料來源使用  -->
        <property name="dataSource" ref="multipleDataSource"/>

        <property name="configLocation" value="classpath:mybatis-config.xml" />
        <property name="mapperLocations">
            <list>
                <value>classpath:com/newcsp/oracle/mapper/*.xml</value>
            </list>
        </property>
    </bean>

    <bean id="sqlSessionTemplate" class="org.mybatis.spring.SqlSessionTemplate">
        <constructor-arg index="0" ref="sqlSessionFactory" />
    </bean>
    <bean id="baseMybatisDao" class="com.newcsp.core.mybatis.BaseMybatisDao">
        <property name="sqlSessionFactory" ref="sqlSessionFactory" />
    </bean>
    <bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
        <property name="basePackage" value="com.newcsp.oracle.dao" />
        <property name="sqlSessionFactoryBeanName" value="sqlSessionFactory" />
    </bean>
    <bean id="transactionManager"
        class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <property name="dataSource" ref="dataSource" />
    </bean>
    <tx:advice id="txAdvice" transaction-manager="transactionManager">
        <tx:attributes>
            <tx:method name="publish*" />
            <tx:method name="save*" />
            <tx:method name="add*" />
            <tx:method name="update*" />
            <tx:method name="insert*" />
            <tx:method name="create*" />
            <tx:method name="del*" />
            <tx:method name="load*" />
            <tx:method name="init*" />

            <tx:method name="*" read-only="true" />
        </tx:attributes>
    </tx:advice>
    <!-- AOP配置 -->
    <aop:config>
        <aop:pointcut id="myPointcut"
            expression="execution(public * com.newcsp.*.service.impl.*.*(..))" />
        <aop:advisor advice-ref="txAdvice" pointcut-ref="myPointcut" />
    </aop:config>

    <!--重要！！！！！此處用於攔截serverimpl層dataSource註解 用於多資料來源使用  -->
    <bean id="dataSourceAspect" class="com.newcsp.core.mybatis.DataSourceAspect" />
        <aop:config>
                <aop:aspect ref="dataSourceAspect">
                <!-- 攔截所有service方法 -->
                    <aop:pointcut id="dataSourcePointcut"
                                    expression="execution(* com.newcsp.*.service.*.*(..))" />
                    <aop:before pointcut-ref="dataSourcePointcut" method="intercept" />
                </aop:aspect>
        </aop:config>
</beans>

使用方法介紹：
在spring-mybatis.xml 中配置了攔截註解@DataSource的方法
在寫程式碼的使用不論怎麼寫都是要經過serviceImpl實現層的，在實現層中加註解
例如：@DataSource(“dataSource”)
因為在配置spring-mybatis.xml 的時候我的mysql配置name叫：dataSource
我的sqlserver配置name叫sqlServerDataSource,需要使用哪個資料庫就加這個資料庫的註解名就可以了！
例如：

@Service
@DataSource("dataSource")
public class UserServiceImpl implements UserService {
}

到此結束，不懂可以交流。歡迎關注！
如果我成功的幫助到您~~您隨便施捨一下都可以~
這裡寫圖片描述

Java配置多資料來源完整程式碼（SSM框架mysql +sqlserver資料庫）

Java配置多資料來源完整程式碼（SSM框架mysql +sqlserver資料庫）

java配置多資料來源多連線池的工具類，這裡是mysql和mongoDB

基於maven的SSM框架搭建+sqlserver資料庫

【Java】一次SpringMVC+ ibatis 配置多資料來源經歷

SpringBoot學習筆記---配置多資料來源（Mybatis ）

SSM整合系列之配置多資料來源並實現手動切換資料來源可實現讀寫分離

SSM配置多資料來源

SSM整合系列之配置多資料來源利用AOP動態切換資料來源實現讀寫分離

SpringBoot配置多資料來源（MySQL+SQLServer）

springboot配置多資料來源java.lang.IllegalArgumentException: At least one JPA metamodel must be present!

mybatis配置多資料來源例項（DynamicDataSource）,無jdbc.properties

【Java】一次SpringMVC+ Mybatis 配置多資料來源經歷

java hibernate多資料來源配置

SpringBoot配置多資料來源（結合Druid）

Spring Boot入門系列（十四）使用JdbcTemplate操作資料庫，配置多資料來源！

maven配置多倉庫鏡像（轉）

Centos7配置ThinkPHP5.0完整過程（二）

springboot配置多資料來源之Spring Date JPA

spring boot 配置多資料來源

配置多個Git賬號（windows 10）

Java配置多資料來源完整程式碼（SSM框架mysql +sqlserver資料庫）

相關推薦