springboot項(xiàng)目連接多種數(shù)據(jù)庫(kù)該如何操作詳析

更新時(shí)間：2024年08月01日 10:01:56 作者：不柔情

在Spring Boot應(yīng)用中連接多個(gè)數(shù)據(jù)庫(kù)或數(shù)據(jù)源可以使用多種方式,下面這篇文章主要給大家介紹了關(guān)于springboot項(xiàng)目連接多種數(shù)據(jù)庫(kù)該如何操作的相關(guān)資料,文中通過(guò)代碼介紹的非常詳細(xì),需要的朋友可以參考下

前言

在項(xiàng)目的開(kāi)發(fā)中，經(jīng)常會(huì)遇到需要連接多個(gè)多種數(shù)據(jù)庫(kù)的情況，mysql、oracle等等，下面詳細(xì)講解如何在一個(gè)服務(wù)中進(jìn)行多種數(shù)據(jù)庫(kù)的配置。

第一步：

在yml配置文件中配置多個(gè)數(shù)據(jù)源，如下，根據(jù)實(shí)際情況更改自己的配置即可。

spring:
  datasource:
    # 配置多個(gè)數(shù)據(jù)源
    primary:
      type: com.alibaba.druid.pool.DruidDataSource
      jdbc-url: jdbc:oracle:thin:@171.28.7.55:1521:example
      username: root
      password: root
      driver-class-name: oracle.jdbc.OracleDriver  #數(shù)據(jù)庫(kù)鏈接驅(qū)動(dòng)
    secondary:
      type: com.alibaba.druid.pool.DruidDataSource
      jdbc-url: jdbc:mysql://127.0.0.1:3306/exinfo?useUnicode=true&characterEncoding=utf-8
      username: root
      password: root
      driver-class-name: com.mysql.cj.jdbc.Driver  #數(shù)據(jù)庫(kù)鏈接驅(qū)動(dòng)

第二步：

創(chuàng)建多個(gè)配置類，以配置oracle和mysql兩個(gè)數(shù)據(jù)庫(kù)為例，可參考代碼進(jìn)行延展。

1.在配置類中需要進(jìn)行數(shù)據(jù)源配置

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

@ConfigurationProperties(prefix = "spring.datasource.primary")用于綁定yml中的第一個(gè)數(shù)據(jù)源配置，這些配置項(xiàng)會(huì)被自動(dòng)映射到db1DataSource所創(chuàng)建的數(shù)據(jù)源實(shí)例中。通過(guò)DataSourceBuilder. create()創(chuàng)建一個(gè)新的數(shù)據(jù)源構(gòu)建器，并調(diào)用.build()方法來(lái)完成數(shù)據(jù)源實(shí)例的創(chuàng)建。

如果有多個(gè)相同類型的Bean，使用@Primary注解可以標(biāo)記出一個(gè)優(yōu)先（默認(rèn)）使用的Bean。所以使用最多的數(shù)據(jù)庫(kù)可以使用@Primary注解。

2.配置MyBatis的SqlSessionFactory，它是MyBatis操作數(shù)據(jù)庫(kù)的核心組件，負(fù)責(zé)創(chuàng)建SqlSession對(duì)象，執(zhí)行SQL語(yǔ)句等。使用名稱為db1DataSource的數(shù)據(jù)源Bean作為構(gòu)造SqlSessionFactory的依賴。

    @Bean
    @Primary
    public SqlSessionFactory db1SqlSessionFactory(@Qualifier("db1DataSource") DataSource dataSource) throws Exception {
        SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
        bean.setDataSource(dataSource);
        //bean.getObject().getConfiguration().setMapUnderscoreToCamelCase(true);//設(shè)置下劃線轉(zhuǎn)駝峰式
        return bean.getObject();
    }

3.配置事務(wù)管理器（DataSourceTransactionManager），它基于數(shù)據(jù)源（DataSource）的事務(wù)管理實(shí)現(xiàn)，專門(mén)用于JDBC事務(wù)處理。注解明確指定使用名為db1DataSource的數(shù)據(jù)源Bean。

    @Bean
    @Primary
    public DataSourceTransactionManager db1TransactionManager(@Qualifier("db1DataSource") DataSource dataSource) {
        return new DataSourceTransactionManager(dataSource);
    }

