AbstractRoutingDataSource AOP如何实现动态数据源切换
发表于:2024-10-01 作者:千家信息网编辑
千家信息网最后更新 2024年10月01日,本篇内容介绍了"AbstractRoutingDataSource AOP如何实现动态数据源切换"的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这
千家信息网最后更新 2024年10月01日AbstractRoutingDataSource AOP如何实现动态数据源切换数据库配置:application.properties
本篇内容介绍了"AbstractRoutingDataSource AOP如何实现动态数据源切换"的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这些情况吧!希望大家仔细阅读,能够学有所成!
数据库配置:application.properties
## datasource master #spring.datasource.type=com.alibaba.druid.pool.DruidDataSourcespring.datasource.driver-class-name=com.mysql.jdbc.Driverspring.datasource.url=jdbc:mysql://localhost:3306/master?characterEncoding=UTF-8&serverTimezone=UTCspring.datasource.username=rootspring.datasource.password=123456## datasource slave #spring.datasource-slave.type=com.alibaba.druid.pool.DruidDataSourcespring.datasource-slave.driver-class-name=com.mysql.jdbc.Driverspring.datasource-slave.url=jdbc:mysql://localhost:3306/slave?characterEncoding=UTF-8&serverTimezone=UTCspring.datasource-slave.username=rootspring.datasource-slave.password=123456
编写数据库名注解
public interface Datasources { String MASTER_DB = "masterDB"; String SLAVE_DB = "slaveDB";}
配置数据源
@Configurationpublic class DataSourceConfig { //destroy-method="close"的作用是当数据库连接不使用的时候,就把该连接重新放到数据池中,方便下次使用调用. @Bean(destroyMethod = "close", name = Datasources.MASTER_DB) @ConfigurationProperties(prefix = "spring.datasource") public DataSource dataSource() { return DataSourceBuilder.create().type(DruidDataSource.class).build(); } @Bean(destroyMethod = "close", name = Datasources.SLAVE_DB) @ConfigurationProperties(prefix = "spring.datasource-slave") public DataSource dataSourceSlave() { return DataSourceBuilder.create().type(DruidDataSource.class).build(); }}
配置成动态数据源
@Configuration@MapperScan(basePackages = {"com.example.dao"})public class MybatisConfig { @Autowired @Qualifier(Datasources.MASTER_DB) private DataSource masterDB; @Autowired @Qualifier(Datasources.SLAVE_DB) private DataSource slaveDB; /** * 动态数据源 */ @Bean(name = "dynamicDataSource") public DataSource dynamicDataSource() { DynamicDataSource dynamicDataSource = new DynamicDataSource(); // 默认数据源 dynamicDataSource.setDefaultTargetDataSource(masterDB); // 配置多数据源 Map
使用ThreadLocal安全的管理当前进程使用的数据源连接
public class DataSourceContextHolder { /** * 默认数据源 */ public static final String DEFAULT_DATASOURCE = Datasources.MASTER_DB; private static final ThreadLocalcontextHolder = new ThreadLocal<>(); // 设置数据源名 public static void setDB(String dbType) { System.out.println("切换到{}数据源:" + dbType); contextHolder.set(dbType); } // 获取数据源名 public static String getDB() { return (contextHolder.get()); } // 清除数据源名 public static void clearDB() { contextHolder.remove(); }}
通过编写切面,对所有我们自定义切库注解的方法进行拦截,动态的选择数据源
@Aspect@Componentpublic class DynamicDataSourceAspect { @Before("@annotation(com.example.util.RoutingDataSource)") public void beforeSwitchDS(JoinPoint joinPoint) { MethodSignature methodSignature = (MethodSignature) joinPoint.getSignature(); Method method = methodSignature.getMethod(); String dataSource = DataSourceContextHolder.DEFAULT_DATASOURCE; if (method.isAnnotationPresent(RoutingDataSource.class)) { RoutingDataSource routingDataSource = method.getDeclaredAnnotation(RoutingDataSource.class); dataSource = routingDataSource.value(); } DataSourceContextHolder.setDB(dataSource); } @After("@annotation(com.example.util.RoutingDataSource)") public void afterSwitchDS(JoinPoint point) { DataSourceContextHolder.clearDB(); }}
动态的取出我们在切面里设置的数据源的字符串
public class DynamicDataSource extends AbstractRoutingDataSource{ @Override protected Object determineCurrentLookupKey() { System.out.println("数据源为{}:" + DataSourceContextHolder.getDB()); return DataSourceContextHolder.getDB(); }}
取消自动配置数据源,使用我们这里定义的数据源配置
@SpringBootApplication(exclude = { DataSourceAutoConfiguration.class})public class CutDataBaseApplication { public static void main(String[] args) { SpringApplication.run(CutDataBaseApplication.class, args); }}
使用
/** * @author aYong * @version 1.0 * @date 2019/7/24 */@RestController@RequestMapping("/route")public class SysUserController { @Autowired private SysUserService sysUserService; @GetMapping("/test1") public SysUser test1(long id) { return sysUserService.test1(id); } @GetMapping("/test2") public Integer test2(long id, String name) { return sysUserService.test2(id, name); }}
"AbstractRoutingDataSource AOP如何实现动态数据源切换"的内容就介绍到这里了,感谢大家的阅读。如果想了解更多行业相关的知识可以关注网站,小编将为大家输出更多高质量的实用文章!
数据
数据源
配置
动态
切换
数据库
内容
切面
更多
注解
知识
实用
安全
学有所成
接下来
作用
关键
困境
字符
字符串
数据库的安全要保护哪些东西
数据库安全各自的含义是什么
生产安全数据库录入
数据库的安全性及管理
数据库安全策略包含哪些
海淀数据库安全审计系统
建立农村房屋安全信息数据库
易用的数据库客户端支持安全管理
连接数据库失败ssl安全错误
数据库的锁怎样保障安全
数据库商数字资源服务策略
计算机和服务器安装配置
深圳市天鹰软件开发座机号码
河北统计局网络安全培训班
mc服务器换了电脑还在吗
祥云杯网络安全大赛时间
公安的大数据库
湘潭市网络安全培训
护苗 网络安全课堂登录
大专的计算机网络技术学什么
天津计算机网络技术本科学校
云帮手可以装在服务器里吗
手机泰拉瑞亚有服务器吗
现在学习软件开发有前途吗
滇西科技互联网金融学什么
当当云阅读数据库 图书馆
电信摄像头云服务器
产品软件开发是什么意思
软件开发类公务员考试
设某商业数据库
百度的网络安全问题
会计经常用哪一个数据库
网络技术服务与支持
神佑释放上去显示没有服务器
国内saas软件开发
魔兽世界服务器名字
中国电信网络安全服务电话
数据库原理的产生
数据库能取消主键吗
学软件开发it