文档章节

使用spring动态切换数据源

暗中观察
 暗中观察
发布于 01/23 15:08
字数 425
阅读 28
收藏 1

原理:主要是调用目标方法时,注入不同的数据源,从而实现切换,即利用aop,而aop的实现是用代理实现的

1,给工程添加一个获取数据源的路由,并给它两个不同的数据源

	@Bean
	public ThreadLocalRountingDataSource threadLocalRountingDataSource() {
		ThreadLocalRountingDataSource dataSource=new ThreadLocalRountingDataSource();
		Map<Object, Object> targetDataSources=new HashMap<Object, Object>();
		DataSource master = master();//master 数据源
		DataSource slave = slave();//slave 数据源
		targetDataSources.put(DataSources.MASTER, master);
		targetDataSources.put(DataSources.SLAVE, slave);
		
		dataSource.setTargetDataSources(targetDataSources);
		dataSource.setDefaultTargetDataSource(master);
		return dataSource;
	}

2,ThreadLocalRountingDataSource类主要是有一个决定数据源键的方法

public class ThreadLocalRountingDataSource extends AbstractRoutingDataSource {
    @Override
    protected Object determineCurrentLookupKey() {
        return DataSourceTypeManager.get();
    }
}

3,DataSourceTypeManager实际是一个对ThreadLocal调用的一个工具类,主要是给当前线程设置期数据源的路由键,代码如下:

import com.example.demo.enums.DataSources;

public class DataSourceTypeManager {
    private static final ThreadLocal<DataSources> dataSourceTypes = new ThreadLocal<DataSources>(){
        @Override
        protected DataSources initialValue(){
            return DataSources.MASTER;
        }
    };
    
    public static DataSources get(){
        return dataSourceTypes.get();
    }
    
    public static void set(DataSources dataSourceType){
        dataSourceTypes.set(dataSourceType);
    }
    
    public static void reset(){
        dataSourceTypes.set(DataSources.MASTER);
    }
}

4,编写一个aop类,决定在哪个方法需要切换数据源

@Aspect    // for aop
@Component // for auto scan
@Order(0)  // execute before @Transactional
public class DataSourceInterceptor {    
    @Pointcut("execution(public * com.example.demo.service..*.getUser(..))")
    public void dataSourceSlave(){};
    
    @Before("dataSourceSlave()")
    public void before(JoinPoint jp) {
        DataSourceTypeManager.set(DataSources.SLAVE);
    }
}

彩蛋:

事务拦截器在啥时候注入了ioc容器?

观察@EnableTransactionManagement,它import了 TransactionManagementConfigurationSelector类,然后给容器注入了

AutoProxyRegistrar和ProxyTransactionManagementConfiguration,这里我们重点关注第二个类,点进去发现如下代码

 

给@Transactional标注的方法添加了 TransactionInterceptor 拦截器

本文转载自:https://www.cnblogs.com/digdeep/p/4512368.html

暗中观察

暗中观察

粉丝 8
博文 138
码字总数 48746
作品 0
惠州
私信 提问
JAVA中使用代码创建多数据源,并实现动态切换(一)

2017-06-06 11:31:57补充:近日,在本文的基础之上,扩展了下,使用atomikos来管理事务,保证多数据源操作时,事务一致性。(https://my.oschina.net/simpleton/blog/916108) 另外,感谢朋友...

十月阳光
2017/03/27
6.2K
0
Spring Boot MyBatis 动态数据源切换、多数据源,读写分离

项目地址 https://github.com/helloworlde/SpringBoot-DynamicDataSource 本项目使用 Spring Boot 和 MyBatis 实现多数据源,动态数据源的切换;有多种不同的实现方式,在学习的过程中发现没...

呜呜呜啦啦啦
2017/12/21
0
0
spring+mybitas 实现多数据源动态切换

1 由于项目需要,需要将不同来源的数据存入不同的数据库,所以需要根据入参的信息动态切换数据源 项目core层采用了spring+mybitas 方式进行架构 1 在spring的配置中定义两个数据源 2创建一个...

black_c
2018/05/15
0
0
Spring动态创建,加载,使用多数据源

项目中我们经常会遇到多数据源的问题,尤其是数据同步或定时任务等项目更是如此。多数据源让人最头痛的,不是配置多个数据源,而是如何能灵活动态的切换数据源。例如在一个spring和hibernate...

Java编程思想
2014/02/26
9.8K
3
spring管理多数据源 现在需要通过zookeeper动态控制切换数据源

需求来源: 上次从库宕机了,导致几个同事都在修改配置文件中的IP把从库ip换成主库IP做查询 ,这样从监控通知到修改再到上线发布至少要30分钟。 现在要求通过一个配置页面轻轻松松点击一下就...

Elijah
2016/04/29
842
2

没有更多内容

加载失败,请刷新页面

加载更多

layui table 加载数据后默认选中第一行的radio

$(".layui-table-view[lay-id='table表格的Id'] .layui-table-body tr[data-index=0] .layui-form-radio").click(); data-index=0 表示第一行数据。 将上面这句话写在done回调函数里面。 , ......

SummerGao
14分钟前
1
0
mongoDB 慢查询日志 locks 解读

因为在使用 mongoDB 的时候有性能问题,有比较慢的情况,然后我们可以看慢查询的日志,然后不是很明白,所以记录一下 日志可能是这样的形式: 然后在 mongoDB 的文档中: 这里锁的类型 type...

woshixin
25分钟前
1
0
当金融科技遇上云原生,蚂蚁金服是怎么做安全架构的?

蚂蚁金服在过去十五年重塑支付改变生活,为全球超过十二亿人提供服务,这些背后离不开技术的支撑。在 2019 杭州云栖大会上,蚂蚁金服将十五年来的技术沉淀,以及面向未来的金融技术创新和参会...

SOFAStack
27分钟前
2
0
mssql用cp实现数据表按年月归档备份

工作上用到了mssql,为了实现数据表按年月归档备份,特意写了个python的demo测试了一下,效率不错,归档备份规则、归档记录采用的是sqlite3数据库,可以实现任意表的归档操作,只需要在配置表...

禾木同荚
30分钟前
1
0
1.UML类图及类图关系

类、接口和类图 类 类(Class)是指具有相同属性、方法和关系的对象的抽象,它封装了数据和行为,是面向对象程序设计(OOP)的基础,具有封装性、继承性和多态性等三大特性。 (1) 类名(Nam...

Eappo_Geng
34分钟前
2
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部