目前有個(gè)需求,需要使用不同的數(shù)據(jù)源,例如某業(yè)務(wù)要用A數(shù)據(jù)源,另一個(gè)業(yè)務(wù)要用B數(shù)據(jù)源,所以下面這篇文章主要給大家介紹了關(guān)于Springboot動(dòng)態(tài)切換數(shù)據(jù)源的具體實(shí)現(xiàn)與原理分析,需要的朋友可以參考下

前言

在springboot項(xiàng)目中只需一句代碼即可實(shí)現(xiàn)多個(gè)數(shù)據(jù)源之間的切換:

// 切換sqlserver數(shù)據(jù)源:
DataSourceContextHolder.setDataBaseType(DataSourceEnum.SQLSERVER_DATASOURCE);
......
// 切換mysql數(shù)據(jù)源    
DataSourceContextHolder.setDataBaseType(DataSourceEnum.MYSQL_DATASOURCE);

具體實(shí)現(xiàn):

本實(shí)例基于springboot2.5+版本實(shí)現(xiàn)。

1.配置數(shù)據(jù)源：

在配置文件中配置多個(gè)數(shù)據(jù)源的連接信息，用不同的前綴作為區(qū)別:

# sqlserver數(shù)據(jù)源1:前綴為:spring.datasource.sqlserver
spring.datasource.sqlserver.driver-class-name=com.microsoft.sqlserver.jdbc.SQLServerDriver
spring.datasource.sqlserver.jdbc-url=jdbc:sqlserver://localhost:1433;DatabaseName=test
spring.datasource.sqlserver.username=sa
spring.datasource.sqlserver.password=sa
# mysql數(shù)據(jù)源1:前綴為:spring.datasource.mysql
spring.datasource.mysql.driver-class-name=com.mysql.jdbc.Driver
spring.datasource.mysql.jdbc-url=jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=UTF-8&useSSL=false&allowMultiQueries=true
spring.datasource.mysql.username=root
spring.datasource.mysql.password=root
# sqlLite數(shù)據(jù)源1:前綴為:spring.datasource.sqlite
spring.datasource.sqlite.driver-class-name=org.sqlite.JDBC
spring.datasource.sqlite.jdbc-url=jdbc:sqlite:D://sqllite//test.db
spring.datasource.sqlite.username=
spring.datasource.sqlite.password=
# sqlserver數(shù)據(jù)源2:前綴為:spring.datasource.sqlserver2
spring.datasource.sqlserver2.driver-class-name=com.microsoft.sqlserver.jdbc.SQLServerDriver
spring.datasource.sqlserver2.jdbc-url=jdbc:sqlserver://localhost;DatabaseName=test1
spring.datasource.sqlserver2.username=sa
spring.datasource.sqlserver2.password=sa
# 配置數(shù)據(jù)庫(kù)連接池信息
spring.datasource.hikari.maximum-pool-size=32
spring.datasource.hikari.minimum-idle=16

2.新建枚舉類DataSourceEnum，有幾個(gè)數(shù)據(jù)源對(duì)應(yīng)設(shè)置幾個(gè)枚舉類。

public enum DataSourceEnum {
    MYSQL_DATASOURCE,
    SQLSERVER_DATASOURCE,
    SQLSERVER2_DATASOURCE,
    SQLLITE_DATASOURCE
}

3.新建數(shù)據(jù)庫(kù)切換工具類DataSourceContextHolder，這里通過ThreadLocal類型的變量來存儲(chǔ)當(dāng)前數(shù)據(jù)源枚舉類，同時(shí)能夠保證線程安全。

public class DataSourceContextHolder {

    /**
     * 通過ThreadLocal保證線程安全
     */
    private static final ThreadLocal<DataSourceEnum> contextHolder = new ThreadLocal<>();

    /**
     * 設(shè)置數(shù)據(jù)源變量
     * @param dataSourceEnum 數(shù)據(jù)源變量
     */
    public static void setDataBaseType(DataSourceEnum dataSourceEnum) {
        System.out.println("修改數(shù)據(jù)源為：" + dataSourceEnum);
        contextHolder.set(dataSourceEnum);
    }

    /**
     * 獲取數(shù)據(jù)源變量
     * @return 數(shù)據(jù)源變量
     */
    public static DataSourceEnum getDataBaseType() {
        DataSourceEnum dataSourceEnum = contextHolder.get() == null ? DataSourceEnum.MYSQL_DATASOURCE : contextHolder.get();
        System.out.println("當(dāng)前數(shù)據(jù)源的類型為：" + dataSourceEnum);
        return dataSourceEnum;
    }

