2. 程式人生 > >SpringBoot+Druid+Mybatis配置多數據源

SpringBoot+Druid+Mybatis配置多數據源

阿新 • • 發佈：2018-08-18
sep 表示 beans 51cto desc 還需要 spring obj -s

我們在開發一個項目的時候，可能會遇到需要對多個數據庫進行讀寫的需求，這時候就得在項目中配置多個數據源了。在Java項目的開發中，目前最常用的數據操作框架是 Mybatis，開發框架也都基本用上了SpringBoot。而Druid號稱最好的數據庫連接池，自然也是被廣泛使用。

所以本文將演示一下，SpringBoot+Druid+Mybatis如何去配置多數據源。首先在IDEA中創建一個SpringBoot工程：
技術分享圖片
技術分享圖片

選擇一些基本的包：
技術分享圖片

完成創建：
技術分享圖片

pom.xml配置的依賴如下：

<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <dependency>
        <groupId>org.mybatis.spring.boot</groupId>
        <artifactId>mybatis-spring-boot-starter</artifactId>
        <version>1.3.2</version>
    </dependency>
    <dependency>
        <groupId>mysql</groupId>
        <artifactId>mysql-connector-java</artifactId>
        <scope>runtime</scope>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-test</artifactId>
        <scope>test</scope>
    </dependency>
    <!-- alibaba的druid數據庫連接池 -->
    <dependency>
        <groupId>com.alibaba</groupId>
        <artifactId>druid-spring-boot-starter</artifactId>
        <version>1.1.9</version>
    </dependency>
</dependencies>

接著就是編輯SpringBoot的配置文件，我這裏使用的是yml格式的。需要註意的是，在使用多數據源的情況下，必須區分出主數據源和從數據源，否則會報錯。application.yml配置文件內容如下：

spring:
  datasource:
    #使用druid連接池
    type: com.alibaba.druid.pool.DruidDataSource

# 自定義的主數據源配置信息
primary:
  datasource:
    #druid相關配置
    druid:
      #監控統計攔截的filters
      filters: stat
      driverClassName: com.mysql.jdbc.Driver
      #配置基本屬性
      url: jdbc:mysql://127.0.0.1:3306/primary_database?useUnicode=true&characterEncoding=UTF-8&allowMultiQueries=true&autoReconnect=true&useSSL=false
      username: root
      password: password
      #配置初始化大小/最小/最大
      initialSize: 1
      minIdle: 1
      maxActive: 20
      #獲取連接等待超時時間
      maxWait: 60000
      #間隔多久進行一次檢測，檢測需要關閉的空閑連接
      timeBetweenEvictionRunsMillis: 60000
      #一個連接在池中最小生存的時間
      minEvictableIdleTimeMillis: 300000
      validationQuery: SELECT ‘x‘
      testWhileIdle: true
      testOnBorrow: false
      testOnReturn: false
      #打開PSCache，並指定每個連接上PSCache的大小。oracle設為true，mysql設為false。分庫分表較多推薦設置為false
      poolPreparedStatements: false
      maxPoolPreparedStatementPerConnectionSize: 20

# 自定義的從數據源配置信息
back:
  datasource:
    #druid相關配置
    druid:
      #監控統計攔截的filters
      filters: stat
      driverClassName: com.mysql.jdbc.Driver
      #配置基本屬性
      url: jdbc:mysql://127.0.0.1:3306/back_database?useUnicode=true&characterEncoding=UTF-8&allowMultiQueries=true&autoReconnect=true&useSSL=false
      username: root
      password: password
      #配置初始化大小/最小/最大
      initialSize: 1
      minIdle: 1
      maxActive: 20
      #獲取連接等待超時時間
      maxWait: 60000
      #間隔多久進行一次檢測，檢測需要關閉的空閑連接
      timeBetweenEvictionRunsMillis: 60000
      #一個連接在池中最小生存的時間
      minEvictableIdleTimeMillis: 300000
      validationQuery: SELECT ‘x‘
      testWhileIdle: true
      testOnBorrow: false
      testOnReturn: false
      #打開PSCache，並指定每個連接上PSCache的大小。oracle設為true，mysql設為false。分庫分表較多推薦設置為false
      poolPreparedStatements: false
      maxPoolPreparedStatementPerConnectionSize: 20

然後在項目中新建一個config包，並在該包下創建一個PrimaryDataBaseConfig類，作為我們的主數據源配置類，用於加載自定義的主數據源配置信息，以及創建數據源和會話連接工廠等實例：

package com.dabo.mini.game.zhaxinle.config;

import com.alibaba.druid.pool.DruidDataSource;
import lombok.Data;
import org.apache.ibatis.session.SqlSessionFactory;
import org.mybatis.spring.SqlSessionFactoryBean;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;

import javax.sql.DataSource;
import java.sql.SQLException;

