SSM 動態切換資料來源（目前自己的專案正在用，超詳細，保證可用）

阿新 • • 發佈：2019-01-18

一、jdbc.properties 檔案

兩個資料庫，這裡使用的postgresql 資料庫

jdbc.driver=org.postgresql.Driver
#���ݿ��ַ
jdbc.url=jdbc:postgresql://localhost:5432/aaa
#�û���
jdbc.username=
#����
jdbc.password=
#���������
c3p0.maxPoolSize=5
#��С������
c3p0.minPoolSize=2
#�ر����Ӻ��Զ�commit
c3p0.autoCommitOnClose=false
#��ȡ���ӳ�ʱʱ��
c3p0.checkoutTimeout=10000
c3p0.maxIdleTime=60
c3p0.idleConnectionTestPeriod=60
c3p0.numHelperThreads=3
#����ȡ����ʧ�����Դ���
c3p0.acquireRetryAttempts=2

jdbc2.driver=org.postgresql.Driver
#���ݿ��ַ
jdbc2.url=jdbc:postgresql://lcoalhost:5432/bbb
#�û���
jdbc2.username=
#����
jdbc2.password=
#���������
c3p02.maxPoolSize=5
#��С������
c3p02.minPoolSize=2
#�ر����Ӻ��Զ�commit
c3p02.autoCommitOnClose=false
#��ȡ���ӳ�ʱʱ��
c3p02.checkoutTimeout=10000
c3p02.maxIdleTime=60
c3p02.idleConnectionTestPeriod=60
c3p02.numHelperThreads=3
#����ȡ����ʧ�����Դ���
c3p02.acquireRetryAttempts=2

二、寫 DynamicDataSource 類

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

/**
 * Function:
 *
 * @author chenjiec
 *         Date: 2017/1/2 上午12:22
 * @since JDK 1.7
 */


public class DynamicDataSource extends AbstractRoutingDataSource {

    @Override
    protected Object determineCurrentLookupKey() {
        // 從自定義的位置獲取資料來源標識
        return DynamicDataSourceHolder.getDataSource();
    }
}

三、寫 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();
    }
}

四、修改 spring-mybatis.xml 檔案

1.定義了兩個資料來源

<!-- 資料庫連線池 -->
    <bean id="dataSource1" class="com.mchange.v2.c3p0.ComboPooledDataSource">
        <property name="driverClass" value="${jdbc.driver}"/>
        <property name="jdbcUrl" value="${jdbc.url}"/>
        <property name="user" value="${jdbc.username}"/>
        <property name="password" value="${jdbc.password}"/>
        <property name="maxPoolSize" value="${c3p0.maxPoolSize}"/>
        <property name="minPoolSize" value="${c3p0.minPoolSize}"/>
        <property name="autoCommitOnClose" value="${c3p0.autoCommitOnClose}"/>
        <property name="checkoutTimeout" value="${c3p0.checkoutTimeout}"/>
        <property name="acquireRetryAttempts" value="${c3p0.acquireRetryAttempts}"/>
        <property name="maxIdleTime" value="${c3p0.maxIdleTime}"/>
        <property name="idleConnectionTestPeriod" value="${c3p0.idleConnectionTestPeriod}"/>
        <property name="numHelperThreads" value="${c3p0.numHelperThreads}"/>
    </bean>
    <!-- 資料庫連線池 -->
    <bean id="dataSource2" class="com.mchange.v2.c3p0.ComboPooledDataSource">
        <property name="driverClass" value="${jdbc2.driver}"/>
        <property name="jdbcUrl" value="${jdbc2.url}"/>
        <property name="user" value="${jdbc2.username}"/>
        <property name="password" value="${jdbc2.password}"/>
        <property name="maxPoolSize" value="${c3p02.maxPoolSize}"/>
        <property name="minPoolSize" value="${c3p02.minPoolSize}"/>
        <property name="autoCommitOnClose" value="${c3p02.autoCommitOnClose}"/>
        <property name="checkoutTimeout" value="${c3p02.checkoutTimeout}"/>
        <property name="acquireRetryAttempts" value="${c3p02.acquireRetryAttempts}"/>
        <property name="maxIdleTime" value="${c3p02.maxIdleTime}"/>
        <property name="idleConnectionTestPeriod" value="${c3p02.idleConnectionTestPeriod}"/>
        <property name="numHelperThreads" value="${c3p02.numHelperThreads}"/>
    </bean>

2. 使用 DynamicDataSource 動態切換資料來源

 <bean id="dataSource" class="com.cmbird.Util.DynamicDataSource">
        <property name="targetDataSources">
            <map key-type="java.lang.String">
                <entry key="dataSource1" value-ref="dataSource1"/>
                <entry key="dataSource2" value-ref="dataSource2"/>
            </map>
        </property>
        <!--預設資料來源-->
        <property name="defaultTargetDataSource" ref="dataSource1"/>
    </bean>

五、測試

   @Test
    public void selectByPrimaryKey() throws Exception {
        DynamicDataSourceHolder.setDataSource("dataSource2");
        System.out.println(iypzdDao.selectYpzdBB());
        DynamicDataSourceHolder.setDataSource("dataSource1");
        System.out.println(iMapDao.selectMap(true));
    }

會發現已經可以自定義切換了，但還是感覺有些麻煩，這時就想到了用spring 自帶的AOP 和自定義註解的思想.

六、自定義註解

1.新建 DataSource 註解介面類

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

@Target({ ElementType.TYPE,ElementType.METHOD })
@Retention(RetentionPolicy.RUNTIME)
public @interface DataSource {
    String value();
}

2.寫切面類

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());
        }
    }
}

3.基於xml 寫 aop(修改spring-mybatis.xml）

    <bean id="dataSourceAspect" class="com.cmbird.Util.DataSourceAspect" />
    <aop:config>
        <aop:aspect ref="dataSourceAspect">
            <!-- 攔截所有service方法 -->
            <aop:pointcut id="dataSourcePointcut" expression="execution(* com.zzz.dao..*.*(..))" />
            <aop:before pointcut-ref="dataSourcePointcut" method="intercept" />
        </aop:aspect>
    </aop:config>

4.大工告成

我寫的這個是在每個dao的介面上新增一個註解，比如

@DataSource("dataSource1")
public interface INewsDao {
    /**
     * 刪除資料
     * @param id
     */
    public void deleteNews(long id);

    /**
     * 更新修改資料
     * @param news
     */
    public void updateNews(News news);

    /**
     * 查詢資料
     * @param pageInfo
     */
    public List<News> selectPageNews(PageInfo pageInfo);

    /**
     * 查詢總數量
     */
    public int selectNewsCount();

    /**
     * 新增資料
     * @param news
     */
    public  void addNews(String news);


    public List<News> selectAllNews();
}

就可以使用了.

七、貼一下完整的 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" xmlns:aop="http://www.springframework.org/schema/aop"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
      http://www.springframework.org/schema/beans/spring-beans.xsd
      http://www.springframework.org/schema/context
      http://www.springframework.org/schema/context/spring-context.xsd
      http://www.springframework.org/schema/tx
      http://www.springframework.org/schema/tx/spring-tx.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd">

    <!-- 掃描service包下所有使用註解的型別 -->
    <context:component-scan base-package="com.cmbird.service"/>

    <!-- 配置資料庫相關引數properties的屬性：${url} -->
    <context:property-placeholder location="classpath:jdbc.properties"/>

    <!-- 資料庫連線池 -->
    <bean id="dataSource1" class="com.mchange.v2.c3p0.ComboPooledDataSource">
        <property name="driverClass" value="${jdbc.driver}"/>
        <property name="jdbcUrl" value="${jdbc.url}"/>
        <property name="user" value="${jdbc.username}"/>
        <property name="password" value="${jdbc.password}"/>
        <property name="maxPoolSize" value="${c3p0.maxPoolSize}"/>
        <property name="minPoolSize" value="${c3p0.minPoolSize}"/>
        <property name="autoCommitOnClose" value="${c3p0.autoCommitOnClose}"/>
        <property name="checkoutTimeout" value="${c3p0.checkoutTimeout}"/>
        <property name="acquireRetryAttempts" value="${c3p0.acquireRetryAttempts}"/>
        <property name="maxIdleTime" value="${c3p0.maxIdleTime}"/>
        <property name="idleConnectionTestPeriod" value="${c3p0.idleConnectionTestPeriod}"/>
        <property name="numHelperThreads" value="${c3p0.numHelperThreads}"/>
    </bean>
    <!-- 資料庫連線池 -->
    <bean id="dataSource2" class="com.mchange.v2.c3p0.ComboPooledDataSource">
        <property name="driverClass" value="${jdbc2.driver}"/>
        <property name="jdbcUrl" value="${jdbc2.url}"/>
        <property name="user" value="${jdbc2.username}"/>
        <property name="password" value="${jdbc2.password}"/>
        <property name="maxPoolSize" value="${c3p02.maxPoolSize}"/>
        <property name="minPoolSize" value="${c3p02.minPoolSize}"/>
        <property name="autoCommitOnClose" value="${c3p02.autoCommitOnClose}"/>
        <property name="checkoutTimeout" value="${c3p02.checkoutTimeout}"/>
        <property name="acquireRetryAttempts" value="${c3p02.acquireRetryAttempts}"/>
        <property name="maxIdleTime" value="${c3p02.maxIdleTime}"/>
        <property name="idleConnectionTestPeriod" value="${c3p02.idleConnectionTestPeriod}"/>
        <property name="numHelperThreads" value="${c3p02.numHelperThreads}"/>
    </bean>

    <bean id="dataSource" class="com.cmbird.Util.DynamicDataSource">
        <property name="targetDataSources">
            <map key-type="java.lang.String">
                <entry key="dataSource1" value-ref="dataSource1"/>
                <entry key="dataSource2" value-ref="dataSource2"/>
            </map>
        </property>
        <!--預設資料來源-->
        <property name="defaultTargetDataSource" ref="dataSource1"/>
    </bean>

    <bean id="dataSourceAspect" class="com.cmbird.Util.DataSourceAspect" />
    <aop:config>
        <aop:aspect ref="dataSourceAspect">
            <!-- 攔截所有service方法 -->
            <aop:pointcut id="dataSourcePointcut" expression="execution(* com.cmbird.dao..*.*(..))" />
            <aop:before pointcut-ref="dataSourcePointcut" method="intercept" />
        </aop:aspect>
    </aop:config>

    <!-- 配置SqlSessionFactory物件 -->
    <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
        <!-- 注入資料庫連線池 -->
        <property name="dataSource" ref="dataSource"/>
        <!-- 掃描model包 使用別名 -->
        <property name="typeAliasesPackage" value="com.cmbird.model"/>
        <!-- 掃描sql配置檔案:mapper需要的xml檔案 -->
        <property name="mapperLocations" value="classpath:mapper/**/*.xml"/>
    </bean>

    <!-- 配置掃描Dao介面包，動態實現Dao介面，注入到spring容器中 -->
    <bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
        <!-- 注入sqlSessionFactory -->
        <property name="sqlSessionFactoryBeanName" value="sqlSessionFactory"/>
        <!-- 給出需要掃描Dao介面包 -->
        <property name="basePackage" value="com.cmbird.dao"/>
    </bean>

    <!-- 配置事務管理器 -->
    <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <!-- 注入資料庫連線池 -->
        <property name="dataSource" ref="dataSource"/>
    </bean>

    <!-- 配置基於註解的宣告式事務 -->
    <tx:annotation-driven transaction-manager="transactionManager"/>

</beans>

ps:我碰到了這個問題，找了很多資料，也試了很多次，確沒有一個能用的。然後我又自己研究了一下，感覺還可以，貼出來以免忘記.

SSM 動態切換資料來源（目前自己的專案正在用，超詳細，保證可用）

目錄五、測試一、jdbc.properties 檔案兩個資料庫，這裡使用的postgresql 資料庫 jdbc.driver=org.postgresql.Driver #��ݿ��ַ jdbc.url=

springmvc+mybatis+pagehelper分頁外掛整合AbstractRoutingDataSource動態切換資料來源（含例子程式碼） ...

一、前期工作 1）開發工具Eclipse+maven+jdk1.6以上 2）Tomcat伺服器 3）技術架構Spring+Mybatis 二、在eclipse一個Maven的Web工程（略）不懂的同學請參考部落格http://www.cnblogs.com/leiOOlei/p/3361633.ht

SSM動態切換資料來源

**** > 有需求就要想辦法解決，最近參與的專案其涉及的三個資料表分別在三臺不同的伺服器上，這就有點突兀了，第一次遇到這種情況，可這難不倒筆者，資料一查，程式碼一打，回頭看看原始碼，萬事大吉 ## 1. 預備知識這裡預設大家都會SSM框架了，使用時我們要往sqlSessionFac

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

摘要：在開發的專案中大都都會使用讀寫分離的技術，本人目前開發的專案接觸到的都是主從複製(一主一從)，就是一個Master資料庫，一個Slave資料庫。主庫負責資料插入、更新和實時資料查詢，從庫庫負責非實時資料查詢。在實際專案應用中，都是讀多寫少，而讀取資料通常比較複雜而且耗時，SQL語句

springboot2之系統架構基礎（三）使用自定義註解動態切換資料來源

yml配置資料來源1 資料來源2 step1. 建立自定義註解 DataSource package com.hg.java.demo.common.annotions; import java.lang.annotation.ElementT

web,jsp,html網站中英文切換，資源國際化解決方案及程式碼（其中包含動態切換資料來源及URL攔截器）.

<bean id="dataSourceCn" class="org.springframework.jdbc.datasource.DriverManagerDataSource">

【十七】Spring Boot 之多資料來源（擴充套件AbstractRoutingDataSource類，實現動態資料來源。使用AOP註解動態切換資料來源）

在一個專案中操作多個不同的資料來源時，需要用到多資料來源的配置。 pom.xml <?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0

ijkplayer修改動態庫名稱（目前最新版本0.8.8）

瞭解ijkplayer的朋友都知道，底層有三個動態庫，分別是libijkffmpeg.so、libijksdl.so、libijkplayer.so。一般出於避免重名衝突和便於區分的考慮都會修改它們的名稱。接下來我就依次介紹如何修改三個動態庫

springboot+mybatis多資料來源配置，AOP註解動態切換資料來源

轉載至：https://blog.csdn.net/xiaosheng_papa/article/details/80218006 親測有效。注：有些系統中已經配置了單資料來源，現在要轉成多資料來源，可能需要額外的配置。拿我自己當前專案來說：專案在啟動類中配置了單資料來源：

springboot+mybatis實現動態切換資料來源

前幾天有個需求，需要使用不同的資料來源，例如某業務要用A資料來源，另一個業務要用B資料來源。我上網收集了一些資料整合了一下，雖然最後這個需求不了了之了，但是多資料來源動態切換還是蠻好用的，所以記錄一下，或許以後有用呢？或者自己感興趣又想玩呢！ 1.加個依賴 <dependency>

j2se環境jpa的實現和簡單動態切換資料來源

專案中持久層用的eclipselink，有個需求是動態切換資料來源，首先做了個demo，先在j2se的環境中實現，然後再嘗試加到專案中。 1、建立jpa專案，建立環境

Android 熱修復BugIy（建立自己專案，理解並使用它）

第一步老規矩導架包 1.在專案的根目錄的配置檔案中的dependencies新增 classpath "com.tencent.bugly:tinker-support:1.1.5" 2.在module的配置檔案中新增 // 多dex配置 compi

關於多資料來源（除自己資料庫外，另一部分資料需通過介面調取第三方獲取）的查詢問題

同樣，還是一次工作上遇到的問題的記錄，當時也是搞了挺久才搞出來的，雖然不太完美，但是誤差方面在我的專案裡還算可以接受，哪位老哥有更好的辦法還請指導下，哪怕評論裡留個網頁連結我去看也好，多謝了。具體問題描述大致如下：　　客戶需要app能查詢出所有訂單，分頁並且按時間倒序排列，現在所有的消費訂單資料在我們

Spring Boot 動態切換資料來源三——動態獲取配置檔案中的配置資訊

這裡是接上篇文章 Spring Boot 動態切換資料來源（負載均衡）留下的問題，配置檔案中資料庫的資訊更改後代碼中能夠動態獲取。所以這裡重點說下優化後的內容。先看配置檔案 slave: hosts: slave1,slave2 hikari

關於void*型別的用法（目前自己所能想到的）

1.C++語言在對於void* 型別的使用很特別，因為void* 可以間接引用任何其他資料型別的指標，比如int*、float*甚至抽象資料型別的指標，而且可以從void* 強制轉換為任何其他資料型別的指標，所以使用起來有時候會比較危險。如果開始將一個void*的指標

使用spring註解在方法或類上動態切換資料來源

1 相關知識 1.1 Spring的AbstractRoutingDataSource抽象類,該類可以充當資料來源的路由中介,可以根據名字動態切換資料來源 1.2 SpringAop 1.3 Spring自定義註解 2 思路 2.1 在類或方法上新增自定義註解，其值

android ble藍芽開發總結（附帶自己專案中提取整理的demo地址）

一些基本的知識我就不寫了，很多其他部落格都可以查到。我主要寫幾點我在其他部落格沒有看到的東西以及我在實際開發中遇到的問題。最後我會貼上程式碼的地址。 1.需要設定2個或3個uuid。通常連線裝置後會得

Spring Boot 動態切換資料來源二——負載均衡

如果僅僅是master-slave模式可以參考我前邊的文章Spring Boot HikariCP整合多資料來源。這篇文章也是在那個基礎上修改的，上篇文章中的多資料來源是有限制的，哪條sql使用哪個資料庫必須在程式碼中寫死。現在針對這點做優化，真正的整合

在使用 Spring Boot 和 MyBatis 動態切換資料來源時遇到的問題以及解決方法

1. org.apache.ibatis.binding.BindingException: Invalid bound statement (not found)在使用了動態資料來源後遇到了該問題，從錯誤資訊來看是因為沒有找到 *.xml 檔案而導致的，但是在配置檔案中確實添加了相關的配置，這種錯誤的原因

Spring程式碼中動態切換資料來源

最近專案中遇到一個場景，需要能夠在一個方法中操作多個具有相同表結構資料庫(你可以理解為一個表中的資料被水平拆分到多個庫中，查詢時需要遍歷這多個庫)。經過筆者幾天的研究，最終解決了問題，並且寫了一個demo共享到我的github。關注筆者部落格的小夥伴一定知道之前的這篇文章

SSM 動態切換資料來源 （目前自己的專案正在用，超詳細，保證可用）

一、jdbc.properties 檔案

二、寫 DynamicDataSource 類

三、寫 DynamicDataSourceHolder 類

四、修改 spring-mybatis.xml 檔案

1.定義了兩個資料來源

2. 使用 DynamicDataSource 動態切換資料來源

五、測試

六、自定義註解

1.新建 DataSource 註解介面類

2.寫切面類

3.基於xml 寫 aop(修改spring-mybatis.xml）

4.大工告成

七、貼一下完整的 spring-mybatis.xml

相關推薦

SSM 動態切換資料來源（目前自己的專案正在用，超詳細，保證可用）