当前位置：首页 > news >正文

Hutool DsFactory多数据源切换

news 2025/9/4 5:14:38

一、简单上手：从配置到使用全流程

DsFactory 的核心优势是零侵入配置，支持多种配置方式，不管是 properties 文件还是代码里直接定义，都能快速初始化数据源。先引依赖（Maven）：

<dependency><groupId>cn.hutool</groupId><artifactId>hutool-db</artifactId><version>5.8.20</version>
</dependency>
<!-- 数据库驱动根据需要添加，比如MySQL -->
<dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>8.0.33</version>
</dependency>

配置文件方式：最推荐的做法在resources目录下创建db.setting文件，配置数据源信息：

在resources目录下创建db.setting文件，配置数据源信息：

# 默认数据源（必填）
[default]
url = jdbc:mysql://localhost:3306/db1
username = root
password=123456
driver = com.mysql.cj.jdbc.Driver# 第二个数据源（名称自定义）
[second]
url = jdbc:mysql://localhost:3306/db2
username = root
password=123456
driver = com.mysql.cj.jdbc.Driver# 连接池配置（可选，全局生效）
[pool]
maxActive = 50
maxIdle = 10
minIdle = 5
initialSize = 5

然后一行代码获取数据源：

// 获取默认数据源
DataSource defaultDs = DsFactory.get();// 获取指定名称的数据源
DataSource secondDs = DsFactory.get("second");

代码配置方式：动态添加数据源

不需要配置文件时，直接在代码里定义：

// 创建数据源配置
DbConfig defaultConfig = new DbConfig();
defaultConfig.setUrl("jdbc:mysql://localhost:3306/db1");
defaultConfig.setUsername("root");
defaultConfig.setPassword("123456");// 添加到DsFactory
DsFactory.register("default", defaultConfig);// 再添加一个数据源
DbConfig otherConfig = new DbConfig();
otherConfig.setUrl("jdbc:mysql://localhost:3306/db3");
otherConfig.setUsername("root");
otherConfig.setPassword("123456");
DsFactory.register("other", otherConfig);// 使用时直接获取
DataSource defaultDs = DsFactory.get("default");
DataSource otherDs = DsFactory.get("other");

支持的数据库类型：不止关系型数据库

除了 MySQL、Oracle 这些关系型数据库，还支持 SQLite、H2 等嵌入式数据库：

# SQLite数据源配置
[sqlite]
url = jdbc:sqlite:test.db
driver = org.sqlite.JDBC
# SQLite不需要用户名密码

甚至可以配置 Redis（虽然 Redis 不是数据库，但 DsFactory 也能管理）：

[redis]
type = redis
host = localhost
port = 6379
password =

二、核心功能：数据源管理就该这么简单

切换数据源：一行代码搞定

需要操作不同数据库时，直接通过名称获取即可：

// 操作默认数据库
Db.use(DsFactory.get()).query("select * from user");// 切换到second数据源
Db.use(DsFactory.get("second")).execute("insert into log values(...)");

在业务代码中切换更是方便：

public class UserService {public List<User> getUsersFromDb1() {// 使用默认数据源return Db.use(DsFactory.get()).query(Entity.create("user"), User.class);}public List<User> getUsersFromDb2() {// 切换到第二个数据源return Db.use(DsFactory.get("second")).query(Entity.create("user"), User.class);}
}

连接池配置：全局统一管理

在db.setting的[pool]节点配置连接池参数，所有数据源都会生效：

[pool]
maxActive = 100  # 最大活跃连接数
maxIdle = 20     # 最大空闲连接数
minIdle = 5      # 最小空闲连接数
initialSize = 10 # 初始连接数
maxWait = 3000   # 获取连接的最大等待时间（毫秒）

如果某个数据源需要特殊配置，可以单独指定：

# 单独给second数据源配置连接池
[second]
url = jdbc:mysql://localhost:3306/db2
username = root
password = 123456
driver = com.mysql.cj.jdbc.Driver
maxActive = 80  # 覆盖全局配置
maxIdle = 15

动态增减数据源：运行时也能改

支持在程序运行中添加或移除数据源，适合动态切换场景：

// 动态添加一个临时数据源
DbConfig tempConfig = new DbConfig();
tempConfig.setUrl("jdbc:mysql://localhost:3306/temp_db");
tempConfig.setUsername("root");
tempConfig.setPassword("123456");
DsFactory.register("temp", tempConfig);// 使用临时数据源
Db.use(DsFactory.get("temp")).execute("create table temp_table(id int)");// 用完移除
DsFactory.unregister("temp");

三、实战场景

读写分离：查询走从库，写入走主库

配置主库和从库两个数据源，业务代码中按需切换：

# db.setting配置
[master]
url = jdbc:mysql://master:3306/db
username = root
password = 123456[slave]
url = jdbc:mysql://slave:3306/db
username = root
password = 123456

业务代码：

public class OrderService {// 写入操作走主库public void createOrder(Order order) {Db.use(DsFactory.get("master")).insert(Entity.parse(order));}// 查询操作走从库public List<Order> getOrders(Long userId) {Entity where = Entity.create("order").set("user_id", userId);return Db.use(DsFactory.get("slave")).query(where, Order.class);}
}

多租户系统：不同租户用不同数据库

给每个租户分配独立数据库，通过租户 ID 切换数据源：

public class TenantService {// 根据租户ID获取数据源private DataSource getTenantDs(String tenantId) {// 检查是否已注册该租户数据源if (!DsFactory.contains(tenantId)) {// 从配置中心获取租户数据库信息（实际项目中从配置中心获取）String url = "jdbc:mysql://localhost:3306/tenant_" + tenantId;DbConfig config = new DbConfig();config.setUrl(url);config.setUsername("root");config.setPassword("123456");// 注册数据源DsFactory.register(tenantId, config);}return DsFactory.get(tenantId);}// 操作租户数据public List<User> getTenantUsers(String tenantId) {return Db.use(getTenantDs(tenantId)).query(Entity.create("user"), User.class);}
}

临时数据处理：动态创建数据源

处理临时任务时，动态创建数据源，用完即删：

public class TempDataService {public void processTempData(String dbPath) {// 动态注册SQLite数据源String dsName = "temp_" + System.currentTimeMillis();DbConfig config = new DbConfig();config.setUrl("jdbc:sqlite:" + dbPath);config.setDriver("org.sqlite.JDBC");DsFactory.register(dsName, config);try {// 处理数据Db.use(DsFactory.get(dsName)).execute("select * from temp_data");} finally {// 移除数据源DsFactory.unregister(dsName);}}
}