Spring-boot 配置dataSource 可配多資料來源

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

第一種方式：有時好使有時不好使，原因不明！推薦使用第二種方式
import java.sql.SQLException;
import javax.sql.DataSource;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.web.servlet.FilterRegistrationBean;
 
import org.springframework.boot.web.servlet.ServletRegistrationBean;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import com.alibaba.druid.filter.stat.MergeStatFilter;
import com.alibaba.druid.pool.DruidDataSource;
 
import com.alibaba.druid.support.http.StatViewServlet;
import com.alibaba.druid.support.http.WebStatFilter;
import org.springframework.data.jpa.repository.config.EnableJpaRepositories;
import org.springframework.transaction.annotation.EnableTransactionManagement;
/**
 * Druid配置
 * Created by Promise.H on 2018/01/15
 
 */
@Configuration
@EnableTransactionManagement
@EnableJpaRepositories(basePackages = {"com.qn.dao.rpt"})
public class DruidDB1Config {
    private Logger logger = LoggerFactory.getLogger(DruidDB1Config.class);
@Value("${spring.datasource.db1.url}")
    private String dbUrl;
@Value("${spring.datasource.username}")
    private String username;
@Value("${spring.datasource.pas1.password}")
    private String password;
@Value("${spring.datasource.driver-class-name}")
    private String driverClassName;
@Value("${spring.datasource.initialSize}")
    private int initialSize;
@Value("${spring.datasource.minIdle}")
    private int minIdle;
@Value("${spring.datasource.maxActive}")
    private int maxActive;
@Value("${spring.datasource.maxWait}")
    private int maxWait;
@Value("${spring.datasource.timeBetweenEvictionRunsMillis}")
    private int timeBetweenEvictionRunsMillis;
@Value("${spring.datasource.minEvictableIdleTimeMillis}")
    private int minEvictableIdleTimeMillis;
@Value("${spring.datasource.validationQuery}")
    private String validationQuery;
@Value("${spring.datasource.testWhileIdle}")
    private boolean testWhileIdle;
@Value("${spring.datasource.testOnBorrow}")
    private boolean testOnBorrow;
@Value("${spring.datasource.testOnReturn}")
    private boolean testOnReturn;
@Value("${spring.datasource.poolPreparedStatements}")
    private boolean poolPreparedStatements;
@Value("${spring.datasource.maxPoolPreparedStatementPerConnectionSize}")
    private int maxPoolPreparedStatementPerConnectionSize;
@Value("${spring.datasource.filters}")
    private String filters;
@Value("{spring.datasource.connectionProperties}")
    private String connectionProperties;
@Bean(name="dataSource1")     //宣告其為Bean例項
@Primary  //在同樣的DataSource中，首先使用被標註的DataSource
@Qualifier("dataSource1")
    public DataSource dataSource(){
        DruidDataSource datasource = new DruidDataSource();
datasource.setUrl(this.dbUrl);
datasource.setUsername(username);
datasource.setPassword(password);
datasource.setDriverClassName(driverClassName);
//configuration
datasource.setInitialSize(initialSize);
datasource.setMinIdle(minIdle);
datasource.setMaxActive(maxActive);
datasource.setMaxWait(maxWait);
datasource.setTimeBetweenEvictionRunsMillis(timeBetweenEvictionRunsMillis);
datasource.setMinEvictableIdleTimeMillis(minEvictableIdleTimeMillis);
datasource.setValidationQuery(validationQuery);
datasource.setTestWhileIdle(testWhileIdle);
datasource.setTestOnBorrow(testOnBorrow);
datasource.setTestOnReturn(testOnReturn);
datasource.setPoolPreparedStatements(poolPreparedStatements);
datasource.setMaxPoolPreparedStatementPerConnectionSize(maxPoolPreparedStatementPerConnectionSize);
        try {
            datasource.setFilters(filters);
} catch (SQLException e) {
            logger.error("druid configuration initialization filter", e);
}
        datasource.setConnectionProperties(connectionProperties);
        return datasource;
}

    @Bean(name="druidServlet1")
    public ServletRegistrationBean druidServlet() {
        ServletRegistrationBean servletRegistrationBean = new ServletRegistrationBean(new StatViewServlet(), "/druid/*");
        return servletRegistrationBean;
}