4.配置SqlSessionTemplate實(shí)例，它是MyBatis與Spring集成的關(guān)鍵組件，提供了線程安全的SQL會(huì)話執(zhí)行環(huán)境。

    @Bean
    @Primary
    public SqlSessionTemplate db1SqlSessionTemplate(@Qualifier("db1SqlSessionFactory") SqlSessionFactory sqlSessionFactory){
        return new SqlSessionTemplate(sqlSessionFactory);
    }

5.類注解@MapperScan

basePackages= "com.example.mapper"：指定了Mapper接口所在的包路徑。Spring會(huì)掃描這個(gè)包及其子包下的所有接口，如果接口符合MyBatis Mapper的規(guī)范，Spring會(huì)自動(dòng)生成代理對(duì)象來(lái)處理SQL調(diào)用。

sqlSessionTemplateRef = "db1SqlSessionTemplate"：指定了與Mapper接口綁定的sqlSessionTemplate的名稱。在執(zhí)行Mapper接口的方法時(shí)，Spring會(huì)使用這個(gè)指定的sqlSessionTemplate來(lái)管理SQL會(huì)話。這里的db1SqlSessionTemplate是之前通過(guò)@Bean方法定義的sqlSessionTemplate Beam的名稱。

DataSourcePrimaryConfig完整代碼如下：

package com.example.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.jdbc.datasource.DataSourceTransactionManager;

import javax.sql.DataSource;

@Configuration
@MapperScan(basePackages = "com.example.mapper", sqlSessionTemplateRef = "db1SqlSessionTemplate")
public class DataSourcePrimaryConfig {

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

    @Bean
    @Primary
    public SqlSessionFactory db1SqlSessionFactory(@Qualifier("db1DataSource") DataSource dataSource) throws Exception {
        SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
        bean.setDataSource(dataSource);
        //bean.getObject().getConfiguration().setMapUnderscoreToCamelCase(true);//設(shè)置下劃線轉(zhuǎn)駝峰式
        return bean.getObject();
    }

    @Bean
    @Primary
    public DataSourceTransactionManager db1TransactionManager(@Qualifier("db1DataSource") DataSource dataSource) {
        return new DataSourceTransactionManager(dataSource);
    }

    @Bean
    @Primary
    public SqlSessionTemplate db1SqlSessionTemplate(@Qualifier("db1SqlSessionFactory") SqlSessionFactory sqlSessionFactory){
        return new SqlSessionTemplate(sqlSessionFactory);
    }
}

DataSourceSecondaryConfig代碼如下：

package com.example.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.jdbc.datasource.DataSourceTransactionManager;

import javax.sql.DataSource;

@Configuration
@MapperScan(basePackages = "com.example.mapper2", sqlSessionTemplateRef = "db2SqlSessionTemplate")
public class DataSourceSecondaryConfig {

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

    @Bean
    public SqlSessionFactory db2SqlSessionFactory(@Qualifier("db2DataSource") DataSource dataSource) throws Exception {
        SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
        bean.setDataSource(dataSource);
        bean.getObject().getConfiguration().setMapUnderscoreToCamelCase(true);//設(shè)置下劃線轉(zhuǎn)駝峰式
        return bean.getObject();
    }

    @Bean
    public DataSourceTransactionManager db2TransactionManager(@Qualifier("db2DataSource") DataSource dataSource) {
        return new DataSourceTransactionManager(dataSource);
    }

    @Bean
    public SqlSessionTemplate db2SqlSessionTemplate(@Qualifier("db2SqlSessionFactory") SqlSessionFactory sqlSessionFactory){
        return new SqlSessionTemplate(sqlSessionFactory);
    }
}

第三步：

根據(jù)配置文件，創(chuàng)建兩個(gè)mapper包如下：

在不同的mapper包下進(jìn)行不同數(shù)據(jù)庫(kù)的交互即可。

總結(jié)

到此這篇關(guān)于springboot項(xiàng)目連接多種數(shù)據(jù)庫(kù)該如何操作的文章就介紹到這了,更多相關(guān)springboot連接多種數(shù)據(jù)庫(kù)內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: