Springboot如何同時裝配兩個相同類型數(shù)據(jù)庫

更新時間：2021年11月17日 11:25:13 作者：enjoy程序人生

這篇文章主要介紹了Springboot如何同時裝配兩個相同類型數(shù)據(jù)庫，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教

同時裝配兩個相同類型數(shù)據(jù)庫

1.配置文件：

spring:
  profiles:
    active: dev
 
  datasource:
    primary:
      jdbc-url: jdbc:sqlserver://localhost:1111;DatabaseName=DB1
      driverClassName: com.microsoft.sqlserver.jdbc.SQLServerDriver
      type: com.alibaba.druid.pool.DruidDataSource
      username: root
      password: root
    secondary:
      jdbc-url: jdbc:sqlserver://localhost:1111;DatabaseName=DB2
      driverClassName: com.microsoft.sqlserver.jdbc.SQLServerDriver
      type: com.alibaba.druid.pool.DruidDataSource
      username: root
      password: root

2.配置類：

①主配置類：DataSourceConfigPrimary

@Configuration
@MapperScan(basePackages = "com.message.dao.primary", sqlSessionFactoryRef = "primarySqlSessionFactory")
public class DataSourceConfigPrimary {
 
    // 將這個對象放入Spring容器中
    @Bean(name = "primaryDataSource")
    // 表示這個數(shù)據(jù)源是默認數(shù)據(jù)源
    @Primary
    // 讀取application.properties中的配置參數(shù)映射成為一個對象
    // prefix表示參數(shù)的前綴
    @ConfigurationProperties(prefix = "spring.datasource.primary")
    public DataSource getDateSourcePrimary()
    {
        return DataSourceBuilder.create().build();
    }
 
    @Bean(name = "primarySqlSessionFactory")
    // 表示這個數(shù)據(jù)源是默認數(shù)據(jù)源
    @Primary
    // @Qualifier表示查找Spring容器中名字為test1DataSource的對象
    public SqlSessionFactory primarySqlSessionFactory(@Qualifier("primaryDataSource") DataSource datasource)
            throws Exception
    {
        SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
        bean.setDataSource(datasource);
        bean.setMapperLocations(
                // 設置mybatis的xml所在位置
                new PathMatchingResourcePatternResolver().getResources("classpath:mapper/primary/*.xml"));
        return bean.getObject();
    }
 
    @Bean("primarySqlSessionTemplate")
    // 表示這個數(shù)據(jù)源是默認數(shù)據(jù)源
    @Primary
    public SqlSessionTemplate primarySqlSessionTemplate(
            @Qualifier("primarySqlSessionFactory") SqlSessionFactory sessionFactory)
    {
        return new SqlSessionTemplate(sessionFactory);
    }
}

②次配置類：DataSourceConfigSecondary

@Configuration
@MapperScan(basePackages = "com.message.dao.secondary", sqlSessionFactoryRef = "secondarySqlSessionFactory")
public class DataSourceConfigSecondary {
    @Bean(name = "secondaryDataSource")
    @ConfigurationProperties(prefix = "spring.datasource.secondary")
    public DataSource getDateSource2()
    {
        return DataSourceBuilder.create().build();
    }
 
    @Bean(name = "secondarySqlSessionFactory")
    public SqlSessionFactory secondarySqlSessionFactory(@Qualifier("secondaryDataSource") DataSource datasource)
            throws Exception
    {
        SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
        bean.setDataSource(datasource);
        bean.setMapperLocations(
                new PathMatchingResourcePatternResolver().getResources("classpath:mapper/secondary/*.xml"));
        return bean.getObject();
    }
 
    @Bean("secondarySqlSessionTemplate")
    public SqlSessionTemplate secondarySqlSessionTemplate(
            @Qualifier("secondarySqlSessionFactory") SqlSessionFactory sessionFactory)
    {
        return new SqlSessionTemplate(sessionFactory);
    }
}

3.掃描XML

4.啟動類：

@SpringBootApplication(scanBasePackages = {"com.lalal.*"})
public class MessageApplication extends SpringBootServletInitializer { 
    public static void main(String[] args) {
        SpringApplication.run(MessageApplication.class, args);
    }
 
    @Bean
    public RestTemplate restTemplate(){
        return new RestTemplate();
    }
}

配置連接兩個或多個數(shù)據(jù)庫

背景：

項目中需要從兩個不同的數(shù)據(jù)庫查詢數(shù)據(jù)，之前實現(xiàn)方法是：springboot配置連接一個數(shù)據(jù)源，另一個使用jdbc代碼連接。

為了改進，現(xiàn)在使用SpringBoot配置連接兩個數(shù)據(jù)源

實現(xiàn)效果：

一個SpringBoot項目，同時連接兩個數(shù)據(jù)庫：比如一個是pgsql數(shù)據(jù)庫，一個是oracle數(shù)據(jù)庫

