📄 datasource 动态数据源使用

本章文档对应视频 📺 22.动态数据源使用

动态数据源

pigx 的多数据配置，是基于 dynamic-datasource-spring-boot-starter (opens new window)实现，理论上支持此组件的全部功能。

注意动态数据源操作不要添加 @Transactional 注解，会导致数据源切换失效

如何使用

1. 业务服务引入动态数据源服务

<dependency>
  <groupId>com.pig4cloud</groupId>
  <artifactId>pigx-common-datasource</artifactId>
</dependency>

2. 配置数据源信息来源

默认查询本服务数据源的 gen_datasource_conf 表

• 可参考 pigx_codegen 模块对应表，复制到指定的业务模块数据源

• 如需修改表名称可通过以下参数修改

spring:
  datasource:
    druid:
      query-ds-sql: 'select * from xxx where del_flag = 0'

3. 开启动态数据源

// 注意此注解方法在所有注解之上
@EnableDynamicDataSource
..
public class App {
	public static void main(String[] args) {
		SpringApplication.run(App.class, args);
	}
}

4. 使用动态数据源查询

• Mapper 层 @Ds("#last") 固定写法，最后一个参数为指定数据源(必须有)

@Mapper
public interface DemoMapper extends BaseMapper<Demo> {
	@DS("#last")
	Map selectDs(String dsName);
}

• Service 层调用

@Service
public class DemoServiceImpl extends ServiceImpl<DemoMapper, Demo> implements DemoService {
	@Override
	public Object getByDs(Integer id) {
		// 此处 dsName 为以上 gen_datasource_conf 加载数据源 name 字段
		return baseMapper.selectDs("pigxx_core");
	}
}

扩展使用

• 可以参考官方文档： 动态参数解析数据源 (opens new window)

@DS("#session.tenantName")//从session获取
public List selectSpelBySession() {
	return userMapper.selectUsers();
}

@DS("#header.tenantName")//从header获取
public List selectSpelByHeader() {
	return userMapper.selectUsers();
}

@DS("#tenantName")//使用spel从参数获取
public List selectSpelByKey(String tenantName) {
	return userMapper.selectUsers();
}

@DS("#user.tenantName")//使用spel从复杂参数获取
public List selecSpelByTenant(User user) {
	return userMapper.selectUsers();
}