SpringBoot + Mybatis plus 實現多資料來源整合

阿新 • • 發佈：2019-02-08

SpringBoot 版本為1.5.10.RELEASE，Mybatis plus 版本為2.1.8。

第一步：填寫配置資訊：

spring:
  aop:
    proxy-target-class: true
    auto: true
  datasource:
    druid:
      # 資料庫 1
      db1:
        url: jdbc:mysql://localhost:3306/db1?useUnicode=true&characterEncoding=utf8&autoReconnect=true&zeroDateTimeBehavior=convertToNull&transformedBitIsBoolean=true 

        username: root
        password: root
        driver-class-name: com.mysql.jdbc.Driver
        initialSize: 5
        minIdle: 5
        maxActive: 20
      # 資料庫 2
      db2:
        url: jdbc:mysql://localhost:3306/db2?useUnicode=true&characterEncoding=utf8&autoReconnect=true&zeroDateTimeBehavior=convertToNull&transformedBitIsBoolean=true 

        username: root
        password: root
        driver-class-name: com.mysql.jdbc.Driver
        initialSize: 5
        minIdle: 5
        maxActive: 20

第二步：資料來源配置：

@Configuration
@MapperScan({"com.warm.system.mapper*"})
public class MybatisPlusConfig {

    /**
     * mybatis-plus分頁外掛<br>
     * 文件：http://mp.baomidou.com<br>
     */ 

    @Bean
    public PaginationInterceptor paginationInterceptor() {
        PaginationInterceptor paginationInterceptor = new PaginationInterceptor();
        //paginationInterceptor.setLocalPage(true);// 開啟 PageHelper 的支援
        return paginationInterceptor;
    }

    /**
     * mybatis-plus SQL執行效率外掛【生產環境可以關閉】
     */
    @Bean
    public PerformanceInterceptor performanceInterceptor() {
        return new PerformanceInterceptor();
    }

    @Bean(name = "db1")
    @ConfigurationProperties(prefix = "spring.datasource.druid.db1" )
    public DataSource db1 () {
        return DruidDataSourceBuilder.create().build();
    }

    @Bean(name = "db2")
    @ConfigurationProperties(prefix = "spring.datasource.druid.db2" )
    public DataSource db2 () {
        return DruidDataSourceBuilder.create().build();
    }
    /**
     * 動態資料來源配置
     * @return
     */
    @Bean
    @Primary
    public DataSource multipleDataSource (@Qualifier("db1") DataSource db1,
                                          @Qualifier("db2") DataSource db2 ) {
        DynamicDataSource dynamicDataSource = new DynamicDataSource();
        Map< Object, Object > targetDataSources = new HashMap<>();
        targetDataSources.put(DBTypeEnum.db1.getValue(), db1 );
        targetDataSources.put(DBTypeEnum.db2.getValue(), db2);
        dynamicDataSource.setTargetDataSources(targetDataSources);
        dynamicDataSource.setDefaultTargetDataSource(db1);
        return dynamicDataSource;
    }

    @Bean("sqlSessionFactory")
    public SqlSessionFactory sqlSessionFactory() throws Exception {
        MybatisSqlSessionFactoryBean sqlSessionFactory = new MybatisSqlSessionFactoryBean();
        sqlSessionFactory.setDataSource(multipleDataSource(db1(),db2()));
        //sqlSessionFactory.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:/mapper/*/*Mapper.xml"));

        MybatisConfiguration configuration = new MybatisConfiguration();
        //configuration.setDefaultScriptingLanguage(MybatisXMLLanguageDriver.class);
        configuration.setJdbcTypeForNull(JdbcType.NULL);
        configuration.setMapUnderscoreToCamelCase(true);
        configuration.setCacheEnabled(false);
        sqlSessionFactory.setConfiguration(configuration);
        sqlSessionFactory.setPlugins(new Interceptor[]{ //PerformanceInterceptor(),OptimisticLockerInterceptor()
                paginationInterceptor() //新增分頁功能
        });
        sqlSessionFactory.setGlobalConfig(globalConfiguration());
        return sqlSessionFactory.getObject();
    }