（啥數(shù)據(jù)庫都一樣，連接兩個同為oracle的數(shù)據(jù)庫，或兩個不同的數(shù)據(jù)庫，只需要更改對應的driver-class-name和jdbc-url等即可）

注意：連接什么數(shù)據(jù)庫，要引入對應數(shù)據(jù)庫的包

實現(xiàn)步驟：

1、修改application.yml，添加一個數(shù)據(jù)庫連接配置

（我這里是yml格式，后綴為properties格式是一樣的

server:
  port: 7101
spring:
  jpa:
    show-sql: true
  datasource:
    test1:
      driver-class-name: org.postgresql.Driver
      jdbc-url: jdbc:postgresql://127.0.0.1:5432/test  #測試數(shù)據(jù)庫
      username: root
      password: root
 
    test2:
      driver-class-name: oracle.jdbc.driver.OracleDriver
      jdbc-url: jdbc:oracle:thin:@127.0.0.1:8888:orcl  #測試數(shù)據(jù)庫
      username: root
      password: root

特別注意：

（1）使用test1、test2區(qū)分兩個數(shù)據(jù)庫連接

（2）url改為：jdbc-url

2、使用代碼進行數(shù)據(jù)源注入，和掃描dao層路徑（以前是在yml文件里配置mybatis掃描dao的路徑）

新建config包，包含數(shù)據(jù)庫1和數(shù)據(jù)庫2的配置文件

（1）第一個數(shù)據(jù)庫作為主數(shù)據(jù)庫，項目啟動默認連接此數(shù)據(jù)庫

DataSource1Config.java

package com.test.config; 
import org.apache.ibatis.session.SqlSessionFactory;
import org.mybatis.spring.SqlSessionFactoryBean;
import org.mybatis.spring.SqlSessionTemplate;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.boot.jdbc.DataSourceBuilder;
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;
 
@Configuration
@MapperScan(basePackages = "com.test.dao.test1", sqlSessionTemplateRef  = "test1SqlSessionTemplate")
public class DataSource1Config {
 
    @Bean(name = "test1DataSource")
    @ConfigurationProperties(prefix = "spring.datasource.test1")
    @Primary
    public DataSource testDataSource() {
        return DataSourceBuilder.create().build();
    }
 
