SpringBoot多數(shù)據(jù)源配置詳細(xì)教程(JdbcTemplate、mybatis)

更新時(shí)間：2021年03月19日 09:38:58 作者：互聯(lián)網(wǎng)編程

這篇文章主要介紹了SpringBoot多數(shù)據(jù)源配置詳細(xì)教程(JdbcTemplate、mybatis)，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧

多數(shù)據(jù)源配置

首先是配置文件

這里采用yml配置文件，其他類型配置文件同理
我配置了兩個(gè)數(shù)據(jù)源，一個(gè)名字叫ds1數(shù)據(jù)源，一個(gè)名字叫ds2數(shù)據(jù)源,如果你想配置更多的數(shù)據(jù)源，繼續(xù)加就行了

spring:
 # 數(shù)據(jù)源配置
 datasource:
  ds1: #數(shù)據(jù)源1
   driver-class-name: com.mysql.jdbc.Driver # mysql的驅(qū)動(dòng)你可以配置別的關(guān)系型數(shù)據(jù)庫
   url: jdbc:mysql://ip:3306/db1 #數(shù)據(jù)源地址
   username: root # 用戶名
   password: root # 密碼
  ds2: # 數(shù)據(jù)源2
   driver-class-name: com.mysql.jdbc.Driver # mysql的驅(qū)動(dòng)你可以配置別的關(guān)系型數(shù)據(jù)庫
   url: jdbc:mysql://ip:3307/db2#數(shù)據(jù)源地址
   username: root # 用戶名
   password: root # 密碼

多數(shù)據(jù)源配置

增加一個(gè)Springboot的配置類

/**
 * 多數(shù)據(jù)源配置
 */
@Configuration
public class DataSourceConfig {

  //主數(shù)據(jù)源配置 ds1數(shù)據(jù)源
  @Primary
  @Bean(name = "ds1DataSourceProperties")
  @ConfigurationProperties(prefix = "spring.datasource.ds1")
  public DataSourceProperties ds1DataSourceProperties() {
    return new DataSourceProperties();
  }

  //主數(shù)據(jù)源 ds1數(shù)據(jù)源
  @Primary
  @Bean(name = "ds1DataSource")
  public DataSource ds1DataSource(@Qualifier("ds1DataSourceProperties") DataSourceProperties dataSourceProperties) {
    return dataSourceProperties.initializeDataSourceBuilder().build();
  }

  //第二個(gè)ds2數(shù)據(jù)源配置
  @Bean(name = "ds2DataSourceProperties")
  @ConfigurationProperties(prefix = "spring.datasource.ds2")
  public DataSourceProperties ds2DataSourceProperties() {
    return new DataSourceProperties();
  }

  //第二個(gè)ds2數(shù)據(jù)源
  @Bean("ds2DataSource")
  public DataSource ds2DataSource(@Qualifier("ds2DataSourceProperties") DataSourceProperties dataSourceProperties) {
    return dataSourceProperties.initializeDataSourceBuilder().build();
  }
}

JdbcTemplate多數(shù)據(jù)源配置

增加一個(gè)Springboot配置類

/**
 * JdbcTemplate多數(shù)據(jù)源配置
 * 依賴于數(shù)據(jù)源配置
 *
 * @see DataSourceConfig
 */
@Configuration
public class JdbcTemplateDataSourceConfig {

  //JdbcTemplate主數(shù)據(jù)源ds1數(shù)據(jù)源
  @Primary
  @Bean(name = "ds1JdbcTemplate")
  public JdbcTemplate ds1JdbcTemplate(@Qualifier("ds1DataSource") DataSource dataSource) {
    return new JdbcTemplate(dataSource);
  }

  //JdbcTemplate第二個(gè)ds2數(shù)據(jù)源
  @Bean(name = "ds2JdbcTemplate")
  public JdbcTemplate ds2JdbcTemplate(@Qualifier("ds2DataSource") DataSource dataSource) {
    return new JdbcTemplate(dataSource);
  }
}

mybatis 多數(shù)據(jù)源配置

增加一個(gè)SpringBoot配置類

mybatis多數(shù)據(jù)源的原理是根據(jù)不同包，調(diào)用不同的數(shù)據(jù)源，你只需要把你的mapper.java和mapper.xml(我喜歡叫dao.java和dao.xml)寫在某個(gè)package中，springboot自動(dòng)幫你實(shí)現(xiàn)數(shù)據(jù)源切換
核心代碼就這句

@MapperScan(basePackages ="com.web.ds2.**.dao", sqlSessionTemplateRef = "ds2SqlSessionTemplate")

用來指定包掃描指定sqlSessionTemplateRef
和sqlSessionFactory.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath*:com/web/ds2/**/*.xml"));
用來指定mapper.xml的路徑

