快捷導(dǎo)航

springboot連接多個(gè)數(shù)據(jù)庫(kù)的實(shí)現(xiàn)方法

更新時(shí)間：2024年08月18日 11:53:01 作者：愛寫B(tài)ug的小孫

有時(shí)候一個(gè)SpringBoot項(xiàng)目需要同時(shí)連接兩個(gè)數(shù)據(jù)庫(kù),本文就來介紹一下springboot連接多個(gè)數(shù)據(jù)庫(kù)的實(shí)現(xiàn)方法,具有一定的參考價(jià)值,感興趣的可以了解一下

一個(gè)SpringBoot項(xiàng)目，同時(shí)連接兩個(gè)數(shù)據(jù)庫(kù)：比如一個(gè)是Mysql數(shù)據(jù)庫(kù)，一個(gè)是oracle數(shù)據(jù)庫(kù)（啥數(shù)據(jù)庫(kù)都一樣，連接兩個(gè)同為oracle的數(shù)據(jù)庫(kù)，或兩個(gè)不同的數(shù)據(jù)庫(kù)，只需要更改對(duì)應(yīng)的driver-class-name和jdbc-url等即可）注意：連接什么數(shù)據(jù)庫(kù)，要引入對(duì)應(yīng)數(shù)據(jù)庫(kù)的包。

第一步：

導(dǎo)入pom

<dependency>
    <groupId>com.alibaba</groupId>
    <artifactId>druid</artifactId>
    <version>1.1.0</version>
</dependency>
 
<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <scope>runtime</scope>
</dependency>

第二步：

修改application.yml配置文件（我采用本地的，IP地址是一致的，實(shí)際開發(fā)中，是兩臺(tái)云服務(wù)，兩臺(tái)MySQL地址進(jìn)行主從讀寫）

    mysql1:
      driver-class-name: com.mysql.cj.jdbc.Driver
      jdbcUrl: jdbc:mysql://localhost:3306/test?useSSL=false&useUnicode=true&characterEncoding=UTF-8&serverTimezone=GMT%2B8
      username: "root"
      password: "12345678"
      type: com.alibaba.druid.pool.DruidDataSource
    mysql2:
      driver-class-name: com.mysql.cj.jdbc.Driver
      jdbcUrl: jdbc:mysql://localhost:3306/test1?useSSL=false&useUnicode=true&characterEncoding=UTF-8&serverTimezone=GMT%2B8
      username: "root"
      password: "12345678"
      type: com.alibaba.druid.pool.DruidDataSource

在這里插入圖片描述

注意格式上面spring.datasource省略了

第三步：

建造配置類：
（1）第一個(gè)庫(kù)配置信息：

/**
 * 數(shù)據(jù)庫(kù)leadnews_article
 */
@Configuration
@MapperScan(basePackages = {"com.example.demo.mapper.db1"}, sqlSessionFactoryRef = "sqlSessionFactoryArticle")
public class DBSrcArticle {
    @Bean
    public SqlSessionFactory sqlSessionFactoryArticle(@Qualifier("mysql1") DataSource dataSource) throws Exception {
        MybatisSqlSessionFactoryBean sqlSessionFactory = new MybatisSqlSessionFactoryBean();
        sqlSessionFactory.setDataSource(dataSource);
        sqlSessionFactory.setMapperLocations(new PathMatchingResourcePatternResolver()
                .getResources("classpath:mapper/db1/*.xml"));
        return sqlSessionFactory.getObject();
    }

    @Bean
    public SqlSessionTemplate sqlSessionTemplateArticle(@Qualifier("sqlSessionFactoryArticle") SqlSessionFactory sqlSessionFactory) throws Exception {
        return new SqlSessionTemplate(sqlSessionFactory);
    }
}

（2）第二個(gè)庫(kù)配置

/**
 * 數(shù)據(jù)庫(kù)leadnews_user
 */
@Configuration
@MapperScan(basePackages = {"com.example.demo.mapper.db2"}, sqlSessionFactoryRef = "sqlSessionFactoryUser")
public class dBSrcUser {
    @Bean
    @Primary
    public SqlSessionFactory sqlSessionFactoryUser(@Qualifier("mysql2") DataSource dataSource) throws Exception {
        MybatisSqlSessionFactoryBean sqlSessionFactory = new MybatisSqlSessionFactoryBean();
        sqlSessionFactory.setDataSource(dataSource);
        sqlSessionFactory.setMapperLocations(new PathMatchingResourcePatternResolver()
                .getResources("classpath:mapper/db2/*.xml"));
        return sqlSessionFactory.getObject();
    }

    @Bean
    @Primary
    public SqlSessionTemplate sqlSessionTemplateUser(@Qualifier("sqlSessionFactoryUser") SqlSessionFactory sqlSessionFactory) throws Exception {
        return new SqlSessionTemplate(sqlSessionFactory);
    }
}

（3）數(shù)據(jù)源配置：

/**
 * 數(shù)據(jù)源配置
 */
@Configuration
public class DataSourceConfig {
    @Primary
    @Bean(name = "mysql1")
    @ConfigurationProperties(prefix = "spring.datasource.mysql1")
    public DataSource dBSrcArticle() {
        return DataSourceBuilder.create().build();
    }

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

注意：連接兩個(gè)以上的數(shù)據(jù)庫(kù)，需要對(duì)mapper文件夾進(jìn)行分包！

在這里插入圖片描述

第四步：

在啟動(dòng)類中加上這三個(gè)注解：

@SpringBootApplication(exclude = {DataSourceAutoConfiguration.class})
@MapperScan(basePackages = {"com.example.demo.entity.db1"}, sqlSessionFactoryRef = "sqlSessionFactoryArticle")
@MapperScan(basePackages = {"com.example.demo.entity.db2"}, sqlSessionFactoryRef = "sqlSessionFactoryUser")

此時(shí)：已經(jīng)可以訪問兩個(gè)數(shù)據(jù)庫(kù)內(nèi)容了。

到此這篇關(guān)于springboot連接多個(gè)庫(kù)的實(shí)現(xiàn)方法的文章就介紹到這了,更多相關(guān)springboot連接多個(gè)庫(kù)內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: