欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

SpringBoot搭建多數(shù)據(jù)源的實(shí)現(xiàn)方法

 更新時(shí)間：2021年12月06日 15:06:27   作者：XiaoHH Superme  
說起多數(shù)據(jù)源,一般都來解決那些問題呢,主從模式或者業(yè)務(wù)比較復(fù)雜需要連接不同的分庫來支持業(yè)務(wù)。本文主要介紹了SpringBoot搭建多數(shù)據(jù)源的實(shí)現(xiàn)方法，感興趣的可以了解一下，感興趣的可以額了解一下

首先我們建立兩個(gè)數(shù)據(jù)庫（可以不在同一臺電腦上）:

multiple_order：

DROP DATABASE IF EXISTS `multiple_order`;
CREATE DATABASE `multiple_order`;
USE `multiple_order`;

CREATE TABLE `order` (
    `order_id` BIGINT UNSIGNED PRIMARY KEY AUTO_INCREMENT COMMENT '訂單id',
    `user_id` BIGINT UNSIGNED NOT NULL COMMENT '用戶id',
    `cost` DECIMAL(13, 2) COMMENT '訂單費(fèi)用'
) COMMENT '訂單表';

multiple_user：

DROP DATABASE IF EXISTS `multiple_user`;
CREATE DATABASE `multiple_user`;
USE `multiple_user`;

CREATE TABLE `user` (
    `user_id` BIGINT UNSIGNED PRIMARY KEY AUTO_INCREMENT COMMENT '用戶id',
    `username` VARCHAR(50) NOT NULL COMMENT '用戶名',
    `age` TINYINT UNSIGNED COMMENT '年齡'
) COMMENT '用戶表';

然后創(chuàng)建一個(gè)maven項(xiàng)目，其中 pom.xml 文件：

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <!-- SpringBoot的夫項(xiàng)目 -->
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.3.9.RELEASE</version>
    </parent>

    <groupId>love.xiaohh.datasource</groupId>
    <artifactId>multiple-datasources</artifactId>
    <version>1.0-SNAPSHOT</version>

    <properties>
        <maven.compiler.source>8</maven.compiler.source>
        <maven.compiler.target>8</maven.compiler.target>
    </properties>

    <dependencies>
        <!-- SpringMVC 相關(guān)的依賴 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <!-- Spring 健康檢測模塊 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>

        <!-- mybatis 相關(guān)依賴 -->
        <dependency>
            <groupId>org.mybatis.spring.boot</groupId>
            <artifactId>mybatis-spring-boot-starter</artifactId>
            <version>2.2.0</version>
        </dependency>

        <!-- MySQL 驅(qū)動(dòng) -->
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
        </dependency>

        <!-- json 工具類 -->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>fastjson</artifactId>
            <version>1.2.78</version>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <!-- 制作一個(gè)可運(yùn)行的 jar 包需要的插件 -->
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

在 application.yml 中需要配置兩個(gè)數(shù)據(jù)源：

spring:
  datasource:
    # 用戶模塊數(shù)據(jù)庫配置
    user:
      driver-class-name: com.mysql.cj.jdbc.Driver
      jdbc-url: jdbc:mysql://127.0.0.1:3306/multiple_user?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
      username: root
      password: xiaohh
    # 訂單模塊數(shù)據(jù)庫配置
    order:
      driver-class-name: com.mysql.cj.jdbc.Driver
      jdbc-url: jdbc:mysql://127.0.0.1:3306/multiple_order?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
      username: root
      password: xiaohh

mybatis:
  # Mapper 的目錄
  mapper-locations: classpath:mapper/**/*Mapper.xml

然后我們定義一個(gè)配置類 DataSourseConfig 用于配置多數(shù)據(jù)源，首先是申明數(shù)據(jù)源，按照 application.yml 當(dāng)中的配置定義兩個(gè)數(shù)據(jù)源，注意當(dāng)中的DataSource 是 javax.sql.DataSource：

/**
 * 配置用戶的數(shù)據(jù)源
 *
 * @return 用戶的數(shù)據(jù)源對象
 */
@Primary // 需要一個(gè)默認(rèn)配置的數(shù)據(jù)源
@Bean("user")
@ConfigurationProperties(prefix = "spring.datasource.user") // 在yml中配置數(shù)據(jù)源的前綴
public DataSource user() {
    return DataSourceBuilder.create().build();
}

/**
 * 配置訂單的數(shù)據(jù)源
 *
 * @return 訂單的數(shù)據(jù)源對象
 */
