1 由于项目需要,需要将不同来源的数据存入不同的数据库,所以需要根据入参的信息动态切换数据源
项目core层采用了spring+mybitas 方式进行架构
1 在spring的配置中定义两个数据源
2创建一个新的类 MultiDataSource
public class MultiDataSource extends AbstractRoutingDataSource {
- private static final ThreadLocal<String> dataSourceKey = new InheritableThreadLocal<String>();
-
- public static void setDataSourceKey(String dataSource) {
- dataSourceKey.set(dataSource);
- }
-
- @Override
- protected Object determineCurrentLookupKey() {
- return dataSourceKey.get();
- }
}
这个类需要继承 AbstractRoutingDataSource
并且重写 determineCurrentLookupKey方法
3 在spring 的配置文件中新增配置
- <map key-type="java.lang.String">
- <entry value-ref="dataSource1" key="dataSource1"></entry>
- <entry value-ref="dataSource2" key="dataSource2"></entry>
- </map>
4 将配置的dataSource 添加到sessionFactory 中
5 将sessionFactory 注入到sqlSession中
6 动态切换数据源决定采用spring-aop 添加切点 去进行动态切换
6.1 新建数据切换类
public class DataBaseAop {