快捷導(dǎo)航

SpringBoot +MybatisPlus集成多數(shù)據(jù)源的使用案例

更新時(shí)間：2025年05月23日 10:31:15 作者：小徐Chao努力

這篇文章主要介紹了SpringBoot +MybatisPlus集成多數(shù)據(jù)源的使用案例,本文分步驟結(jié)合實(shí)例代碼給大家講解的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下

引言

應(yīng)項(xiàng)目需求，需要引入另外的Mysql數(shù)據(jù)庫(kù)，但是項(xiàng)目已經(jīng)引入一個(gè)Mysql，這時(shí)有幾種方案

通過(guò)Dynamic-DataSource 框架，無(wú)縫集成但是是動(dòng)態(tài)切換數(shù)據(jù)源的，跟項(xiàng)目需求不符合，于是采取第二種
通過(guò)自定義數(shù)據(jù)源配置類，無(wú)縫引入多個(gè)數(shù)據(jù)源，并且基于文件目錄隔離

步驟

引入依賴

項(xiàng)目需要引入了MyBatis Plus即可，無(wú)需引入額外依賴

<dependency>
    <groupId>com.baomidou</groupId>
    <artifactId>mybatis-plus-boot-starter</artifactId>
    <version>3.5.12</version>
</dependency>

修改配置文件

spring:
  datasource:
    d1:
      password: xxxx
      username: xxxx
      jdbc-url: jdbc:mysql://xxxx:3306/ecshop_wp?characterEncoding=utf-8&useSSL=false&serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true
      driver-class-name: com.mysql.cj.jdbc.Driver
    d2:
      password: root
      username: root
      jdbc-url: jdbc:mysql://127.0.0.1:3306/xg_bi_lcc?characterEncoding=utf-8&useSSL=false&serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true
      driver-class-name: com.mysql.cj.jdbc.Driver

添加配置類

@Configuration
@MapperScan(basePackages = "xg.xx.model.front.service.mysql.mapper1", sqlSessionFactoryRef = "d1SqlSessionFactory")
public class EcshopWpDataSourceConfig {
    @Bean(name = "d1DataSource")
    @ConfigurationProperties(prefix = "spring.datasource.d1")
    public DataSource ecshopWpDataSource() {
        return DataSourceBuilder.create().build();
    }
    @Bean(name = "d1SqlSessionFactory")
    public SqlSessionFactory ecshopWpSqlSessionFactory(@Qualifier("d1DataSource") DataSource dataSource) throws Exception {
        MybatisSqlSessionFactoryBean bean = new MybatisSqlSessionFactoryBean();
        //configuration配置bean
        //MybatisConfiguration configuration = new MybatisConfiguration();
        //configuration.setMapUnderscoreToCamelCase(true);
        //configuration.setCacheEnabled(false);
        // 配置打印sql語(yǔ)句s
        //configuration.setLogImpl(StdOutImpl.class);
        // 添加自定義SQL注入
        //bean.setConfiguration(configuration);
        //插件對(duì)象
        MybatisPlusInterceptor mybatisPlusInterceptor = new MybatisPlusInterceptor();
        //動(dòng)態(tài)表名
        //DynamicTableNameInnerInterceptor dynamicTableNameInnerInterceptor = new DynamicTableNameInnerInterceptor();
        //可以傳多個(gè)表名參數(shù)，指定哪些表使用MonthTableNameHandler處理表名稱
        //dynamicTableNameInnerInterceptor.setTableNameHandler(new MonthTableNameHandler("t_table_name"));
        //以攔截器的方式處理表名稱
        //可以傳遞多個(gè)攔截器，即：可以傳遞多個(gè)表名處理器TableNameHandler
        //mybatisPlusInterceptor.addInnerInterceptor(dynamicTableNameInnerInterceptor);
        //分頁(yè)插件
        mybatisPlusInterceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.MYSQL));
        bean.setDataSource(dataSource);
        // 設(shè)置mybatis的xml所在位置
        bean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath*:mybatis/d1/*.xml"));
        bean.setPlugins(mybatisPlusInterceptor);
        return bean.getObject();
    }
    @Bean(name = "d1TransactionManager")
    public DataSourceTransactionManager ecshopWpTransactionManager(@Qualifier("d1DataSource") DataSource dataSource) {
        return new DataSourceTransactionManager(dataSource);
    }
}

@Configuration
@MapperScan(basePackages = "xg.xx.model.front.service.mysql.Mapper2", sqlSessionFactoryRef = "d2SqlSessionFactory")
public class XgBiLccDataSourceConfig {
    @Bean(name = "d2DataSource")
    @ConfigurationProperties(prefix = "spring.datasource.d2")
    public DataSource ecshopWpDataSource() {
        return DataSourceBuilder.create().build();
    }
    @Bean(name = "d2SqlSessionFactory")
    public SqlSessionFactory ecshopWpSqlSessionFactory(@Qualifier("d2DataSource") DataSource dataSource) throws Exception {
        MybatisSqlSessionFactoryBean bean = new MybatisSqlSessionFactoryBean();
        //configuration配置bean
        //MybatisConfiguration configuration = new MybatisConfiguration();
        //configuration.setMapUnderscoreToCamelCase(true);
        //configuration.setCacheEnabled(false);
        // 配置打印sql語(yǔ)句s
        //configuration.setLogImpl(StdOutImpl.class);
        // 添加自定義SQL注入
        //bean.setConfiguration(configuration);
        //插件對(duì)象
        MybatisPlusInterceptor mybatisPlusInterceptor = new MybatisPlusInterceptor();
        //動(dòng)態(tài)表名
        //DynamicTableNameInnerInterceptor dynamicTableNameInnerInterceptor = new DynamicTableNameInnerInterceptor();
        //可以傳多個(gè)表名參數(shù)，指定哪些表使用MonthTableNameHandler處理表名稱
        //dynamicTableNameInnerInterceptor.setTableNameHandler(new MonthTableNameHandler("t_table_name"));
        //以攔截器的方式處理表名稱
        //可以傳遞多個(gè)攔截器，即：可以傳遞多個(gè)表名處理器TableNameHandler
        //mybatisPlusInterceptor.addInnerInterceptor(dynamicTableNameInnerInterceptor);
        //分頁(yè)插件
        mybatisPlusInterceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.MYSQL));
        bean.setDataSource(dataSource);
        // 設(shè)置mybatis的xml所在位置
        bean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath*:mybatis/d2/*.xml"));
        bean.setPlugins(mybatisPlusInterceptor);
        return bean.getObject();
    }
    @Bean(name = "d2TransactionManager")
    public DataSourceTransactionManager ecshopWpTransactionManager(@Qualifier("d2DataSource") DataSource dataSource) {
        return new DataSourceTransactionManager(dataSource);
    }
}

使用案例

@Transactional

@Transactional(value = "d2TransactionManager", rollbackFor = Exception.class)
這樣即可進(jìn)行全局事物管理

到此這篇關(guān)于SpringBoot +MybatisPlus集成多數(shù)據(jù)源的文章就介紹到這了,更多相關(guān)SpringBoot MybatisPlus多數(shù)據(jù)源內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: