关于多数据源解决方案
目前在SpringBoot
框架基础上多数据源的解决方案大多手动创建多个DataSource
,后续方案有三:
- 继承
org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource
,使用AOP
切面注入相应的数据源 ,但是这种做法仅仅适用单Service
方法使用一个数据源可行,如果单Service
方法有多个数据源执行会造成误读。 - 通过
DataSource
配置JdbcTemplate
Bean,直接使用JdbcTemplate
操控数据源。 - 分别通过
DataSource
创建SqlSessionFactory
并扫描相应的Mapper
文件和Mapper
接口。
MybatisPlus
的多数据源
我通过阅读源码,发现MybatisPlus
的多数据源解决方案正是AOP
,继承了org.springframework.jdbc.datasource.AbstractDataSource
,有自己对ThreadLocal
的处理。通过注解切换数据源。也就是说,MybatisPlus
只支持在单Service
方法内操作一个数据源,毕竟官网都指明——“强烈建议只注解在service实现上”。
而后,注意看com.baomidou.dynamic.datasource.toolkit.DynamicDataSourceContextHolder
,也就是MybatisPlus
是如何切换数据源的。
重点看:
/** * 为什么要用链表存储(准确的是栈) * <pre> * 为了支持嵌套切换,如ABC三个service都是不同的数据源 * 其中A的某个业务要调B的方法,B的方法需要调用C的方法。一级一级调用切换,形成了链。 * 传统的只设置当前线程的方式不能满足此业务需求,必须模拟栈,后进先出。 * </pre> */ private static final ThreadLocal<Deque<String>><strong>本文来源gao@daima#com搞(%代@#码网</strong> LOOKUP_KEY_HOLDER = new ThreadLocal() { @Override protected Object initialValue() { return new ArrayDeque(); } };
这段话翻译为大家都能懂得的意思就是“可以同时操控多个数据源”。那么,在MYSQL
中,有语法为schemaName
+.
+tableName
,如此一来就不会误走数据源了。
我继续看MybatisPlus
是如何利用mybatis
本身的ORM
机制将实体类自动映射以及生成SQL
语句的(这里插一句,MybatisPlus
的源码易读懂,写的很不错)。无意看到了注解com.baomidou.mybatisplus.annotation.TableName
中的schema
,如果在类上加schema
,在生成SQL
语句时就会生成schemaName
+.
+tableName
格式。
MybatisPlus
多数据源事务(JTA
)
简单说明一下JTA
JTA
包括事务管理器(Transaction Manager)和一个或多个支持 XA 协议的资源管理器 ( Resource Manager ) 两部分, 可以将资源管理器看做任意类型的持久化数据存储;事务管理器则承担着所有事务参与单元的协调与控制。
JTA
只是提供了一个接口,并没有提供具体的实现。
不过Atomikos
对其进行了实现,而后SpringBoot
将其进行了整合,对其进行了托管,很方便开发者拿来即用。
其中事务管理器的主要部分为UserTransaction
接口,开发人员通过此接口在信息系统中实现分布式事务;而资源管理器则用来规范提供商(如数据库连接提供商)所提供的事务服务,它约定了事务的资源管理功能,使得 JTA
可以在异构事务资源之间执行协同沟通。