发帖
雷达卡
1、在项目中添加相关依赖，修改 pom.xml 文件以引入所需组件。
<!-- 动态数据源依赖 -->
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>dynamic-datasource-spring-boot-starter</artifactId>
<version>3.6.1</version>
</dependency>2、配置 application.yml 文件，设置多数据源的相关参数。
spring:
datasource:
dynamic:
primary: primary # 指定默认数据源
datasource:
# 第一个数据源（默认）
primary:
url: jdbc:mysql://127.0.0.1:22377/dade_py?useSSL=false&serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true&rewriteBatchedStatements=true
username: root
password: 123456
driver-class-name: com.mysql.cj.jdbc.Driver
hikari:
maximum-pool-size: 20
minimum-idle: 5
connection-timeout: 30000
idle-timeout: 600000
# 第二个数据源
second:
url: jdbc:mysql://【第二个数据库IP】:【端口】/【数据库名】?useSSL=false&serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true&rewriteBatchedStatements=true
username: 【第二个数据库用户名】
password: 【第二个数据库密码】
driver-class-name: com.mysql.cj.jdbc.Driver
hikari:
maximum-pool-size: 15
minimum-idle: 3
connection-timeout: 30000
idle-timeout: 6000003、通过注解方式实现数据源的切换。只需在 Service 类或具体方法上使用 @DS 注解，即可指定对应的数据源。
import com.baomidou.dynamic.datasource.annotation.DS;
import org.springframework.stereotype.Service;
@Service
public class TestService {
// 使用默认数据源（primary）
public void testPrimaryDb() {
// ... 操作默认数据库
}
// 切换到第二个数据源（second）
@DS("second")
public void testSecondDb() {
// ... 操作第二个数据库
}
}4、若希望整个 Service 类中的所有方法均使用同一数据源，可将 @DS 注解直接标注在类上。
@Service
@DS("second") // ???? 类上注解：该类所有方法默认使用 second 数据源
public class SecondDbService {
private final UserMapper userMapper;
public SecondDbService(UserMapper userMapper) {
this.userMapper = userMapper;
}
// 无需单独加注解，自动使用 second 数据源
public List<User> getUserList() {
return userMapper.selectList(null);
}
}5、当某个 Service 方法需要同时访问多个数据源时（例如从 primary 数据源查询数据，并插入到 second 数据源），仅使用 @DS 注解无法满足需求。此时需借助 DynamicDataSourceContextHolder 手动管理数据源上下文切换。
@Service
public class DataSyncService {
private final UserMapper userMapper;
private final OrderMapper orderMapper;
public DataSyncService(UserMapper userMapper, OrderMapper orderMapper) {
this.userMapper = userMapper;
this.orderMapper = orderMapper;
}
public void syncData() {
// 1. 用默认数据源（primary）查询数据
List<User> userList = userMapper.selectList(null);
// 2. 手动切换到 second 数据源（try-finally 确保切换后恢复）
DynamicDataSourceContextHolder.push("second");
try {
// 执行 SQL：使用 second 数据源
orderMapper.batchInsert(userList);
} finally {
// 3. 恢复默认数据源（必须执行，避免污染上下文）
DynamicDataSourceContextHolder.poll();
}
}
}6、关于 Mapper 接口的设计：每个 Mapper 应固定绑定一个数据源。若涉及两个数据库，则应分别创建两个独立的 Mapper 接口。
默认数据源对应的 Mapper 配置如下：
package com.dao;
import com.baomidou.dynamic.datasource.annotation.DS;
import org.apache.ibatis.annotations.*;
import java.util.List;
import java.util.Map;
/**
* 使用默认数据源
* */
@DS("primary")
@Mapper
public interface CommonMapper {
@Select("${sql}")
public List<Map<String,Object>> query(@Param("sql")String sql);
@Select("${sql}")
public String querycode(@Param("sql")String sql);
@Insert("${sql}")
public int insert(@Param("sql")String sql);
@Update("${sql}")
public Integer update(@Param("sql")String sql);
@Delete("${sql}")
public Boolean del(@Param("sql")String sql);
/**
* LAST_INSERT_ID()
* 客户端返回的值是该客户端产生对影响AUTO_INCREMENT列的最新语句第一个 AUTO_INCREMENT值的。这个值不能被其它客户端影响，即使它们产生它们自己的 AUTO_INCREMENT值。这个行为保证了你能够找回自己的 ID 而不用担心其它客户端的活动，而且不需要加锁或处理
* */
@Select("SELECT LAST_INSERT_ID()")
public int id();
/**
* 开启事务
* */
@Select("START TRANSACTION")
public Boolean TRANSACTION();
/**
* 提交事务
* */
@Select("COMMIT")
public Boolean COMMIT();
/**
* 回滚事务
* */
@Select("ROLLBACK")
public Boolean ROLLBACK();
}另一个数据源的 Mapper 配置示例如下：
package com.dao;
import com.baomidou.dynamic.datasource.annotation.DS;
import org.apache.ibatis.annotations.*;
import java.util.List;
import java.util.Map;
/**
* 使用second数据源
* */
@DS("second")
@Mapper
public interface CommonSecondMapper {
@Select("${sql}")
public List<Map<String,Object>> query(@Param("sql")String sql);
@Select("${sql}")
public String querycode(@Param("sql")String sql);
@Insert("${sql}")
public int insert(@Param("sql")String sql);
@Update("${sql}")
public Integer update(@Param("sql")String sql);
@Delete("${sql}")
public Boolean del(@Param("sql")String sql);
/**
* LAST_INSERT_ID()
* 客户端返回的值是该客户端产生对影响AUTO_INCREMENT列的最新语句第一个 AUTO_INCREMENT值的。这个值不能被其它客户端影响，即使它们产生它们自己的 AUTO_INCREMENT值。这个行为保证了你能够找回自己的 ID 而不用担心其它客户端的活动，而且不需要加锁或处理
* */
@Select("SELECT LAST_INSERT_ID()")
public int id();
/**
* 开启事务
* */
@Select("START TRANSACTION")
public Boolean TRANSACTION();
/**
* 提交事务
* */
@Select("COMMIT")
public Boolean COMMIT();
/**
* 回滚事务
* */
@Select("ROLLBACK")
public Boolean ROLLBACK();
}实际使用时的调用方式如下所示：
package com.service.impl;
import com.dao.CommonMapper;
import com.dao.CommonSecondMapper;
import com.service.AdminService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.List;
import java.util.Map;
@Service
public class AdminServiceImpl implements AdminService {
@Autowired
private CommonMapper commonMapper;
@Autowired
private CommonSecondMapper commonSecondMapper;
@Override
public List<Map<String,Object>> query(String table, Map<String, Object> params) {
List<Map<String,Object>> datas = commonMapper.query("select * from dade");
List<Map<String,Object>> user = commonSecondMapper.query("select * from users");
System.out.println(datas);
System.out.println(user);
return datas;
}
}
京公网安备 11010802022788号