/**
 * @ProjectName zhaxinle
 * @Author: zeroJun
 * @Date: 2018/8/16 16:49
 * @Description: 主數據源配置類
 */
@Data
@Configuration
// 前綴為primary.datasource.druid的配置信息
@ConfigurationProperties(prefix = "primary.datasource.druid")
@MapperScan(basePackages = PrimaryDataBaseConfig.PACKAGE, sqlSessionFactoryRef = "primarySqlSessionFactory")
public class PrimaryDataBaseConfig {

    /**
     * dao層的包路徑
     */
    static final String PACKAGE = "com.dabo.mini.game.zhaxinle.dao.primary";

    /**
     * mapper文件的相對路徑
     */
    private static final String MAPPER_LOCATION = "classpath:mappers/primary/*.xml";

    private String filters;
    private String url;
    private String username;
    private String password;
    private String driverClassName;
    private int initialSize;
    private int minIdle;
    private int maxActive;
    private long maxWait;
    private long timeBetweenEvictionRunsMillis;
    private long minEvictableIdleTimeMillis;
    private String validationQuery;
    private boolean testWhileIdle;
    private boolean testOnBorrow;
    private boolean testOnReturn;
    private boolean poolPreparedStatements;
    private int maxPoolPreparedStatementPerConnectionSize;

    // 主數據源使用@Primary註解進行標識
    @Primary
    @Bean(name = "primaryDataSource")
    public DataSource primaryDataSource() throws SQLException {
        DruidDataSource druid = new DruidDataSource();
        // 監控統計攔截的filters
        druid.setFilters(filters);

        // 配置基本屬性
        druid.setDriverClassName(driverClassName);
        druid.setUsername(username);
        druid.setPassword(password);
        druid.setUrl(url);

        //初始化時建立物理連接的個數
        druid.setInitialSize(initialSize);
        //最大連接池數量
        druid.setMaxActive(maxActive);
        //最小連接池數量
        druid.setMinIdle(minIdle);
        //獲取連接時最大等待時間，單位毫秒。
        druid.setMaxWait(maxWait);
        //間隔多久進行一次檢測，檢測需要關閉的空閑連接
        druid.setTimeBetweenEvictionRunsMillis(timeBetweenEvictionRunsMillis);
        //一個連接在池中最小生存的時間
        druid.setMinEvictableIdleTimeMillis(minEvictableIdleTimeMillis);
        //用來檢測連接是否有效的sql
        druid.setValidationQuery(validationQuery);
        //建議配置為true，不影響性能，並且保證安全性。
        druid.setTestWhileIdle(testWhileIdle);
        //申請連接時執行validationQuery檢測連接是否有效
        druid.setTestOnBorrow(testOnBorrow);
        druid.setTestOnReturn(testOnReturn);
        //是否緩存preparedStatement，也就是PSCache，oracle設為true，mysql設為false。分庫分表較多推薦設置為false
        druid.setPoolPreparedStatements(poolPreparedStatements);
        // 打開PSCache時，指定每個連接上PSCache的大小
        druid.setMaxPoolPreparedStatementPerConnectionSize(maxPoolPreparedStatementPerConnectionSize);

        return druid;
    }

    // 創建該數據源的事務管理
    @Primary
    @Bean(name = "primaryTransactionManager")
    public DataSourceTransactionManager primaryTransactionManager() throws SQLException {
        return new DataSourceTransactionManager(primaryDataSource());
    }

    // 創建Mybatis的連接會話工廠實例
    @Primary
    @Bean(name = "primarySqlSessionFactory")
    public SqlSessionFactory primarySqlSessionFactory(@Qualifier("primaryDataSource") DataSource primaryDataSource) throws Exception {
        final SqlSessionFactoryBean sessionFactory = new SqlSessionFactoryBean();
        sessionFactory.setDataSource(primaryDataSource);  // 設置數據源bean
        sessionFactory.setMapperLocations(new PathMatchingResourcePatternResolver()
                .getResources(PrimaryDataBaseConfig.MAPPER_LOCATION));  // 設置mapper文件路徑

        return sessionFactory.getObject();
    }
}

同樣的，還需要創建一個從數據源配置類，與主數據源配置類不同的是，從數據源配置類不能使用@Primary註解，即表示它是一個從數據源。代碼如下：

package com.dabo.mini.game.zhaxinle.config;

import com.alibaba.druid.pool.DruidDataSource;
import lombok.Data;
import org.apache.ibatis.session.SqlSessionFactory;
import org.mybatis.spring.SqlSessionFactoryBean;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;

import javax.sql.DataSource;
import java.sql.SQLException;

/**
 * @ProjectName zhaxinle
 * @Author: zeroJun
 * @Date: 2018/8/16 16:49
 * @Description: 後臺數據源配置類
 */