    @Bean
    public GlobalConfiguration globalConfiguration() {
        GlobalConfiguration conf = new GlobalConfiguration(new LogicSqlInjector());
        conf.setLogicDeleteValue("-1");
        conf.setLogicNotDeleteValue("1");
        conf.setIdType(0);
        conf.setMetaObjectHandler(new MyMetaObjectHandler());
        conf.setDbColumnUnderline(true);
        conf.setRefresh(true);
        return conf;
    }
}

第三步：利用AOP進行資料來源的動態切換：

@Component
@Aspect
@Order(-100) //這是為了保證AOP在事務註解之前生效,Order的值越小,優先順序越高
@Slf4j
public class DataSourceSwitchAspect {

    @Pointcut("execution(* com.warm.system.service.db1..*.*(..))")
    private void db1Aspect() {
    }

    @Pointcut("execution(* com.warm.system.service.db2..*.*(..))")
    private void db2Aspect() {
    }

    @Before( "db1Aspect()" )
    public void db1() {
        log.info("切換到db1 資料來源...");
        DbContextHolder.setDbType(DBTypeEnum.db1);
    }

    @Before("db2Aspect()" )
    public void db2 () {
        log.info("切換到db2 資料來源...");
        DbContextHolder.setDbType(DBTypeEnum.db2);
    }
}

public class DbContextHolder {
    private static final ThreadLocal contextHolder = new ThreadLocal<>();
    /**
     * 設定資料來源
     * @param dbTypeEnum
     */
    public static void setDbType(DBTypeEnum dbTypeEnum) {
        contextHolder.set(dbTypeEnum.getValue());
    }

    /**
     * 取得當前資料來源
     * @return
     */
    public static String getDbType() {
        return (String) contextHolder.get();
    }

    /**
     * 清除上下文資料
     */
    public static void clearDbType() {
        contextHolder.remove();
    }
}

public enum DBTypeEnum {
    db1("db1"), db2("db2");
    private String value;

    DBTypeEnum(String value) {
        this.value = value;
    }

    public String getValue() {
        return value;
    }
}

public class DynamicDataSource extends AbstractRoutingDataSource {
    /**
     * 取得當前使用哪個資料來源
     * @return
     */
    @Override
    protected Object determineCurrentLookupKey() {
        return DbContextHolder.getDbType();
    }
}

OK！寫個單元測試來驗證一下：

@SpringBootTest
@RunWith(SpringJUnit4ClassRunner.class)
public class DataTest {
    @Autowired
    private UserService userService;
    @Autowired
    private OrderService orderService;

    @Test
    public void test() {
        userService.getUserList().stream().forEach(item -> System.out.println(item));
        orderService.getOrderList().stream().forEach(item -> System.out.println(item));
    }
}

如圖所示，證明資料來源能動態切換了。
這裡寫圖片描述

具體專案結構和程式碼參考Github。

踩坑記錄：

直接呼叫Mybatis plus 的service方法AOP不會生效，即資料來源不會動態切換，解決方法：在自己的service層中封裝一下，呼叫自定義的service方法AOP即能正常生效了，如下所示：

@Service
public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements UserService {

    @Override
    public List<User> getUserList() {
        return selectList(null);
    }
}

application.yml 定義的mybatis plus 配置資訊不生效，如：

#MyBatis
mybatis-plus:
  mapper-locations: classpath:/mapper/*/*Mapper.xml
  #實體掃描，多個package用逗號或者分號分隔
  typeAliasesPackage: com.jinhuatuo.edu.sys.entity
  global-config:
    #主鍵型別  0:"資料庫ID自增", 1:"使用者輸入ID",2:"全域性唯一ID (數字型別唯一ID)", 3:"全域性唯一ID UUID";
    id-type: 0
    #欄位策略 0:"忽略判斷",1:"非 NULL 判斷"),2:"非空判斷"
    field-strategy: 2
    #駝峰下劃線轉換
    db-column-underline: true
    #重新整理mapper 除錯神器
    refresh-mapper: true
    #資料庫大寫下劃線轉換
    #capital-mode: true
    #序列介面實現類配置
    #key-generator: com.baomidou.springboot.xxx
    #邏輯刪除配置
    #logic-delete-value: 0
    #logic-not-delete-value: 1
    #自定義填充策略介面實現
    meta-object-handler: com.jinhuatuo.edu.config.mybatis.MyMetaObjectHandler
    #自定義SQL注入器
    #sql-injector: com.baomidou.springboot.xxx
  configuration:
    map-underscore-to-camel-case: true
    cache-enabled: false

解決方法：所有這些配置在MybatisPlusConfig 類中用程式碼的方式進行配置，分頁外掛亦是如此，否則統計列表總數的資料會拿不到，參考程式碼即可。

在application.yml配置

logging:
  level: debug

控制檯也不會列印Mybatis 執行的SQL語句，解決方法：自定義日誌輸出方案，如在classpath下直接引入日誌配置檔案如logback-spring.xml即可，同時application.yml無需再配置日誌資訊。

logback-spring.xml配置參考：

<?xml version="1.0" encoding="UTF-8"?>
<!-- scan:配置檔案如果發生改變，將會重新載入，預設值為true -->
<configuration scan="true" scanPeriod="10 seconds">  
    <!-- <include resource="org/springframework/boot/logging/logback/base.xml"/> -->
    <!-- 日誌檔案路徑 -->
    <!-- <springProperty  name="logFilePath" source="logging.path"/> -->
    <property resource="application.yml" />
    <substitutionProperty name="LOG_HOME" value="${logging.path}" />
    <substitutionProperty name="PROJECT_NAME" value="${spring.application.name}" />
    <!--<substitutionProperty name="CUR_NODE" value="${info.node}" />-->

    <!-- 日誌資料庫路徑 -->
    <!-- <springProperty  name="logDbPath" source="spring.datasource.one.url"/>
    <springProperty  name="logDbDriver" source="spring.datasource.one.driver-class-name"/>
    <springProperty  name="logDbUser" source="spring.datasource.one.username"/>
    <springProperty  name="logDbPwd" source="spring.datasource.one.password"/> -->

    <!-- 將日誌檔案 -->
    <appender name="file" class="ch.qos.logback.core.rolling.RollingFileAppender">
        <append>true</append>
        <encoder>
            <pattern>
                [ %-5level] [%date{yyyy-MM-dd HH:mm:ss}] %logger{96} [%line] - %msg%n
            </pattern>
            <charset>utf-8</charset>
        </encoder>

        <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
            <fileNamePattern>${LOG_HOME}/${PROJECT_NAME}-%d{yyyy-MM-dd}.%i.log</fileNamePattern>
            <timeBasedFileNamingAndTriggeringPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP">
                <maxFileSize>50 MB</maxFileSize>
            </timeBasedFileNamingAndTriggeringPolicy>
            <!--最多保留30天log-->
            <maxHistory>30</maxHistory>
        </rollingPolicy>
    </appender>
    <!-- 將日誌錯誤檔案-->
    <appender name="file_error" class="ch.qos.logback.core.rolling.RollingFileAppender">
        <append>true</append>
        <encoder>
            <pattern>
                [ %-5level] [%date{yyyy-MM-dd HH:mm:ss}] %logger{96} [%line] - %msg%n
            </pattern>
            <charset>utf-8</charset>
        </encoder>

        <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
            <fileNamePattern>${LOG_HOME}/${PROJECT_NAME}-error-%d{yyyy-MM-dd}.%i.log</fileNamePattern>
            <timeBasedFileNamingAndTriggeringPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP">
                <maxFileSize>50 MB</maxFileSize>
            </timeBasedFileNamingAndTriggeringPolicy>
            <!--最多保留30天log-->
            <maxHistory>30</maxHistory>
        </rollingPolicy>
        <filter class="ch.qos.logback.classic.filter.ThresholdFilter">
            <level>ERROR</level>
            <!-- <onMatch>ACCEPT</onMatch>
            <onMismatch>DENY </onMismatch> -->
        </filter>
    </appender>
    <!-- 將日誌寫入控制檯 -->
    <appender name="console" class="ch.qos.logback.core.ConsoleAppender">
        <encoder>
            <pattern>
                [ %-5level] [%date{yyyy-MM-dd HH:mm:ss}] %logger{96} [%line] - %msg%n
            </pattern>
            <!--<charset>utf-8</charset>-->
        </encoder>
    </appender>
    <!-- 將日誌寫入資料庫 -->
    <!-- <appender name="DB-CLASSIC-MYSQL-POOL" class="ch.qos.logback.classic.db.DBAppender">  
        <connectionSource class="ch.qos.logback.core.db.DataSourceConnectionSource">  
            <dataSource class="org.springframework.jdbc.datasource.DriverManagerDataSource">  
                <driverClassName>${logDbDriver}</driverClassName>  
                <url>${logDbPath}</url>  
                <username>${logDbUser}</username>  
                <password>${logDbPwd}</password>  
            </dataSource>  
        </connectionSource>  
    </appender>  -->
    <!-- spring擴充套件，分環境配置log資訊 -->
    <springProfile name="dev">

        <!-- <logger name="sand.dao" level="DEBUG"/> -->
        <!-- <logger name="org.springframework.web" level="INFO"/> -->
        <logger name="org.springboot.sample" level="TRACE" />
        <logger name="org.springframework.cloud" level="INFO" />
        <logger name="com.netflix" level="INFO"></logger>
        <logger name="org.springframework.boot" level="INFO"></logger>
        <logger name="org.springframework.web" level="INFO"/>
        <logger name="jdbc.sqltiming" level="debug"/>
        <logger name="com.ibatis" level="debug" />
        <logger name="com.ibatis.common.jdbc.SimpleDataSource" level="debug" />
        <logger name="com.ibatis.common.jdbc.ScriptRunner" level="debug" />
        <logger name="com.ibatis.sqlmap.engine.impl.SqlMapClientDelegate" level="debug" />
        <logger name="java.sql.Connection" level="debug" />
        <logger name="java.sql.Statement" level="debug" />
        <logger name="java.sql.PreparedStatement" level="debug" />
        <logger name="java.sql.ResultSet" level="debug" />
        <logger name="com.warm" level="debug"/>
        <root level="DEBUG">
            <appender-ref ref="console" />
            <appender-ref ref="file" />
        </root>
        <root level="ERROR">
            <appender-ref ref="file_error" />
            <!-- <appender-ref ref="DB-CLASSIC-MYSQL-POOL" /> -->
        </root>
    </springProfile>
    <springProfile name="test">
        <logger name="org.springboot.sample" level="TRACE" />
        <logger name="org.springframework.cloud" level="INFO" />
        <logger name="com.netflix" level="INFO"></logger>
        <logger name="org.springframework.boot" level="INFO"></logger>

        <logger name="org.springframework.web" level="INFO"/>
        <logger name="jdbc.sqltiming" level="debug"/>
        <logger name="com.ibatis" level="debug" />
        <logger name="com.ibatis.common.jdbc.SimpleDataSource" level="debug" />
        <logger name="com.ibatis.common.jdbc.ScriptRunner" level="debug" />
        <logger name="com.ibatis.sqlmap.engine.impl.SqlMapClientDelegate" level="debug" />
        <logger name="java.sql.Connection" level="debug" />
        <logger name="java.sql.Statement" level="debug" />
        <logger name="java.sql.PreparedStatement" level="debug" />
        <logger name="java.sql.ResultSet" level="debug" />
        <logger name="com.warm" level="DEBUG"/>
        <root level="DEBUG">
            <!-- <appender-ref ref="console" /> -->
            <appender-ref ref="file" />
        </root>
        <root level="ERROR">
            <appender-ref ref="file_error" />
            <!-- <appender-ref ref="DB-CLASSIC-MYSQL-POOL" /> -->
        </root>
    </springProfile>
    <springProfile name="prod">
        <logger name="org.springboot.sample" level="TRACE" />
        <logger name="org.springframework.cloud" level="INFO" />
        <logger name="com.netflix" level="INFO"></logger>
        <logger name="org.springframework.boot" level="INFO"></logger>

        <logger name="org.springframework.web" level="INFO"/>
        <logger name="jdbc.sqltiming" level="debug"/>
        <logger name="com.ibatis" level="debug" />
        <logger name="com.ibatis.common.jdbc.SimpleDataSource" level="debug" />
        <logger name="com.ibatis.common.jdbc.ScriptRunner" level="debug" />
        <logger name="com.ibatis.sqlmap.engine.impl.SqlMapClientDelegate" level="debug" />
        <logger name="java.sql.Connection" level="debug" />
        <logger name="java.sql.Statement" level="debug" />
        <logger name="java.sql.PreparedStatement" level="debug" />
        <logger name="java.sql.ResultSet" level="debug" />
        <logger name="com.warm" level="info"/>
        <root level="DEBUG">
            <!-- <appender-ref ref="console" /> -->
            <appender-ref ref="file" />
        </root>
        <root level="ERROR">
            <appender-ref ref="file_error" />
            <!-- <appender-ref ref="DB-CLASSIC-MYSQL-POOL" /> -->
        </root>
    </springProfile>
</configuration>

SpringBoot + Mybatis plus 實現多資料來源整合

SpringBoot 版本為1.5.10.RELEASE，Mybatis plus 版本為2.1.8。第一步：填寫配置資訊： spring: aop: proxy-target-class: true auto: true

springboot+mybatis+druid實現多資料來源配置，支援註解和xml兩種sql書寫方式

https://github.com/cheegoday/springboot-demo-djg 要點：一、依次建立以下幾個Bean 資料來源：DataSource session工廠：SqlSessionFactory 執行緒安全session：Sql

（六）springboot + mybatis plus實現多表聯查分頁3.X版本

註明：上兩篇文章我們講解了springboot+mybatis-plus對於單表的CRUD和條件構造器的使用方法，但是對於我們的實戰專案中多表聯查也是經常會出現的。今天我們就來說下怎麼在springboot+MP模式下實現多表聯查並分頁。 MP推薦使用的是

springboot+Mybatis配置實現多資料來源

簡述應公司需求，結合網上的許多資料和公司專案配置實現多資料來源。在此記錄一下配置過程，以供大家參考。專案簡介框架用的是SpringBoot+Mybatis，初始資料庫是MySQL，具體MySQL的整合在這裡不做詳細說明，要求是新增一個Oracle

springboot + mybatis plus實現多表聯查分頁

auto score ice get pro err type 實現 app 1 配置分頁插件 public class MybatisPlusConfig { @Bean public PaginationInterceptor paginationInt

SpringBoot+Mybatis+Druid動態多資料來源

背景前兩天突然想起了，咕泡老師寫的原始碼中有關於多資料來源的實現。翻出來看了看，想移植到springboot裡面去，可是移動過去，不起作用，而後又百度了些大神做法，還是不起作用，故自己研究了一番，最終實現了mybatis的動態資料來源。水平有限，還請大佬輕噴，

Springboot整合mybatis實現多資料來源

1:SpringBoot整合mybatis實現多資料來源有兩種方法 1:靜態方式將每個資料來源都實現一個mybatis的sqlSessionFactory中,但是這種方法,缺點在於:你有幾個資料來源都會有幾個mybatis的配置類;對於資料來源的事務也不是很

springboot+mybatis+druid 多資料來源整合

前言：在上一篇文章裡面我們進行了spring boot 和 mybatis 的整合《springboot整合mybatis使用druid資料來源》, 文中是使用的單資料來源，因為專案中有很多需要用到多資料來源的場景，比如主從同步（讀寫分離）

SpringBoot31 整合SpringJDBC、整合MyBatis、利用AOP實現多資料來源切換

一、整合SpringJDBC 1 JDBC 　　JDBC（Java Data Base Connectivity，Java 資料庫連線）是一種用於執行 SQL 語句的 Java API，可以為多種關係資料庫提供統一訪問，它由一組用 Java 語言編寫的類和介面組成。JDBC 提

Spring Boot整合MyBatis實現多資料來源配置

Spring Boot最大的特點是簡化開發，因此使用Java Config實現去xml配置，本文將使用這種方式完成對SpringBoot+Mybatis的多資料來源配置。同時，會用到阿里巴巴的開源資料來源Druid。依賴：<?xml version="1.0" encoding="UTF-8"?>

SpringBoot+Mybatis+ Druid+PageHelper 實現多資料來源並分頁

前言本篇文章主要講述的是SpringBoot整合Mybatis、Druid和PageHelper 並實現多資料來源和分頁。其中SpringBoot整合Mybatis這塊，在之前的的一篇文章中已經講述了，這裡就不過多說明了。重點是講述在多資料來源下的如何配置使用Druid和PageHelper 。 Druid

Springboot+Mybatis實現多資料來源配置

1、預設application.properties配置檔案增加多資料來源配置，也可另行自己增加新的配置檔案獨立維護 ## master資料來源[主端業務]：用於mybatis自動程式碼生成呼叫及spring對資料庫的系列操作 master.datasource.url=j

springboot mybatis plus多資料來源輕鬆搞定（上）

在開發中經常會遇到一個程式需要呼叫多個數據庫的情況，總得來說分為下面的幾種情況： 1. 一個程式會呼叫不同結構的兩個資料庫。 2. 讀寫分離，兩個資料結構可能一樣高，但是不同的操作針對不同的資料庫。 3. 混合情況，既有不同的結構的資料庫，也可能存在讀寫分離的情況。下面針對第一種情況，提供一個解決方案。

Springboot+mybatis+MySQL實現簡單的多表查詢

Springboot+mybatis+MySQL實現簡單的多表查詢直接進入正題 1.首先我們新建一個數據庫，再建兩個表 tbl_employee表建表SQL語句 CREATE TABLE `tbl_employee` ( `id` int(200) NOT NULL AUT

springboot使用mybatis如何配置多資料來源

本篇部落格提供一個工程想連線多個數據庫進行業務查詢，在原先的單個數據庫上進行配置實現多個數據庫的使用，對於springboot以及mybatis不在此進行展開介紹，只需要把程式碼按照步驟一步步貼上進你的專案，調整一下就能實現；簡單介紹單個數據源配置 pom檔案匯入依賴 <

SpringBoot學習筆記---配置多資料來源（Mybatis ）

介紹為什麼配置多資料來源，因為在實際業務需求中資料的來源可能不是一個數據庫中可進行配置兩套資料來源就可以避免跨庫查詢 pom檔案需要引入的依賴 <dependency> <groupId>org.mybatis.spring.boot</gr

SpringBoot實現多資料來源

springboot的出現大大方便了我們程式設計師的編碼，不用再去各種xml中配置，節省了大量的時間，我也是剛開始學習。使用springboot實現多資料來源也是相當簡單的，首先在pom中新增相應的資料庫所需的依賴（這裡就不多討論了），然後在如圖的properties檔案中配

Spring Boot 整合mybatis 如何使用多資料來源

前言本篇教程偏向實戰，程式猿直接copy程式碼加入到自己的專案中做簡單的修修改改便可使用，而對於springboot以及mybatis不在此進行展開介紹，如有讀者希望瞭解可以給我留言，並持續關注，我後續會慢慢更新。（黑色區域程式碼部分，安卓手機可手動向左滑動，來

（三）springboot + mybatis plus整合AutoGenerator快速搭建專案

註明： AutoGenerator 是 MyBatis-Plus 的程式碼生成器，通過 AutoGenerator 可以快速生成 Entity、Mapper、Mapper XML、Service、Controller 等各個模組的程式碼，極大的提升了開發效率。

Spring+SpringMVC+Mybatis 多資料來源整合

此篇文章是基於Spring3.0和mybatis3.2的總體大概流程： 1. 拷貝所需jar 2.寫一個數據庫切換的工具類：DataSourceContextHolder，用來切換資料庫3.寫一個DynamicDataSource類來繼承AbstractRoutingDa

SpringBoot + Mybatis plus 實現多資料來源整合

相關推薦