溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務條款》

Springboot mybais配置多數(shù)據(jù)源過程解析

發(fā)布時間:2020-08-22 20:23:19 來源:腳本之家 閱讀:195 作者:一步一高 欄目:編程語言

一、分包方式實現(xiàn):

1、在application.properties中配置兩個數(shù)據(jù)庫:

#druid連接池
#dataSoureOne(這里是我本地的數(shù)據(jù)源)
spring.datasource.one.type=com.alibaba.druid.pool.DruidDataSource
spring.datasource.one.driver-class-name=com.mysql.jdbc.Driver
spring.datasource.one.jdbc-url=jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=UTC
spring.datasource.one.username=root
spring.datasource.one.password=root
#dataSoureTwo(這里是我們服務器的數(shù)據(jù)源)
spring.datasource.two.type=com.alibaba.druid.pool.DruidDataSource
spring.datasource.two.driver-class-name=com.mysql.jdbc.Driver
spring.datasource.two.jdbc-url=jdbc:mysql://xx.xxx.xx.xxx:3306/kds_master_info?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=UTC
spring.datasource.two.username=root
spring.datasource.two.password=KDSmaster123

2、建立連個數(shù)據(jù)源的配置文件:

注意下面DataSource包引入的是import javax.activation.DataSource;

@Configuration// 配置mybatis的接口類放的地方
@MapperScan(basePackages = "com.example.mybatis.mapper",sqlSessionFactoryRef = "sqlSessionFactoryOne")
public class DataSourceConfigOne {

  @Bean(name = "dataSourceOne")
  @Primary// 表示這個數(shù)據(jù)源是默認數(shù)據(jù)源
  // 讀取application.properties中的配置參數(shù)映射成為一個對象,prefix表示參數(shù)的前綴
  @ConfigurationProperties(prefix = "spring.datasource.one")
  public DataSource dataSourceOne() {
    return DataSourceBuilder.create().build();
  }

  @Bean(name = "sqlSessionFactoryOne")
  @Primary
  public SqlSessionFactory sqlSessionFactoryOne(@Qualifier("dataSourceOne") DataSource datasource)throws Exception {
    SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
    bean.setDataSource(datasource);
    bean.setMapperLocations(
        // 設置mybatis的xml所在位置
        new PathMatchingResourcePatternResolver().getResources("classpath:mapper/*.xml"));    bean.getObject().getConfiguration().setMapUnderscoreToCamelCase(true);return bean.getObject();
  }

  @Primary
  public SqlSessionTemplate sqlsessiontemplateOne(@Qualifier("sqlsessiontemplateOne") SqlSessionFactory sessionfactory) {
    return new SqlSessionTemplate(sessionfactory);
  }
}
@Configuration
@MapperScan(basePackages = "com.example.mybatis.mapper2",sqlSessionFactoryRef = "sqlSessionFactoryTwo")
public class DataSourceConfigTwo {
  @Bean(name = "dataSourceTwo")
  // 讀取application.properties中的配置參數(shù)映射成為一個對象,prefix表示參數(shù)的前綴
  @ConfigurationProperties(prefix = "spring.datasource.two")
  public DataSource dataSourceTwo() {
    return DataSourceBuilder.create().build();
  }

  @Bean(name = "sqlSessionFactoryTwo")
  public SqlSessionFactory sqlSessionFactoryTwo(@Qualifier("dataSourceTwo") DataSource datasource)throws Exception {
    SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
    bean.setDataSource((javax.sql.DataSource) datasource);
    bean.setMapperLocations(
        // 設置mybatis的xml所在位置
        new PathMatchingResourcePatternResolver().getResources("classpath:mapper2/*.xml"));    bean.getObject().getConfiguration().setMapUnderscoreToCamelCase(true);
    return bean.getObject();
  }

  public SqlSessionTemplate sqlsessiontemplateTwo(@Qualifier("sqlsessiontemplateTwo") SqlSessionFactory sessionfactory) {
    return new SqlSessionTemplate(sessionfactory);
  }
}

注意:1、@Primary這個注解必須要加,因為不加的話spring將分不清楚那個為主數(shù)據(jù)源(默認數(shù)據(jù)源)2、mapper的接口、xml形式以及dao層都需要兩個分開,目錄如圖:

Springboot mybais配置多數(shù)據(jù)源過程解析

3、bean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources(“XXXX”));mapper的xml形式文件位置必須要配置,不然將報錯:no statement (這種錯誤也可能是mapper的xml中,namespace與項目的路徑不一致導致的)

4、在service層中根據(jù)不同的業(yè)務注入不同的dao層:

Springboot mybais配置多數(shù)據(jù)源過程解析

Springboot mybais配置多數(shù)據(jù)源過程解析

5.開始我啟動項目并訪問接口會報錯,查看了半小時才發(fā)現(xiàn),是下劃線與駝峰映射失敗,這個要在sqlSessionFactoryOne和sqlSessionFactoryTwo里面添加一行bean.getObject().getConfiguration().setMapUnderscoreToCamelCase(true);才可以,然后繼續(xù)訪問,又報錯Failed to obtain JDBC Connection; nested exception is com.mysql.jdbc.exceptions.jdbc4.CommunicationsException: Communications link failure.后來查詢得知,要在上面的數(shù)據(jù)庫連接url中將&useSSL=true改為&useSSL=false

最后測試一下,兩個數(shù)據(jù)庫userInfo和user表的數(shù)據(jù)都顯示出來了:

userInfo:

Springboot mybais配置多數(shù)據(jù)源過程解析

user:

Springboot mybais配置多數(shù)據(jù)源過程解析

最后還有一個錯誤忘了補充,在這里補充一下,我的springboot是2.x版本,在配置單個數(shù)據(jù)源時候,數(shù)據(jù)庫連接的url是spring.datasource.url=xxx,這樣沒有問題,但是在配置多數(shù)據(jù)源的時候spring.datasource.one.url和spring.datasource.two.url會報錯jdbcUrl is required with driverClassName.將spring.datasource.one.url和spring.datasource.two.url中的url改成spring.datasource.one.jdbc-url,也就是將url改成jdbc-url即可。

以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支持億速云。

向AI問一下細節(jié)

免責聲明:本站發(fā)布的內容(圖片、視頻和文字)以原創(chuàng)、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯(lián)系站長郵箱:is@yisu.com進行舉報,并提供相關證據(jù),一經查實,將立刻刪除涉嫌侵權內容。

AI