    /**
     * 清空數(shù)據(jù)類型
     */
    public static void clearDataBaseType() {
        contextHolder.remove();
    }

4.新建DynamicDataSource類繼承AbstractRoutingDataSource類，并實(shí)現(xiàn)determineCurrentLookupKey方法，該方法是指定當(dāng)前默認(rèn)數(shù)據(jù)源的方法。

public class DynamicDataSource extends AbstractRoutingDataSource {
    @Override
    protected Object determineCurrentLookupKey() {
        return DataSourceContextHolder.getDataBaseType();
    }
}

這個(gè)類看似內(nèi)容不多，但其實(shí)繼承了AbstractRoutingDataSource類是實(shí)現(xiàn)動(dòng)態(tài)切換數(shù)據(jù)源的關(guān)鍵。

5.新建DataSourceConfig類用來創(chuàng)建bean的實(shí)例，其中包括各數(shù)據(jù)源的DataSource實(shí)例，DynamicDataSource實(shí)例以及跟Mybatis相關(guān)的SqlSessionFactory或Spring的JdbcTemplate實(shí)例。

@Configuration
public class DataSourceConfig {
    @Bean(name = "sqlserverDataSource")
    @ConfigurationProperties(prefix = "spring.datasource.sqlserver")
    public DataSource getDateSource1() {
        return DataSourceBuilder.create().build();
    }

    @Bean(name = "sqlserver2DataSource")
    @ConfigurationProperties(prefix = "spring.datasource.sqlserver2")
    public DataSource getDateSource11() {
        return DataSourceBuilder.create().build();
    }

    @Bean(name = "mysqlDataSource")
    @ConfigurationProperties(prefix = "spring.datasource.mysql")
    public DataSource getDateSource2() {
        return DataSourceBuilder.create().build();
    }


    @Bean(name = "sqlLiteDataSource")
    @ConfigurationProperties(prefix = "spring.datasource.sqlite")
    public DataSource getDateSource3() {
        return DataSourceBuilder.create().build();
    }

    @Bean(name = "dynamicDataSource")
    public DynamicDataSource DataSource(@Qualifier("sqlserverDataSource") DataSource sqlserverDataSource,
                                        @Qualifier("sqlserver2DataSource") DataSource sqlserver2DataSource,
                                        @Qualifier("mysqlDataSource") DataSource mysqlDataSource,
                                        @Qualifier("sqlLiteDataSource") DataSource sqlLiteDataSource) {
        //配置多數(shù)據(jù)源
        Map<Object, Object> targetDataSource = new HashMap<>();
        targetDataSource.put(DataSourceEnum.SQLSERVER_DATASOURCE, sqlserverDataSource);
        targetDataSource.put(DataSourceEnum.MYSQL_DATASOURCE, mysqlDataSource);
        targetDataSource.put(DataSourceEnum.SQLLITE_DATASOURCE, sqlLiteDataSource);
        targetDataSource.put(DataSourceEnum.SQLSERVER2_DATASOURCE, sqlserver2DataSource);
        DynamicDataSource dataSource = new DynamicDataSource();
        //多數(shù)據(jù)源
        dataSource.setTargetDataSources(targetDataSource);
        //默認(rèn)數(shù)據(jù)源
        dataSource.setDefaultTargetDataSource(sqlserverDataSource);
        return dataSource;
    }
    @Bean(name = "SqlSessionFactory")
    public SqlSessionFactory test1SqlSessionFactory(@Qualifier("dynamicDataSource") DataSource dynamicDataSource)
            throws Exception {
        SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
        bean.setDataSource(dynamicDataSource);
        return bean.getObject();
    }

    @Bean(name = "JdbcTemplate")
    public JdbcTemplate test1JdbcTemplate(@Qualifier("dynamicDataSource") DataSource dynamicDataSource) {
        return new JdbcTemplate(dynamicDataSource);
    }
}

這樣就把我們切換數(shù)據(jù)庫(kù)鎖需要的bean全部交給spring容器中了，使用時(shí)直接通過DataSourceContextHolder.setDataBaseType(DataSourceEnum dataSourceEnum);這個(gè)方法指定數(shù)據(jù)源對(duì)應(yīng)的枚舉類即可。

原理分析:

其實(shí)我們新建數(shù)據(jù)庫(kù)連接的時(shí)候也是通過DataSource來獲取連接的，這里的AbstractRoutingDataSource也是通過了DataSource中的getConnection方法來獲取連接的。

這個(gè)類里維護(hù)了兩個(gè)Map來存儲(chǔ)數(shù)據(jù)庫(kù)連接信息：

@Nullable
private Map<Object, Object> targetDataSources; 

@Nullable
private Object defaultTargetDataSource;

private boolean lenientFallback = true;

private DataSourceLookup dataSourceLookup = new JndiDataSourceLookup();

@Nullable
private Map<Object, DataSource> resolvedDataSources;

@Nullable
private DataSource resolvedDefaultDataSource;

下面對(duì)上面的幾個(gè)屬性進(jìn)行說明：

其中第一個(gè)targetDataSources是一個(gè)Map對(duì)象，在我們上面第五步創(chuàng)建DynamicDataSource實(shí)例的時(shí)候?qū)⒍鄠€(gè)數(shù)據(jù)源的DataSource類，放入到這個(gè)Map中去，這里的Key是枚舉類，values就是DataSource類。

第二個(gè)defaultTargetDataSource是默認(rèn)的數(shù)據(jù)源，就是DynamicDataSource中唯一重寫的方法來給這個(gè)對(duì)象賦值的。

第三個(gè)lenientFallback是一個(gè)標(biāo)識(shí)，是當(dāng)指定數(shù)據(jù)源不存在的時(shí)候是否采用默認(rèn)數(shù)據(jù)源，默認(rèn)是true，設(shè)置為false之后如果找不到指定數(shù)據(jù)源將會(huì)返回null.