@Bean("order")
@ConfigurationProperties(prefix = "spring.datasource.order") // 在yml中配置數(shù)據(jù)源的前綴
public DataSource order() {
    return DataSourceBuilder.create().build();
}

然后創(chuàng)建 SqlSessionFactory ：

/**
 * 注冊用戶的 SqlSession 工廠
 *
 * @param user 數(shù)據(jù)源
 * @return SqlSession 工廠
 * @throws Exception 可能會(huì)拋出異常
 */
@Primary // 配置一個(gè)這個(gè)類型默認(rèn)的 bean
@Bean("userSqlSessionFactory")
public SqlSessionFactory userSqlSessionFactory(@Qualifier("user") DataSource user) throws Exception {
    // 創(chuàng)建bean
    SqlSessionFactoryBean factory = new SqlSessionFactoryBean();
    // 設(shè)置數(shù)據(jù)源
    factory.setDataSource(user);
    // 設(shè)置 mapper 文件的掃描
    factory.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:mapper/user/*.xml"));
    return factory.getObject();
}

/**
 * 注冊訂單的 SqlSession 工廠
 *
 * @param order 數(shù)據(jù)源
 * @return SqlSession 工廠
 * @throws Exception 可能會(huì)拋出異常
 */
@Bean("orderSqlSessionFactory")
public SqlSessionFactory orderSqlSessionFactory(@Qualifier("order") DataSource order) throws Exception {
    // 創(chuàng)建bean
    SqlSessionFactoryBean factory = new SqlSessionFactoryBean();
    // 設(shè)置數(shù)據(jù)源
    factory.setDataSource(order);
    // 設(shè)置 mapper 文件的掃描
    factory.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:mapper/order/*.xml"));
    return factory.getObject();
}

最后聲明兩個(gè) SqlSessionTemplate ：

/**
 * 用戶的 SqlSessionTemplate
 *
 * @param userSqlSessionFactory 用戶的 SqlSession 工廠
 * @return 用戶的 SqlSessionTemplate
 */
@Primary // 設(shè)置這個(gè)類型默認(rèn)的 bean
@Bean("userSqlSessionTemplate")
public SqlSessionTemplate userSqlSessionTemplate(@Qualifier("userSqlSessionFactory") SqlSessionFactory userSqlSessionFactory) {
    return new SqlSessionTemplate(userSqlSessionFactory);
}

/**
 * 訂單的 SqlSessionTemplate
 *
 * @param orderSqlSessionFactory 訂單的 SqlSession 工廠
 * @return 用戶的 SqlSessionTemplate
 */
@Bean("orderSqlSessionTemplate")
public SqlSessionTemplate orderSqlSessionTemplate(@Qualifier("orderSqlSessionFactory") SqlSessionFactory orderSqlSessionFactory) {
    return new SqlSessionTemplate(orderSqlSessionFactory);
}

最后別忘了在配置類上加上一個(gè)注解，用于聲明哪些Mapper文件用哪些注解：

@Configuration
@MapperScans({
        // basePackages 是mapper的包路徑，sqlSessionTemplateRef 是指定我們創(chuàng)建的 SqlSessionTemplate
        @MapperScan(basePackages = "love.xiaohh.datasource.mapper.user", sqlSessionTemplateRef = "userSqlSessionTemplate"),
        @MapperScan(basePackages = "love.xiaohh.datasource.mapper.order", sqlSessionTemplateRef = "orderSqlSessionTemplate")
})

完整的 DataSourceConfig 類的代碼：

package love.xiaohh.datasource.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.mybatis.spring.annotation.MapperScans;
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 javax.sql.DataSource;

/**
 * <p>
 * 多數(shù)據(jù)源的配置類
 * </p>
 *
 * @author XiaoHH
 * @version 1.0
 * @date 2021-12-03 星期五 11:15:06
 * @file DataSourceConfig.java
 */
@Configuration
@MapperScans({
        // basePackages 是mapper的包路徑，sqlSessionTemplateRef 是指定我們創(chuàng)建的 SqlSessionTemplate
        @MapperScan(basePackages = "love.xiaohh.datasource.mapper.user", sqlSessionTemplateRef = "userSqlSessionTemplate"),
        @MapperScan(basePackages = "love.xiaohh.datasource.mapper.order", sqlSessionTemplateRef = "orderSqlSessionTemplate")
})
public class DataSourceConfig {

    /**
     * 配置用戶的數(shù)據(jù)源
     *
     * @return 用戶的數(shù)據(jù)源對象
     */
    @Primary // 需要一個(gè)默認(rèn)配置的數(shù)據(jù)源
    @Bean("user")
    @ConfigurationProperties(prefix = "spring.datasource.user") // 在yml中配置數(shù)據(jù)源的前綴
    public DataSource user() {
        return DataSourceBuilder.create().build();
    }

    /**
     * 配置訂單的數(shù)據(jù)源
     *
     * @return 訂單的數(shù)據(jù)源對象
     */
    @Bean("order")
    @ConfigurationProperties(prefix = "spring.datasource.order") // 在yml中配置數(shù)據(jù)源的前綴
    public DataSource order() {
        return DataSourceBuilder.create().build();
    }

    /**
     * 注冊用戶的 SqlSession 工廠
     *
     * @param user 數(shù)據(jù)源
     * @return SqlSession 工廠
     * @throws Exception 可能會(huì)拋出異常
     */
    @Primary // 配置一個(gè)這個(gè)類型默認(rèn)的 bean
    @Bean("userSqlSessionFactory")
    public SqlSessionFactory userSqlSessionFactory(@Qualifier("user") DataSource user) throws Exception {
        // 創(chuàng)建bean
        SqlSessionFactoryBean factory = new SqlSessionFactoryBean();
        // 設(shè)置數(shù)據(jù)源
        factory.setDataSource(user);
        // 設(shè)置 mapper 文件的掃描
        factory.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:mapper/user/*.xml"));
        return factory.getObject();
    }

    /**
     * 注冊訂單的 SqlSession 工廠
     *
     * @param order 數(shù)據(jù)源
     * @return SqlSession 工廠
     * @throws Exception 可能會(huì)拋出異常
     */
    @Bean("orderSqlSessionFactory")
    public SqlSessionFactory orderSqlSessionFactory(@Qualifier("order") DataSource order) throws Exception {
        // 創(chuàng)建bean
        SqlSessionFactoryBean factory = new SqlSessionFactoryBean();
        // 設(shè)置數(shù)據(jù)源
        factory.setDataSource(order);
        // 設(shè)置 mapper 文件的掃描
        factory.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:mapper/order/*.xml"));
        return factory.getObject();
    }

    /**
     * 用戶的 SqlSessionTemplate
     *
     * @param userSqlSessionFactory 用戶的 SqlSession 工廠
     * @return 用戶的 SqlSessionTemplate
     */
    @Primary // 設(shè)置這個(gè)類型默認(rèn)的 bean
    @Bean("userSqlSessionTemplate")
    public SqlSessionTemplate userSqlSessionTemplate(@Qualifier("userSqlSessionFactory") SqlSessionFactory userSqlSessionFactory) {
        return new SqlSessionTemplate(userSqlSessionFactory);
    }

    /**
     * 訂單的 SqlSessionTemplate
     *
     * @param orderSqlSessionFactory 訂單的 SqlSession 工廠
     * @return 用戶的 SqlSessionTemplate
     */
    @Bean("orderSqlSessionTemplate")
    public SqlSessionTemplate orderSqlSessionTemplate(@Qualifier("orderSqlSessionFactory") SqlSessionFactory orderSqlSessionFactory) {
        return new SqlSessionTemplate(orderSqlSessionFactory);
    }
}

然后按照注解上面定義的包創(chuàng)建兩個(gè) Mapper 接口

OrderMapper：

package love.xiaohh.datasource.mapper.order;

import love.xiaohh.datasource.entities.order.Order;
import org.apache.ibatis.annotations.Mapper;

import java.util.List;

/**
 * <p>
 * 訂單的數(shù)據(jù)庫訪問接口
 * </p>
 *
 * @author tanghai
 * @version 1.0
 * @date 2021-12-03 星期五 14:08:19
 * @file OrderMapper.java
 */
@Mapper
public interface OrderMapper {

    /**
     * 新增一個(gè)訂單實(shí)體
     *
     * @param order 訂單實(shí)體
     * @return 受影響行數(shù)
     */
    int insertOrder(Order order);

    /**
     * 查詢一個(gè)訂單列表
     *
     * @param order 查詢參數(shù)
     * @return 符合條件的訂單列表
     */
    List<Order> selectOrder(Order order);
}

UserMapper：

package love.xiaohh.datasource.mapper.user;

import love.xiaohh.datasource.entities.user.User;
import org.apache.ibatis.annotations.Mapper;

import java.util.List;

/**
 * <p>
 * 用戶的數(shù)據(jù)庫訪問接口
 * </p>
 *
 * @author tanghai
 * @version 1.0
 * @date 2021-12-03 星期五 14:11:55
 * @file UserMapper.java
 */
@Mapper
public interface UserMapper {

    /**
     * 新增一個(gè)用戶
     *
     * @param user 用戶對象
     * @return 受影響行數(shù)
     */
    int insertUser(User user);

    /**
     * 查詢用戶列表
     *
     * @param user 查詢參數(shù)
     * @return 符合條件的用戶列表
     */
    List<User> selectUser(User user);
}

之后我會(huì)將代碼提交到 gitee，所以 Mapper.xml、Controller、Service 代碼在此處省略，然后我們新增幾條用戶數(shù)據(jù)：

在這里插入圖片描述

查詢一下：

在這里插入圖片描述

同時(shí)訂單數(shù)據(jù)庫：
在這里插入圖片描述

查詢：

在這里插入圖片描述

然后在數(shù)據(jù)庫當(dāng)中查看是否是發(fā)送到不同的數(shù)據(jù)庫：

在這里插入圖片描述

可以確定，確實(shí)是存入了兩個(gè)數(shù)據(jù)庫。好了下課
代碼倉庫：https://gitee.com/xiaohha/multiple-datasources

到此這篇關(guān)于SpringBoot搭建多數(shù)據(jù)源的實(shí)現(xiàn)方法的文章就介紹到這了,更多相關(guān)SpringBoot搭建多數(shù)據(jù)源內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

相關(guān)文章

  • Java棧的應(yīng)用之括號匹配算法實(shí)例分析

    Java棧的應(yīng)用之括號匹配算法實(shí)例分析

    這篇文章主要介紹了Java棧的應(yīng)用之括號匹配算法,結(jié)合實(shí)例形式分析了Java使用棧實(shí)現(xiàn)括號匹配算法的相關(guān)原理、操作技巧與注意事項(xiàng),需要的朋友可以參考下
    2020-03-03
  • Mybatis-plus的service通用接口解讀

    Mybatis-plus的service通用接口解讀

    這篇文章主要介紹了Mybatis-plus的service通用接口解讀，具有很好的參考價(jià)值，希望對大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教
    2023-07-07
  • Sping中如何處理@Bean注解bean同名的問題

    Sping中如何處理@Bean注解bean同名的問題

    這篇文章主要介紹了Sping中如何處理@Bean注解bean同名的問題，具有很好的參考價(jià)值，希望對大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教
    2023-06-06
  • Java排序算法總結(jié)之希爾排序

    Java排序算法總結(jié)之希爾排序

    這篇文章主要介紹了Java排序算法總結(jié)之希爾排序,較為詳細(xì)的分析了希爾排序的原理與java的實(shí)現(xiàn)技巧,需要的朋友可以參考下
    2015-05-05
  • 如何替換@PathVariable中的變量

    如何替換@PathVariable中的變量

    這篇文章主要介紹了如何替換@PathVariable中的變量，具有很好的參考價(jià)值，希望對大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教
    2021-10-10
  • java將excel轉(zhuǎn)為pdf的方法步驟

    java將excel轉(zhuǎn)為pdf的方法步驟

    之前工作需要,查了挺多種Excel轉(zhuǎn)PDF的方法,下面這篇文章主要給大家介紹了關(guān)于java將excel轉(zhuǎn)為pdf的相關(guān)資料,文中通過代碼介紹的非常詳細(xì),需要的朋友可以參考下
    2024-01-01
  • SpringBoot 創(chuàng)建web項(xiàng)目并部署到外部Tomcat

    SpringBoot 創(chuàng)建web項(xiàng)目并部署到外部Tomcat

    本篇文章主要介紹了SpringBoot 創(chuàng)建web項(xiàng)目并部署到外部Tomcat，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下
    2017-06-06
  • Linux+Docker+SpringBoot+IDEA一鍵自動(dòng)化部署的詳細(xì)步驟

    Linux+Docker+SpringBoot+IDEA一鍵自動(dòng)化部署的詳細(xì)步驟

    這篇文章主要介紹了Linux+Docker+SpringBoot+IDEA一鍵自動(dòng)化部署的詳細(xì)步驟，本文給大家介紹的非常詳細(xì)，對大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下
    2020-07-07
  • java使用gzip實(shí)現(xiàn)文件解壓縮示例

    java使用gzip實(shí)現(xiàn)文件解壓縮示例

    這篇文章主要介紹了java使用gzip實(shí)現(xiàn)文件解壓縮示例,需要的朋友可以參考下
    2014-03-03
  • java實(shí)現(xiàn)即時(shí)通信的完整步驟分享

    java實(shí)現(xiàn)即時(shí)通信的完整步驟分享

    這篇文章主要給大家介紹了關(guān)于java實(shí)現(xiàn)即時(shí)通信的完整步驟，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
    2020-09-09

最新評論