Spring如何實現(xiàn)切換動態(tài)數(shù)據(jù)源？針對這個問題，這篇文章詳細介紹了相對應的分析和解答，希望可以幫助更多想解決這個問題的小伙伴找到更簡單易行的方法。
創(chuàng)新互聯(lián)公司專注于隴縣企業(yè)網(wǎng)站建設,成都響應式網(wǎng)站建設公司,商城網(wǎng)站定制開發(fā)。隴縣網(wǎng)站建設公司,為隴縣等地區(qū)提供建站服務。全流程按需定制網(wǎng)站，專業(yè)設計，全程項目跟蹤，創(chuàng)新互聯(lián)公司專業(yè)和態(tài)度為您提供的服務
一、前言
近期一項目A需實現(xiàn)數(shù)據(jù)同步到另一項目B數(shù)據(jù)庫中，在不改變B項目的情況下，只好選擇項目A中切換數(shù)據(jù)源，直接把數(shù)據(jù)寫入項目B的數(shù)據(jù)庫中。這種需求，在數(shù)據(jù)同步與定時任務中經(jīng)常需要。
那么問題來了，該如何解決多數(shù)據(jù)源問題呢？不光是要配置多個數(shù)據(jù)源，還得能靈活動態(tài)的切換數(shù)據(jù)源。以spring+hibernate框架項目為例：
單個數(shù)據(jù)源綁定給sessionFactory，再在Dao層操作，若多個數(shù)據(jù)源的話，那不是就成了下圖：
可見，sessionFactory都寫死在了Dao層，若我再添加個數(shù)據(jù)源的話，則又得添加一個sessionFactory。所以比較好的做法應該是下圖：
接下來就為大家講解下如何用spring來整合這些數(shù)據(jù)源，同樣以spring+hibernate配置為例。
二、實現(xiàn)原理
1、擴展Spring的AbstractRoutingDataSource抽象類（該類充當了DataSource的路由中介, 能有在運行時, 根據(jù)某種key值來動態(tài)切換到真正的DataSource上。）
從AbstractRoutingDataSource的源碼中：
我們可以看到，它繼承了AbstractDataSource，而AbstractDataSource不就是javax.sql.DataSource的子類，So我們可以分析下它的getConnection方法：
重慶分公司
重慶分公司
public Connection getConnection() throws SQLException {
return determineTargetDataSource().getConnection();
}
public Connection getConnection(String username, String password) throws SQLException {
return determineTargetDataSource().getConnection(username, password);
}獲取連接的方法中，重點是determineTargetDataSource()方法，看源碼：
/**
* Retrieve the current target DataSource. Determines the
* {@link #determineCurrentLookupKey() current lookup key}, performs
* a lookup in the {@link #setTargetDataSources targetDataSources} map,
* falls back to the specified
* {@link #setDefaultTargetDataSource default target DataSource} if necessary.
* @see #determineCurrentLookupKey()
*/
protected DataSource determineTargetDataSource() {
Assert.notNull(this.resolvedDataSources, "DataSource router not initialized");
Object lookupKey = determineCurrentLookupKey();
DataSource dataSource = this.resolvedDataSources.get(lookupKey);
if (dataSource == null && (this.lenientFallback || lookupKey == null)) {
dataSource = this.resolvedDefaultDataSource;
}
if (dataSource == null) {
throw new IllegalStateException("Cannot determine target DataSource for lookup key [" + lookupKey + "]");
}
return dataSource;
}上面這段源碼的重點在于determineCurrentLookupKey()方法，這是AbstractRoutingDataSource類中的一個抽象方法，而它的返回值是你所要用的數(shù)據(jù)源dataSource的key值，有了這個key值，resolvedDataSource（這是個map,由配置文件中設置好后存入的）就從中取出對應的DataSource，如果找不到，就用配置默認的數(shù)據(jù)源。
看完源碼，應該有點啟發(fā)了吧，沒錯！你要擴展AbstractRoutingDataSource類，并重寫其中的determineCurrentLookupKey()方法，來實現(xiàn)數(shù)據(jù)源的切換：
package com.datasource.test.util.database;
import org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource;
/**
* 獲取數(shù)據(jù)源（依賴于spring）
* @author linhy
*/
public class DynamicDataSource extends AbstractRoutingDataSource{
@Override
protected Object determineCurrentLookupKey() {
return DataSourceHolder.getDataSource();
}
}DataSourceHolder這個類則是我們自己封裝的對數(shù)據(jù)源進行操作的類：
package com.datasource.test.util.database;
/**
* 數(shù)據(jù)源操作
* @author linhy
*/
public class DataSourceHolder {
//線程本地環(huán)境
private static final ThreadLocal dataSources = new ThreadLocal();
//設置數(shù)據(jù)源
public static void setDataSource(String customerType) {
dataSources.set(customerType);
}
//獲取數(shù)據(jù)源
public static String getDataSource() {
return (String) dataSources.get();
}
//清除數(shù)據(jù)源
public static void clearDataSource() {
dataSources.remove();
}
} 2、有人就要問，那你setDataSource這方法是要在什么時候執(zhí)行呢？當然是在你需要切換數(shù)據(jù)源的時候執(zhí)行啦。手動在代碼中調(diào)用寫死嗎？這是多蠢的方法，當然要讓它動態(tài)咯。所以我們可以應用spring aop來設置，把配置的數(shù)據(jù)源類型都設置成為注解標簽，在service層中需要切換數(shù)據(jù)源的方法上，寫上注解標簽，調(diào)用相應方法切換數(shù)據(jù)源咯（就跟你設置事務一樣）：
@DataSource(name=DataSource.slave1)
public List getProducts(){當然，注解標簽的用法可能很少人用到，但它可是個好東西哦，大大的幫助了我們開發(fā)：
package com.datasource.test.util.database;
import java.lang.annotation.*;
@Target({ElementType.METHOD, ElementType.TYPE})
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface DataSource {
String name() default DataSource.master;
public static String master = "dataSource1";
public static String slave1 = "dataSource2";
public static String slave2 = "dataSource3";
}三、配置文件
為了精簡篇幅，省略了無關本內(nèi)容主題的配置。
項目中單獨分離出application-database.xml，關于數(shù)據(jù)源配置的文件。