@Data
@Configuration
@ConfigurationProperties(prefix = "back.datasource.druid")
@MapperScan(basePackages = BackDataBaseConfig.PACKAGE, sqlSessionFactoryRef = "backSqlSessionFactory")
public class BackDataBaseConfig {

    /**
     * dao層的包路徑
     */
    static final String PACKAGE = "com.dabo.mini.game.zhaxinle.dao.back";

    /**
     * mapper文件的相對路徑
     */
    private static final String MAPPER_LOCATION = "classpath:mappers/back/*.xml";

    private String filters;
    private String url;
    private String username;
    private String password;
    private String driverClassName;
    private int initialSize;
    private int minIdle;
    private int maxActive;
    private long maxWait;
    private long timeBetweenEvictionRunsMillis;
    private long minEvictableIdleTimeMillis;
    private String validationQuery;
    private boolean testWhileIdle;
    private boolean testOnBorrow;
    private boolean testOnReturn;
    private boolean poolPreparedStatements;
    private int maxPoolPreparedStatementPerConnectionSize;

    @Bean(name = "backDataSource")
    public DataSource backDataSource() throws SQLException {
        DruidDataSource druid = new DruidDataSource();
        // 監控統計攔截的filters
        druid.setFilters(filters);

        // 配置基本屬性
        druid.setDriverClassName(driverClassName);
        druid.setUsername(username);
        druid.setPassword(password);
        druid.setUrl(url);

        //初始化時建立物理連接的個數
        druid.setInitialSize(initialSize);
        //最大連接池數量
        druid.setMaxActive(maxActive);
        //最小連接池數量
        druid.setMinIdle(minIdle);
        //獲取連接時最大等待時間，單位毫秒。
        druid.setMaxWait(maxWait);
        //間隔多久進行一次檢測，檢測需要關閉的空閑連接
        druid.setTimeBetweenEvictionRunsMillis(timeBetweenEvictionRunsMillis);
        //一個連接在池中最小生存的時間
        druid.setMinEvictableIdleTimeMillis(minEvictableIdleTimeMillis);
        //用來檢測連接是否有效的sql
        druid.setValidationQuery(validationQuery);
        //建議配置為true，不影響性能，並且保證安全性。
        druid.setTestWhileIdle(testWhileIdle);
        //申請連接時執行validationQuery檢測連接是否有效
        druid.setTestOnBorrow(testOnBorrow);
        druid.setTestOnReturn(testOnReturn);
        //是否緩存preparedStatement，也就是PSCache，oracle設為true，mysql設為false。分庫分表較多推薦設置為false
        druid.setPoolPreparedStatements(poolPreparedStatements);
        // 打開PSCache時，指定每個連接上PSCache的大小
        druid.setMaxPoolPreparedStatementPerConnectionSize(maxPoolPreparedStatementPerConnectionSize);

        return druid;
    }

    @Bean(name = "backTransactionManager")
    public DataSourceTransactionManager backTransactionManager() throws SQLException {
        return new DataSourceTransactionManager(backDataSource());
    }

    @Bean(name = "backSqlSessionFactory")
    public SqlSessionFactory backSqlSessionFactory(@Qualifier("backDataSource") DataSource backDataSource) throws Exception {
        final SqlSessionFactoryBean sessionFactory = new SqlSessionFactoryBean();
        sessionFactory.setDataSource(backDataSource);
        sessionFactory.setMapperLocations(new PathMatchingResourcePatternResolver()
                .getResources(BackDataBaseConfig.MAPPER_LOCATION));

        return sessionFactory.getObject();
    }
}

完成以上配置後，該工程就具有連接兩個數據庫的能力了，如果要配置兩個以上的數據庫也是一樣的，配置多個從數據源即可。業務代碼層面除了需要將不同的數據源相關的mapper、dao、pojo分包存放方便掃描之外，代碼上的編寫還是和之前單數據源的時候一樣，所以這裏就不貼出業務代碼了。

SpringBoot+Druid+Mybatis配置多數據源

相關推薦

SpringBoot+Druid+Mybatis配置多數據源

sep 表示 beans 51cto desc 還需要 spring obj -s 我們在開發一個項目的時候，可能會遇到需要對多個數據庫進行讀寫的需求，這時候就得在項目中配置多個數據源了。在Java項目的開發中，目前最常用的數據操作框架是 Mybatis，開發框架也都基本用

springboot:mybatis配置多數據源

ces npr getc text private port work filters ESS 第一個數據源：import org.springframework.boot.context.properties.ConfigurationProperties; import

[轉]SpringMVC+ Mybatis 配置多數據源 + 手動切換數據源

cat ons 接口 data ppi 研究 www contex ans 正確可行的解決方法：使用Spring提供的AbstractRoutingDataSource類來根據請求路由到不同的數據源。具體做法是先設置兩個不同的dataSource代表不同的數據源，再建一個總

springboot 2.1.3 + mybatis + druid配置多數據源

tab sys cal 1.9 path exc http bject cat 在一些大型的項目中，通常會選擇多數據庫來滿足一些業務需求，此處講解使用springboot、mybatis和druid來配置多數據源 1、依賴配置 　　pom文件引入相關依賴

SpringBoot+Mybatis+ Druid+PageHelper 實現多數據源並分頁

utf 重置數據 count system 配置文件 urn 規模 pos mapper 前言 本篇文章主要講述的是SpringBoot整合Mybatis、Druid和PageHelper 並實現多數據源和分頁。其中SpringBoot整合Mybatis這塊，在之前的的一篇

springboot配置多數據源

目前 toolbar ont oca exceptio init user brush temp 在做項目的過程中難免會遇到這種情況：一個項目需要兩個數據庫中的數據，希望這篇文章能給遇到這些問題的小夥伴一點幫助第一步：將兩個數據源的mapper接口和xml文件分別放入不同的

在Springboot2.0項目中使用Druid配置多數據源

clas sin word npr PE ng- 多個 pap final 在Springboot出現之前配置數據源以及相關的事物，緩存等內容一直是個繁瑣的工作，但是Springboot出現後這些基本都可以靠默認配置搞定，就變得很輕松了。這就是現在推崇模板>配置的原因

MyBatis配置數據源的兩種方式

devel tom src 方式 onf sof 數據 XML nag ---------------------siwuxie095 MyBatis 配置數據源的兩種方式 1、配置方式一：配置數據庫連接

JdbcTemplate 配置多數據源(完全照抄,完整)

framework -i into repos .so not scrip version org <?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.

Spring3 整合MyBatis3 配置多數據源 動態選擇SqlSessionFactory（轉）

poi lba == lan bat load -o esp int 1. Spring整合MyBatis切換SqlSessionFactory有兩種方法，第一、 繼承SqlSessionDaoSupport，重寫獲取Sql

Tomcat配置多數據源出現Unable to create initial connections

list source nali fin lee runnable bst r.java PE 遷自惡心人的網易博客 2017-06-27完整標題：Tomcat配置多個JNDI數據源（Postgresql）出現Unable to create initial connect

SpringMVC mybatis SSM 多數據源 java redis shiro ehcach

tail .com 圖片爬蟲 AS 系統菜單 socket編程 在線編輯器 控件 通過 博文來源：http://www.fhadmin.org/webnewsdetail1.htmlA代碼編輯器，在線模版編輯，仿開發工具編輯器，pdf在線預覽，文件轉換編碼B 集成代碼生成器

springboot2.0.3使用jpa和hibernate的方式配置多數據源(sqlite和mysql)

自動 username urn ini sqli tps www 不同的 sqlite數據庫 application.properties配置: #數據庫配置 mysql.spring.datasource.jdbc-url =jdbc:mysql://127.0.0.1

sping boot 配置多數據源

eid .com druid ring char type vendor manage ssi spring boot 本身自帶對數據源的支持。 但在項目開發過程中，存在這種情況需要用到多數據源，用spring boot 自帶的數據源就不是那麽方便了。這裏有個實例實現spr

spring mvc + mybaties配置多數據源

源配置 項目 mvc 數據源 src 分配 就是 配置數據源 image 1：首先配置數據源,可以現在配置文件中引入，在這裏我直接寫在spring配置文件中了 首先給出單數據源配置文件 主要修改的就是這二個地方， 現在來看看

SpringBoot入門之基於Druid配置Mybatis多數據源

this ssp hide llb 就是 delet exc .sql isp 上一篇了解了Druid進行配置連接池的監控和慢sql處理，這篇了解下使用基於基於Druid配置Mybatis多數據源。SpringBoot默認配置數據庫連接信息時只需設置url等屬性信息就可以了

springboot mybatis 多數據源配置

進行 figure resource path can sca mar pre esc 首先導入mybatis等包，這裏就不多說。 下面是配置多數據源和mybatis，每個數據源對應一套mybatis模板 數據源1： 1 package com.aa

springboot添加多數據源連接池並配置Mybatis

是個 -name 個數 數據庫日誌 發生 uri -i esql 開始 springboot添加多數據源連接池並配置Mybatis 轉載請註明出處：https://www.cnblogs.com/funnyzpc/p/9190226.html May 12, 201

shardingsphere多數據源（springboot + mybatis+shardingsphere+druid）

names inf 讀取 直接 sql 個數 mage 源配置 actor org.springframeword.boot:spring-boot-starer-web: 2.0.4release io.shardingsphere:sharding-jdbc-spri

springMVC+spring+mybatis多數據源配置

expr init mybatis onf exp 超時 png wait http 1.application.properties配置 <?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http