SpringBoot3.4.2基于MyBatis和MySQL8多数据源使用示例

itbeien2025年3月3日大约 7 分钟

SpringBoot3.4.2基于MyBatis和MySQL8多数据源使用示例

前一篇本专栏文章SpringBoot3.4.1基于MySQL8和Quartz实现定时任务管理。今天分享SpringBoot3.4.2基于MyBatis和MySQL8多数据源使用示例。我们在实际的项目开发过程中会同时连接多个数据库进行企业级应用系统功能的开发，基于此背景今天实现多数据源功能。

完整代码在文章最后，如果觉得本篇文章对你有用，记得点赞、关注、收藏哦。你的支持是我持续更新的动力!

文章最后可以加入免费的Java&AI技术和支付系统沟通社群，一起探讨Java/你的产品如何与AI结合，请按照要求加入。在群中可以聊开发、系统设计、架构、行业趋势、AI等等话题

SpringBoot3专栏软件环境

JDK17.0.12
SpringBoot3.4.2
MyBatis3.5.19
MySQL8.4.3
IDEA2024.3.3

我们先看本篇文章对应的项目结构，请看下图

1 项目搭建

1.1 pom依赖配置

<?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>
    <parent>
        <groupId>cn.itbeien</groupId>
        <artifactId>springboot3-labs-master</artifactId>
        <version>1.0-SNAPSHOT</version>
    </parent>

    <artifactId>springboot-mybatis-multi-datasource</artifactId>

    <properties>
        <mysql-connector-java-version>8.0.33</mysql-connector-java-version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.mybatis.spring.boot</groupId>
            <artifactId>mybatis-spring-boot-starter</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
        </dependency>
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>${mysql-connector-java-version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>

</project>

1.2 配置信息

mybatis.type-aliases-package=cn.itbeien.multi.entity

spring.datasource.testone.jdbc-url=jdbc:mysql://localhost:3306/test1?serverTimezone=UTC&useUnicode=true&characterEncoding=utf-8&useSSL=true
spring.datasource.testone.username=root
spring.datasource.testone.password=rootpwd20241215
spring.datasource.testone.driver-class-name=com.mysql.cj.jdbc.Driver

spring.datasource.testtwo.jdbc-url=jdbc:mysql://localhost:3306/test2?serverTimezone=UTC&useUnicode=true&characterEncoding=utf-8&useSSL=true
spring.datasource.testtwo.username=root
spring.datasource.testtwo.password=rootpwd20241215
spring.datasource.testtwo.driver-class-name=com.mysql.cj.jdbc.Driver

1.3 代码实现

1.3.1 多数据源配置

package cn.itbeien.multi.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;

/**
 * @author itbeien
 * 项目网站：https://www.itbeien.cn
 * 公众号：贝恩聊架构
 * 全网同名，欢迎小伙伴们关注
 * Java/AI学习社群
 * Copyright© 2025 itbeien
 */
@Configuration
@MapperScan(basePackages = "cn.itbeien.multi.mapper.testone", sqlSessionTemplateRef  = "testOneSqlSessionTemplate")
public class DataSourceOneConfig {

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

    @Bean(name = "testOneSqlSessionFactory")
    @Primary
    public SqlSessionFactory testSqlSessionFactory(@Qualifier("testOneDataSource") DataSource dataSource) throws Exception {
        SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
        bean.setDataSource(dataSource);
        return bean.getObject();
    }

    @Bean(name = "testOneTransactionManager")
    @Primary
    public DataSourceTransactionManager testTransactionManager(@Qualifier("testOneDataSource") DataSource dataSource) {
        return new DataSourceTransactionManager(dataSource);
    }

    @Bean(name = "testOneSqlSessionTemplate")
    @Primary
    public SqlSessionTemplate testSqlSessionTemplate(@Qualifier("testOneSqlSessionFactory") SqlSessionFactory sqlSessionFactory) throws Exception {
        return new SqlSessionTemplate(sqlSessionFactory);
    }

}

1.3.2 数据持久层

package cn.itbeien.multi.mapper.testone;


import cn.itbeien.multi.entity.SysUser;
import org.apache.ibatis.annotations.*;

import java.util.List;

/**
 * @author itbeien
 * 项目网站：https://www.itbeien.cn
 * 公众号：贝恩聊架构
 * 全网同名，欢迎小伙伴们关注
 * Java/AI学习社群
 * Copyright© 2025 itbeien
 */
public interface UserOneMapper {


	@Select("SELECT * FROM sys_user")
	@Results({
			@Result(property = "userSex",  column = "user_sex"),
			@Result(property = "nickName", column = "nick_name")
	})
	List<SysUser> getAll();

	@Select("SELECT * FROM sys_user WHERE id = #{id}")
	@Results({
			@Result(property = "userSex",  column = "user_sex"),
			@Result(property = "nickName", column = "nick_name"),
			@Result(property = "userName", column = "user_name")
	})
	SysUser getOne(Long id);

	@Insert("INSERT INTO sys_user(user_name,password,user_sex) VALUES(#{userName}, #{password}, #{userSex})")
	void insert(SysUser user);

	@Update("UPDATE sys_user SET user_name=#{userName},nick_name=#{nickName} WHERE id =#{id}")
	void update(SysUser user);

	@Delete("DELETE FROM sys_user WHERE id =#{id}")
	void delete(Long id);

}

1.3.3 单元测试

package cn.itbeien.multi;

import cn.itbeien.multi.entity.SysUser;
import cn.itbeien.multi.mapper.testone.UserOneMapper;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;

import java.util.List;

/**
 * @author itbeien
 * 项目网站：https://www.itbeien.cn
 * 公众号：贝恩聊架构
 * 全网同名，欢迎小伙伴们关注
 * Java/AI学习社群
 * Copyright© 2025 itbeien
 */
@SpringBootTest
public class MultiBootTest {

    @Autowired
    private UserOneMapper userMapper;

    @Test
    public void testInsert() throws Exception {
        userMapper.insert(new SysUser("itbeien", "123", "0"));
        userMapper.insert(new SysUser("itdatong", "12", "1"));
        userMapper.insert(new SysUser("abc", "123", "1"));

    }

    @Test
    public void testQuery() throws Exception {
        List<SysUser> users = userMapper.getAll();
        if(users==null || users.isEmpty()){
            System.out.println("is null");
        }else{
            System.out.println(users.size());
        }
    }


    @Test
    public void testUpdate() throws Exception {
        SysUser user = userMapper.getOne(1000l);
        System.out.println(user.toString());
        user.setNickName("itbeien");
        userMapper.update(user);
	}
}