    @Bean(name = "test1SqlSessionFactory")
    @Primary
    public SqlSessionFactory testSqlSessionFactory(@Qualifier("test1DataSource") DataSource dataSource) throws Exception {
        SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
        bean.setDataSource(dataSource);
        bean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:test1/*.xml"));
        return bean.getObject();
    }
 
    @Bean(name = "test1TransactionManager")
    @Primary
    public DataSourceTransactionManager testTransactionManager(@Qualifier("test1DataSource") DataSource dataSource) {
        return new DataSourceTransactionManager(dataSource);
    }
 
    @Bean(name = "test1SqlSessionTemplate")
    @Primary
    public SqlSessionTemplate testSqlSessionTemplate(@Qualifier("test1SqlSessionFactory") SqlSessionFactory sqlSessionFactory) throws Exception {
        return new SqlSessionTemplate(sqlSessionFactory);
    }
}

特別注意：

（1）主數(shù)據(jù)庫都有 @Primary注解，從數(shù)據(jù)庫都沒有

（2）第二個數(shù)據(jù)庫作為從數(shù)據(jù)庫

DataSource2Config.java

package com.test.config; 
import org.apache.ibatis.session.SqlSessionFactory;
import org.mybatis.spring.SqlSessionFactoryBean;
import org.mybatis.spring.SqlSessionTemplate;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.boot.jdbc.DataSourceBuilder;
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;
 
@Configuration
@MapperScan(basePackages = "com.test.dao.test2", sqlSessionTemplateRef  = "test2SqlSessionTemplate")
public class DataSource2Config {
 
    @Bean(name = "test2DataSource")
    @ConfigurationProperties(prefix = "spring.datasource.test2")
    public DataSource testDataSource() {
        return DataSourceBuilder.create().build();
    }
 
    @Bean(name = "test2SqlSessionFactory")
    public SqlSessionFactory testSqlSessionFactory(@Qualifier("test2DataSource") DataSource dataSource) throws Exception {
        SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
        bean.setDataSource(dataSource);
        bean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:test2/*.xml"));
        return bean.getObject();
    }
 
    @Bean(name = "test2TransactionManager")
    public DataSourceTransactionManager testTransactionManager(@Qualifier("test2DataSource") DataSource dataSource) {
        return new DataSourceTransactionManager(dataSource);
    }
 
    @Bean(name = "test2SqlSessionTemplate")
    public SqlSessionTemplate testSqlSessionTemplate(@Qualifier("test2SqlSessionFactory") SqlSessionFactory sqlSessionFactory) throws Exception {
        return new SqlSessionTemplate(sqlSessionFactory);
    }
}

3、在dao文件夾下，新建test1和test2兩個包，分別放兩個不同數(shù)據(jù)庫的dao層文件

（1）TestDao1.java

@Component
public interface TestDao1 { 
    List<DailyActivityDataMiddle> selectDailyActivity(); 
}

（2）TestDao2.java

@Component
public interface TestDao2 { 
    List<MovieShowTest> selectDailyActivity(); 
}

4、在resource下新建test1和test2兩個文件夾，分別放入對應dao層的xml文件

（我原來項目的dao的xml文件在resource目錄下，你們在自己的項目對應目錄下即可）

注意dao的java文件和dao的xml文件名字要一致

（1）TestDao1.xml

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper
        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> 
<mapper namespace="com.test.dao.test1.TestDao1"> 
    <select id="selectDailyActivity" resultType="com.test.pojo.DailyActivityDataMiddle"> 
        SELECT * FROM daily_activity_data_middle 
    </select> 
</mapper>

（2）TestDao2.xml

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper
        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> 
<mapper namespace="com.test.dao.test2.TestDao2"> 
    <select id="selectDailyActivity" resultType="com.test.pojo.MovieShowTest"> 
        SELECT * FROM movieshowtest 
    </select> 
</mapper>

5、測試

在controller文件里，注入兩個數(shù)據(jù)庫的dao，分別查詢數(shù)據(jù)

@RestController
public class TestController extends BaseController{ 
    @Autowired
    private PropertiesUtils propertiesUtils; 
    @Autowired
    private TestDao1 testDao1; 
    @Autowired
    private TestDao2 testDao2;
 
    @RequestMapping(value = {"/test/test1"},method = RequestMethod.POST)
    public Result<JSONObject> DataStatistics (@RequestBody JSONObject body) throws Exception {
        Result<JSONObject> result = new Result<>(ICommon.SUCCESS, propertiesUtils.get(ICommon.SUCCESS)); 
        JSONObject object = new JSONObject();
        object.put("data",testDao1.selectDailyActivity());
        result.setResult(object);
        return result;
    }
 
    @RequestMapping(value = {"/test/test2"},method = RequestMethod.POST)
    public Result<JSONObject> DataStatisticsaa (@RequestBody JSONObject body) throws Exception {
        Result<JSONObject> result = new Result<>(ICommon.SUCCESS, propertiesUtils.get(ICommon.SUCCESS)); 
        JSONObject object = new JSONObject();
        object.put("data",testDao2.selectDailyActivity());
        result.setResult(object);
        return result;
    }
}

以上為個人經(jīng)驗，希望能給大家一個參考，也希望大家多多支持腳本之家。

您可能感興趣的文章:

java -jar啟動項目以及日志輸出的相關問題
這篇文章主要介紹了java -jar啟動項目以及日志輸出的相關問題,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教
2024-04-04
仿釘釘流程輕松實現(xiàn)JSON轉BPMN完整實現(xiàn)過程示例
這篇文章主要為大家介紹了仿釘釘流程輕松實現(xiàn)JSON轉BPMN完整實現(xiàn)過程示例,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪
2023-08-08
Java通過apache poi生成excel實例代碼
本篇文章主要介紹了Java通過apache poi生成excel實例代碼，小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧
2017-06-06
Java IO中字節(jié)流復制圖片實現(xiàn)代碼
這篇文章主要介紹了Java IO中字節(jié)流復制圖片實現(xiàn)代碼的相關資料,需要的朋友可以參考下
2017-04-04
使用kotlin集成springboot開發(fā)的超詳細教程
目前大多數(shù)都在使用java集成 springboot進行開發(fā)，本文演示僅僅將 java換成 kotlin，其他不變的情況下進行開發(fā),需要的朋友可以參考下
2021-09-09
詳解非spring框架下使用querydsl的方法
Querydsl是一個采用API代替拼湊字符串來構造查詢語句，可跟 Hibernate 和 JPA 等框架結合使用。本文介紹的是非spring環(huán)境下querydsl JPA整合使用，感興趣的小伙伴們可以參考一下
2019-01-01
SpringBoot中使用異步調度程序的高級方法
本文主要介紹了SpringBoot中使用異步調度程序的高級方法,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧
2024-07-07
Java語言實現(xiàn)簡單FTP軟件輔助功能模塊FTP站點管理實現(xiàn)(12)
這篇文章主要為大家詳細介紹了Java語言實現(xiàn)簡單FTP軟，輔助功能模塊FTP站點管理的實現(xiàn)方法，具有一定的參考價值，感興趣的小伙伴們可以參考一下
2017-04-04
spring aop實現(xiàn)用戶權限管理的示例
本篇文章主要介紹了spring aop實現(xiàn)用戶權限管理的示例，小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧
2017-12-12
Spring注解配置實現(xiàn)過程詳解
這篇文章主要介紹了Spring注解配置實現(xiàn)過程詳解,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下
2020-08-08