    @Bean(name="filterRegistrationBean1")
    public FilterRegistrationBean filterRegistrationBean() {
        FilterRegistrationBean filterRegistrationBean = new FilterRegistrationBean();
filterRegistrationBean.setFilter(new WebStatFilter());
filterRegistrationBean.addUrlPatterns("/*");
filterRegistrationBean.addInitParameter("exclusions", "*.js,*.gif,*.jpg,*.png,*.css,*.ico,/druid/*");
        return filterRegistrationBean;
}
    
    /**
     * 設定慢sql列印時間
     * @return
*/
@Bean(name="mergeStatFilter1")
    public MergeStatFilter mergeStatFilter(){
       MergeStatFilter mergeStatFilter=new MergeStatFilter();
mergeStatFilter.setLogSlowSql(true);
mergeStatFilter.setSlowSqlMillis(1);
       return mergeStatFilter;
}
}

第二種方式：

編寫兩個datasource


import com.alibaba.druid.pool.DruidDataSource;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;

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

/**
 * Created by win 10 on 2018/2/7.
 */
@Configuration
public class DataSourcePrimaryConfig {
    private Logger logger = LoggerFactory.getLogger(DataSourcePrimaryConfig.class);

    @Value("${spring.datasource.db1.url}")
    private String dbUrl;

    @Value("${spring.datasource.username}")
    private String username;

    @Value("${spring.datasource.pas1.password}")
    private String password;

    @Value("${spring.datasource.driver-class-name}")
    private String driverClassName;

    @Value("${spring.datasource.initialSize}")
    private int initialSize;

    @Value("${spring.datasource.minIdle}")
    private int minIdle;

    @Value("${spring.datasource.maxActive}")
    private int maxActive;

    @Value("${spring.datasource.maxWait}")
    private int maxWait;

    @Value("${spring.datasource.timeBetweenEvictionRunsMillis}")
    private int timeBetweenEvictionRunsMillis;

    @Value("${spring.datasource.minEvictableIdleTimeMillis}")
    private int minEvictableIdleTimeMillis;

    @Value("${spring.datasource.validationQuery}")
    private String validationQuery;

    @Value("${spring.datasource.testWhileIdle}")
    private boolean testWhileIdle;

    @Value("${spring.datasource.testOnBorrow}")
    private boolean testOnBorrow;

    @Value("${spring.datasource.testOnReturn}")
    private boolean testOnReturn;

    @Value("${spring.datasource.poolPreparedStatements}")
    private boolean poolPreparedStatements;

    @Value("${spring.datasource.maxPoolPreparedStatementPerConnectionSize}")
    private int maxPoolPreparedStatementPerConnectionSize;

    @Value("${spring.datasource.filters}")
    private String filters;

    @Value("{spring.datasource.connectionProperties}")
    private String connectionProperties;

    @Bean(name = "primaryDataSource")
    @Primary
    @Qualifier("primaryDataSource")
    public DataSource primaryDataSource() {
        DruidDataSource datasource = new DruidDataSource();

        datasource.setUrl(this.dbUrl);
        datasource.setUsername(username);
        datasource.setPassword(password);
        datasource.setDriverClassName(driverClassName);

        //configuration
        datasource.setInitialSize(initialSize);
        datasource.setMinIdle(minIdle);
        datasource.setMaxActive(maxActive);
        datasource.setMaxWait(maxWait);
        datasource.setTimeBetweenEvictionRunsMillis(timeBetweenEvictionRunsMillis);
        datasource.setMinEvictableIdleTimeMillis(minEvictableIdleTimeMillis);
        datasource.setValidationQuery(validationQuery);
        datasource.setTestWhileIdle(testWhileIdle);
        datasource.setTestOnBorrow(testOnBorrow);
        datasource.setTestOnReturn(testOnReturn);
        datasource.setPoolPreparedStatements(poolPreparedStatements);
        datasource.setMaxPoolPreparedStatementPerConnectionSize(maxPoolPreparedStatementPerConnectionSize);
        try {
            datasource.setFilters(filters);
        } catch (SQLException e) {
            logger.error("druid configuration initialization filter", e);
        }
        datasource.setConnectionProperties(connectionProperties);
        return datasource;
    }
}

import com.alibaba.druid.pool.DruidDataSource;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

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

/**
 * Created by win 10 on 2018/2/7.
 */
@Configuration
public class DataSourceSecondaryConfig {

    private Logger logger = LoggerFactory.getLogger(DataSourceSecondaryConfig.class);

    @Value("${spring.datasource.db2.url}")
    private String dbUrl;

    @Value("${spring.datasource.username}")
    private String username;

    @Value("${spring.datasource.pas2.password}")
    private String password;