詳細(xì)配置代碼如下

/**
 * Mybatis主數(shù)據(jù)源ds1配置
 * 多數(shù)據(jù)源配置依賴數(shù)據(jù)源配置
 * @see DataSourceConfig
 */
@Configuration
@MapperScan(basePackages ="com.web.ds1.**.dao", sqlSessionTemplateRef = "ds1SqlSessionTemplate")
public class MybatisPlusConfig4ds1 {

  //主數(shù)據(jù)源 ds1數(shù)據(jù)源
  @Primary
  @Bean("ds1SqlSessionFactory")
  public SqlSessionFactory ds1SqlSessionFactory(@Qualifier("ds1DataSource") DataSource dataSource) throws Exception {
    MybatisSqlSessionFactoryBean sqlSessionFactory = new MybatisSqlSessionFactoryBean();
    sqlSessionFactory.setDataSource(dataSource);
    sqlSessionFactory.setMapperLocations(new PathMatchingResourcePatternResolver().
            getResources("classpath*:com/web/ds1/**/*.xml")); 
    return sqlSessionFactory.getObject();
  }

  @Primary
  @Bean(name = "ds1TransactionManager")
  public DataSourceTransactionManager ds1TransactionManager(@Qualifier("ds1DataSource") DataSource dataSource) {
    return new DataSourceTransactionManager(dataSource);
  }

  @Primary
  @Bean(name = "ds1SqlSessionTemplate")
  public SqlSessionTemplate ds1SqlSessionTemplate(@Qualifier("ds1SqlSessionFactory") SqlSessionFactory sqlSessionFactory) {
    return new SqlSessionTemplate(sqlSessionFactory);
  }
}

/**
 * Mybatis 第二個(gè)ds2數(shù)據(jù)源配置
 * 多數(shù)據(jù)源配置依賴數(shù)據(jù)源配置
 * @see DataSourceConfig
 */
@Configuration
@MapperScan(basePackages ="com.web.ds2.**.dao", sqlSessionTemplateRef = "ds2SqlSessionTemplate")
public class MybatisPlusConfig4ds2 {

  //ds2數(shù)據(jù)源
  @Bean("ds2SqlSessionFactory")
  public SqlSessionFactory ds2SqlSessionFactory(@Qualifier("ds2DataSource") DataSource dataSource) throws Exception {
    MybatisSqlSessionFactoryBean sqlSessionFactory = new MybatisSqlSessionFactoryBean();
    sqlSessionFactory.setDataSource(dataSource);
    sqlSessionFactory.setMapperLocations(new PathMatchingResourcePatternResolver().
        getResources("classpath*:com/web/ds2/**/*.xml"));
    return sqlSessionFactory.getObject();
  }

//事務(wù)支持
  @Bean(name = "ds2TransactionManager")
  public DataSourceTransactionManager ds2TransactionManager(@Qualifier("ds2DataSource") DataSource dataSource) {
    return new DataSourceTransactionManager(dataSource);
  }

  @Bean(name = "ds2SqlSessionTemplate")
  public SqlSessionTemplate ds2SqlSessionTemplate(@Qualifier("ds2SqlSessionFactory") SqlSessionFactory sqlSessionFactory) {
    return new SqlSessionTemplate(sqlSessionFactory);
  }
}

mybatis-plus 多數(shù)據(jù)源配置

mybatis-plus是mybatis的增強(qiáng)版，只增加，不影響。也就是說使用mybatis-plus兼容原來所有的mybatis代碼和配置。然后又做了很多增加和簡化使用，具體看官網(wǎng)教程https://mybatis.plus/

相對于mybatis的多數(shù)據(jù)源配置就是改了下 SqlSessionFactory
核心代碼就是修改mybatis為mybatis-plus，如下

  @Bean("ds2SqlSessionFactory")
  public SqlSessionFactory ds2SqlSessionFactory(@Qualifier("ds2DataSource") DataSource dataSource) throws Exception {
    MybatisSqlSessionFactoryBean sqlSessionFactory = new MybatisSqlSessionFactoryBean();
    sqlSessionFactory.setDataSource(dataSource);
    MybatisConfiguration configuration = new MybatisConfiguration();
    configuration.setDefaultScriptingLanguage(MybatisXMLLanguageDriver.class);
    configuration.setJdbcTypeForNull(JdbcType.NULL);
    sqlSessionFactory.setConfiguration(configuration);
    sqlSessionFactory.setMapperLocations(new PathMatchingResourcePatternResolver().
        getResources("classpath*:com/web/ds2/**/*.xml"));
    sqlSessionFactory.setPlugins(new Interceptor[]{
        new PaginationInterceptor(),
        new PerformanceInterceptor()
//            .setFormat(true),
    });
    sqlSessionFactory.setGlobalConfig(new GlobalConfig().setBanner(false));
    return sqlSessionFactory.getObject();
  }

