SpringBoot多数据源切换，AOP实现动态数据源切换SpringBoot多数据源切换，AOP实现动态数据源切换
操作数据⼀般都是在DAO层进⾏处理，可以选择直接使⽤JDBC进⾏编程
或者是使⽤多个DataSource 然后创建多个SessionFactory，在使⽤Dao层的时候通过不同的SessionFactory进⾏处理，不过这样的⼊侵性⽐较明显，⼀般的情况下我们都是使⽤继承HibernateSupportDao进⾏封装了的处理，如果多个SessionFactory这样处理就是⽐较的⿇烦了，修改的地⽅估计也是蛮多的
最后⼀个，也就是使⽤AbstractRoutingDataSource的实现类通过AOP或者⼿动处理实现动态的使⽤我们的数据源，这样的⼊侵性较低，⾮常好的满⾜使⽤的需求。⽐如我们希望对于读写分离或者其他的数据同步的业务场景
●单数据源的场景（⼀般的Web项⽬⼯程这样配置进⾏处理，就已经⽐较能够满⾜我们的业务需求）
多数据源多SessionFactory这样的场景，估计作为刚刚开始想象想处理在使⽤框架的情况下处理业务，配置多个SessionFactory，然后在Dao层中对于特定的请求，通过特定的SessionFactory即可处理实现这样的业务需求，不过这样的处理带来了很多的不便之处，所有很多情况下我们宁愿直接使⽤封装的JDBC编程，或者使⽤Mybatis处理这样的业务场景
●使⽤AbstractRoutingDataSource 的实现类，进⾏灵活的切换，可以通过AOP或者⼿动编程设置当前的DataSource，不⽤修改我们编写的对于继承HibernateSupportDao的实现类的修改，这样的编写⽅式⽐较好，⾄于其中的实现原理，让我细细到来。我们想看看如何去应⽤，实现原理慢慢的说！
●编写AbstractRoutingDataSource的实现类,HandlerDataSource就是提供给我们动态选择数据源的数据的信息，我们这⾥编写⼀个根据当前线程来选择数据源，然后通过AOP拦截特定的注解，设置当前的数据源信息，也可以⼿动的设置当前的数据源，在编程的类中。
* @date 2017年3⽉5⽇上午9:11:49
*/
public class DynamicDataSource extends AbstractRoutingDataSource {
private Map<Object, Object> allResolvedDataSources = new HashMap<>();
@Override
protected Object determineCurrentLookupKey() {
DataSourceType();
}
/**
* 添加数据源
* @param name
* @param dataSource
*/
public void addDataSource(Object name,DataSource dataSource){
ainsKey(name))
allResolvedDataSources.put(name,dataSource);
setTargetDataSources(allResolvedDataSources);
}
/**
* 删除数据源
* @param name
* @return
*/
public Object deleteDataSource(Object name){
Object rst = null;
ainsKey(name))
{
rst = (name);
setTargetDataSources(allResolvedDataSources);
}
return rst;
}
/**
* 检查数据源是否存在
* @param name
* @return
*/
public Boolean isExistDataSource(Object name){
ainsKey(name);
}
}
●设置动态选择的Datasource，这⾥的Set⽅法可以留给AOP调⽤，或者留给我们的具体的Dao层或者Service层中⼿动调⽤，在执⾏SQL 语句之前。
* @date 2017年3⽉5⽇上午9:11:49
*/
public class DynamicDataSource extends AbstractRoutingDataSource {
private Map<Object, Object> allResolvedDataSources = new HashMap<>();
@Override
protected Object determineCurrentLookupKey() {
DataSourceType();
}
/**
* 添加数据源
* @param name
* @param dataSource
*/
public void addDataSource(Object name,DataSource dataSource){
ainsKey(name))
allResolvedDataSources.put(name,dataSource);
setTargetDataSources(allResolvedDataSources);
}
/**
* 删除数据源
* @param name
* @return
*/
public Object deleteDataSource(Object name){
Object rst = null;
ainsKey(name))
{
rst = (name);
setTargetDataSources(allResolvedDataSources);
}
return rst;
}
spring aop应用场景/**
* 检查数据源是否存在
* @param name
* @return
*/
public Boolean isExistDataSource(Object name){
ainsKey(name);
}
}
●在项⽬启动的时候初始化所有的数据源信息，通过DynamicDataSource类以键值对的形式存储
DruidDataSource dataSource = dataSource();
DruidDataSource masterDataSource = masterDataSource();
DruidDataSource clusterDataSource = clusterDataSource();
//DruidDataSource bizDataSource = bizDataSource();
try {
dataSource.init();
clusterDataSource.init();
masterDataSource.init();
// bizDataSource.init();
}catch (SQLException sql){
sql.printStackTrace();
}
DynamicDataSource dynamicDataSource = new DynamicDataSource();
dynamicDataSource.addDataSource(DSEnum.DATA_SOURCE_NAME,dataSource); dynamicDataSource.addDataSource(DSEnum.MASTER_D dynamicDataSource.addDataSource(DSEnum.CLUSTER_DATA_SOURCE_NAME,clusterDataSource);
DataSourceContextUtil.setDataSourceType(DSEnum.DATA_SOURCE_NAME);//设置默认的数据源的Key
dynamicDataSource.setDefaultTargetDataSource(dataSource);//设置默认的数据源
●代码使⽤⽅法，注意的是这⾥使⽤过后需要调⽤清空的⽅法，让其返回默认的数据源，否则将会带着这个数据源满世界的报错不到表，
不到列，映射不到类。。。。。。
DataSourceContextUtil.setDataSourceType(DSEnum.CLUSTER_DATA_SOURCE_NAME);
String sql2="select * from sys_config";
List<Map<String,Object>>String(),null);
DataSourceContextUtil.clearDataSourceType();
下⾯是我使⽤的枚举类型，⽤来当做Key来使⽤的
/**
*
* 多数据源的枚举
*
* @author
* @date 2017年3⽉5⽇上午10:15:02
*/
public interface DSEnum {
String DATA_SOURCE_NAME = "dataSource"; //base数据源
String MASTER_DATA_SOURCE_NAME = "masterDataSource"; //base数据源
String CLUSTER_DATA_SOURCE_NAME = "clusterDataSource"; //base数据源
}
版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。
发表评论