    @Value("${spring.datasource.driver-class-name}")
    private String driverClassName;

    @Value("${spring.datasource.initialSize}")
    private int initialSize;

    @Value("${spring.datasource.minIdle}")
    private int minIdle;

    @Value("${spring.datasource.maxActive}")
    private int maxActive;

    @Value("${spring.datasource.maxWait}")
    private int maxWait;

    @Value("${spring.datasource.timeBetweenEvictionRunsMillis}")
    private int timeBetweenEvictionRunsMillis;

    @Value("${spring.datasource.minEvictableIdleTimeMillis}")
    private int minEvictableIdleTimeMillis;

    @Value("${spring.datasource.validationQuery}")
    private String validationQuery;

    @Value("${spring.datasource.testWhileIdle}")
    private boolean testWhileIdle;

    @Value("${spring.datasource.testOnBorrow}")
    private boolean testOnBorrow;

    @Value("${spring.datasource.testOnReturn}")
    private boolean testOnReturn;

    @Value("${spring.datasource.poolPreparedStatements}")
    private boolean poolPreparedStatements;

    @Value("${spring.datasource.maxPoolPreparedStatementPerConnectionSize}")
    private int maxPoolPreparedStatementPerConnectionSize;

    @Value("${spring.datasource.filters}")
    private String filters;

    @Value("{spring.datasource.connectionProperties}")
    private String connectionProperties;

    @Bean(name = "secondaryDataSource")
    @Qualifier("secondaryDataSource")
    public DataSource secondaryDataSource() {
        DruidDataSource datasource = new DruidDataSource();

        datasource.setUrl(this.dbUrl);
        datasource.setUsername(username);
        datasource.setPassword(password);
        datasource.setDriverClassName(driverClassName);

        //configuration
        datasource.setInitialSize(initialSize);
        datasource.setMinIdle(minIdle);
        datasource.setMaxActive(maxActive);
        datasource.setMaxWait(maxWait);
        datasource.setTimeBetweenEvictionRunsMillis(timeBetweenEvictionRunsMillis);
        datasource.setMinEvictableIdleTimeMillis(minEvictableIdleTimeMillis);
        datasource.setValidationQuery(validationQuery);
        datasource.setTestWhileIdle(testWhileIdle);
        datasource.setTestOnBorrow(testOnBorrow);
        datasource.setTestOnReturn(testOnReturn);
        datasource.setPoolPreparedStatements(poolPreparedStatements);
        datasource.setMaxPoolPreparedStatementPerConnectionSize(maxPoolPreparedStatementPerConnectionSize);
        try {
            datasource.setFilters(filters);
        } catch (SQLException e) {
            logger.error("druid configuration initialization filter", e);
        }
        datasource.setConnectionProperties(connectionProperties);
        return datasource;
    }
}

也可以利用SpringBoot自動配置

@Configuration
public class DataSourceConfig {

    @Bean(name = "primaryDataSource")
    @Qualifier("primaryDataSource")
    @ConfigurationProperties(prefix="spring.datasource.primary")
    public DataSource primaryDataSource() {
        return DataSourceBuilder.create().build();
    }

    @Bean(name = "secondaryDataSource")
    @Qualifier("secondaryDataSource")
    @Primary
    @ConfigurationProperties(prefix="spring.datasource.secondary")
    public DataSource secondaryDataSource() {
        return DataSourceBuilder.create().build();
    }

}

編寫兩個從config


import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.autoconfigure.orm.jpa.JpaProperties;
import org.springframework.boot.orm.jpa.EntityManagerFactoryBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import org.springframework.data.jpa.repository.config.EnableJpaRepositories;
import org.springframework.orm.jpa.JpaTransactionManager;
import org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean;
import org.springframework.transaction.PlatformTransactionManager;
import org.springframework.transaction.annotation.EnableTransactionManagement;

import javax.persistence.EntityManager;
import javax.sql.DataSource;
import java.util.Map;

/**
 * Created by win 10 on 2018/2/7.
 */
@Configuration
@EnableTransactionManagement
@EnableJpaRepositories(
        entityManagerFactoryRef="entityManagerFactoryPrimary",
        transactionManagerRef="transactionManagerPrimary",
        basePackages= { "com.qn.dao.rpt" }) //設定Repository所在位置
public class PrimaryConfig {
    @Autowired
    @Qualifier("primaryDataSource")
    private DataSource primaryDataSource;

    @Primary
    @Bean(name = "entityManagerPrimary")
    public EntityManager entityManager(EntityManagerFactoryBuilder builder) {
        return entityManagerFactoryPrimary(builder).getObject().createEntityManager();
    }

    @Primary
    @Bean(name = "entityManagerFactoryPrimary")
    public LocalContainerEntityManagerFactoryBean entityManagerFactoryPrimary (EntityManagerFactoryBuilder builder) {
        return builder
                .dataSource(primaryDataSource)
                .properties(getVendorProperties(primaryDataSource))
                .packages("com.qn.domain.rpt") //設定實體類所在位置
                .persistenceUnit("primaryPersistenceUnit")
                .build();
    }

    @Autowired
    private JpaProperties jpaProperties;

    private Map<String, String> getVendorProperties(DataSource dataSource) {
        return jpaProperties.getHibernateProperties(dataSource);
    }

    @Primary
    @Bean(name = "transactionManagerPrimary")
    public PlatformTransactionManager transactionManagerPrimary(EntityManagerFactoryBuilder builder) {
        return new JpaTransactionManager(entityManagerFactoryPrimary(builder).getObject());
    }
}


import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.autoconfigure.orm.jpa.JpaProperties;
import org.springframework.boot.orm.jpa.EntityManagerFactoryBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.jpa.repository.config.EnableJpaRepositories;
import org.springframework.orm.jpa.JpaTransactionManager;
import org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean;
import org.springframework.transaction.PlatformTransactionManager;
import org.springframework.transaction.annotation.EnableTransactionManagement;

import javax.persistence.EntityManager;
import javax.sql.DataSource;
import java.util.Map;

/**
 * Created by win 10 on 2018/2/7.
 */
@Configuration
@EnableTransactionManagement
@EnableJpaRepositories(
        entityManagerFactoryRef="entityManagerFactorySecondary",
        transactionManagerRef="transactionManagerSecondary",
        basePackages= { "com.qn.dao.qyrep" }) //設定Repository所在位置
public class SecondaryConfig {
    @Autowired
    @Qualifier("secondaryDataSource")
    private DataSource secondaryDataSource;

    @Bean(name = "entityManagerSecondary")
    public EntityManager entityManager(EntityManagerFactoryBuilder builder) {
        return entityManagerFactorySecondary(builder).getObject().createEntityManager();
    }

    @Bean(name = "entityManagerFactorySecondary")
    public LocalContainerEntityManagerFactoryBean entityManagerFactorySecondary (EntityManagerFactoryBuilder builder) {
        return builder
                .dataSource(secondaryDataSource)
                .properties(getVendorProperties(secondaryDataSource))
                .packages("com.qn.domain.qyrep") //設定實體類所在位置
                .persistenceUnit("secondaryPersistenceUnit")
                .build();
    }

    @Autowired
    private JpaProperties jpaProperties;

    private Map<String, String> getVendorProperties(DataSource dataSource) {
        return jpaProperties.getHibernateProperties(dataSource);
    }

    @Bean(name = "transactionManagerSecondary")
    PlatformTransactionManager transactionManagerSecondary(EntityManagerFactoryBuilder builder) {
        return new JpaTransactionManager(entityManagerFactorySecondary(builder).getObject());
    }

}

Spring-boot 配置dataSource 可配多資料來源

第一種方式：有時好使有時不好使，原因不明！推薦使用第二種方式 import java.sql.SQLException; import javax.sql.DataSource; import org.slf4j.Logger; import org.slf4j.Logger

詳解Spring Boot配置文件之多環境配置

多個提高效率橫線文件 style ica property form blog 一. 多環境配置的好處： 1.不同環境配置可以配置不同的參數~ 2.便於部署，提高效率，減少出錯~ 二. properties多環境配置 1. 配置激活選項 spring.profile

Spring Boot + Mybatis + Druid 動態切換多資料來源

在大型應用程式中，配置主從資料庫並使用讀寫分離是常見的設計模式。在Spring應用程式中，要實現讀寫分離，最好不要對現有程式碼進行改動，而是在底層透明地支援。這樣，就需要我們再一個專案中，配置兩個，乃至多個數據源。今天，小編先來介紹一下自己配置動態多資料來源的步驟專案簡介：　　編譯器：ID

Spring Boot 整合 Mybatis 實現 Druid 多資料來源詳解

“清醒時做事，糊塗時跑步，大怒時睡覺，獨處時思考” 本文提綱一、多資料來源的應用場景二、執行 springboot-mybatis-mutil-datasource 工程案例三、springboot-mybatis-mutil-datasource 工程程式碼配置詳解一、多資料來

Spring boot 基於註解的的多資料來源切換

一.建立以下類import org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource;/** * 動態資料來源 * * @author liwc * @version V1.0 * @date 2

spring-boot入門（六）多資料來源

spring-boot入門（六）多資料來源我們現在可以通過自定義的資料來源，用spring boot迅速的搭建起一個訪問資料庫的應用，有時候一個系統往往會和多個數據庫進行互動。當然可以通過遠端服務呼叫方式訪問多個數據庫，每個服務負責不同的資料庫訪問，但是多資料來源的方式可能會更加的

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

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

(2)、Spring Boot與Mybatis的整合( 多資料來源)

1、背景的介紹有時候我們需要做分庫分表，那麼肯定存在多資料來源，Spring Boot和Mybatis的多資料來源是如何整合的呢？比如說我們現在做了一個浪跡天涯管理的後臺系統，商品資訊是存在itemCenter資料來源中的，而與使用者相關的資訊是存在account資料來源中，

Spring Boot 配置DataSource

目錄 [TOC] 1. 使用Spring Boot預設資料來源 1.1 引入POM依賴在pom檔案中直接依賴官方提供的spring-boot-start-jdbc模組或者spring-boot-start-data-jpa模組。 <

Spring Boot配置DataSource並整合Mybatis

1.引入POM依賴 <dependency> <groupId>org.springframework.data</groupId> <artifactId>spring-data-commons</artifact

spring-boot-route（十）多資料來源切換

前面我們已經介紹了三種方式來操作資料庫，在實際開發中，往往會出現一個服務連線多個數據庫的需求，這時候就需要在專案中進行靈活切換資料來源來完成多個數據庫操作。這一章中，我們使用jdbcTemplate來學習多資料來源的配置。 ## 一準備工作 ### 1.1 建庫、建表我們新建兩個庫`db1`和`db

[轉] Spring Boot配置多個DataSource

pro img ssp 情況每一個所有 title 進行 rom [From] https://www.liaoxuefeng.com/article/001484212576147b1f07dc0ab9147a1a97662a0bd270c20000 Sprin

spring boot 配置多資料來源

1.application.yml配置 server: port: 8088 spring: http: multipart: max-file-size: 50Mb max-request-size: 50Mb enabl

Spring boot配置多個Redis資料來源操作例項

原文：https://www.jianshu.com/p/c79b65b253fa Spring boot配置多個Redis資料來源操作例項在SpringBoot是專案中整合了兩個Redis的操作例項，可以增加多個；一般在一個微服務生態群中是不會出現多

Spring Boot配置多資料來源並實現Druid自動切換

SpringBoot多資料來源切換,先上配置檔案: 1.pom: <?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0"

spring boot 配置單資料來源和多controller問題

1 配置資料來源參考這篇部落格使用的是jpa hibernate 2 程式碼目錄問題遇到一些奇奇怪怪的啟動問題 1 建立了另一個controller，結果無法完成對映，requestMapping失敗，報404 2 說是找不到userDao 的bean，無法自動

Spring Boot配置多個DataSource

使用Spring Boot時，預設情況下，配置DataSource非常容易。Spring Boot會自動為我們配置好一個DataSource。如果在application.yml中指定了spring.datasource的相關配置，Spring Boot就會使用該配置

Spring boot配置資料來源報錯之java.sql.SQLException和java.sql.SQLNonTransientConnectionException

週末想自己用Spring boot整合Mybatis寫點簡單的demo，沒想到出了點以前沒遇到過的bug，特記錄一下 java.sql.SQLException: The server time zone value 'ÖÐ¹ú±ê×¼Ê±¼ä' is unrecognized or repre

Spring Boot 配置檔案詳解：自定義屬性、隨機數、多環境配置等

相信很多人選擇Spring Boot主要是考慮到它既能兼顧Spring的強大功能，還能實現快速開發的便捷。我們在Spring Boot使用過程中，最直觀的感受就是沒有了原來自己整合Spring應用時繁多的XML配置內容，替代它的是在pom.xml中引入模組化的Starter POMs，其中各個模組都有自己的預

spring boot配置druid資料來源和監控配置

直接上程式碼：一.pom.xml中新增依賴 1 <dependency> 2 <groupId>com.github.drtrang</groupId> 3 <artifactId>druid-s

Spring-boot 配置dataSource 可配多資料來源

相關推薦