全部配置代碼如下

/**
 * Mybatis-plus ds2數(shù)據(jù)源配置
 * 多數(shù)據(jù)源配置依賴數(shù)據(jù)源配置
 * @see DataSourceConfig
 */
@Configuration
@MapperScan(basePackages ="com.web.ds2.**.dao", sqlSessionTemplateRef = "ds2SqlSessionTemplate")
public class MybatisPlusConfig4ds2{

  //ds2數(shù)據(jù)源
  @Bean("ds2SqlSessionFactory")
  public SqlSessionFactory ds2SqlSessionFactory(@Qualifier("ds2DataSource") DataSource dataSource) throws Exception {
    MybatisSqlSessionFactoryBean sqlSessionFactory = new MybatisSqlSessionFactoryBean();
    sqlSessionFactory.setDataSource(dataSource);
    MybatisConfiguration configuration = new MybatisConfiguration();
    configuration.setDefaultScriptingLanguage(MybatisXMLLanguageDriver.class);
    configuration.setJdbcTypeForNull(JdbcType.NULL);
    sqlSessionFactory.setConfiguration(configuration);
    sqlSessionFactory.setMapperLocations(new PathMatchingResourcePatternResolver().
        getResources("classpath*:com/web/ds2/**/*.xml"));
    sqlSessionFactory.setPlugins(new Interceptor[]{
        new PaginationInterceptor(),
        new PerformanceInterceptor()
//            .setFormat(true),
    });
    sqlSessionFactory.setGlobalConfig(new GlobalConfig().setBanner(false));
    return sqlSessionFactory.getObject();
  }

  @Bean(name = "ds2TransactionManager")
  public DataSourceTransactionManager ds2TransactionManager(@Qualifier("ds2DataSource") DataSource dataSource) {
    return new DataSourceTransactionManager(dataSource);
  }

  @Bean(name = "ds2SqlSessionTemplate")
  public SqlSessionTemplate ds2SqlSessionTemplate(@Qualifier("ds2SqlSessionFactory") SqlSessionFactory sqlSessionFactory) {
    return new SqlSessionTemplate(sqlSessionFactory);
  }
}

/**
 * Mybatis-plus 主數(shù)據(jù)源ds1配置
 * 多數(shù)據(jù)源配置依賴數(shù)據(jù)源配置
 * @see DataSourceConfig
 */
@Configuration
@MapperScan(basePackages ="com.web.ds1.**.dao", sqlSessionTemplateRef = "ds1SqlSessionTemplate")
public class MybatisPlusConfig4ds1 {

  //主數(shù)據(jù)源 ds1數(shù)據(jù)源
  @Primary
  @Bean("ds1SqlSessionFactory")
  public SqlSessionFactory ds1SqlSessionFactory(@Qualifier("ds1DataSource") DataSource dataSource) throws Exception {
    MybatisSqlSessionFactoryBean sqlSessionFactory = new MybatisSqlSessionFactoryBean();
    sqlSessionFactory.setDataSource(dataSource);
    MybatisConfiguration configuration = new MybatisConfiguration();
    configuration.setDefaultScriptingLanguage(MybatisXMLLanguageDriver.class);
    configuration.setJdbcTypeForNull(JdbcType.NULL);
    sqlSessionFactory.setConfiguration(configuration);
    sqlSessionFactory.setMapperLocations(new PathMatchingResourcePatternResolver().
            getResources("classpath*:com/ds1/web/ds1/**/*.xml"));
    sqlSessionFactory.setPlugins(new Interceptor[]{
        new PaginationInterceptor(),
        new PerformanceInterceptor()
//            .setFormat(true),
    });
    sqlSessionFactory.setGlobalConfig(new GlobalConfig().setBanner(false));
    return sqlSessionFactory.getObject();
  }

  @Primary
  @Bean(name = "ds1TransactionManager")
  public DataSourceTransactionManager ds1TransactionManager(@Qualifier("ds1DataSource") DataSource dataSource) {
    return new DataSourceTransactionManager(dataSource);
  }

  @Primary
  @Bean(name = "ds1SqlSessionTemplate")
  public SqlSessionTemplate ds1SqlSessionTemplate(@Qualifier("ds1SqlSessionFactory") SqlSessionFactory sqlSessionFactory) {
    return new SqlSessionTemplate(sqlSessionFactory);
  }
}

到此這篇關(guān)于SpringBoot多數(shù)據(jù)源配置詳細(xì)教程(JdbcTemplate、mybatis)的文章就介紹到這了,更多相關(guān)SpringBoot多數(shù)據(jù)源配置內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: