spring boot + mybatis实现动态切换数据源实例代码

 更新时间:2018年10月30日 15:20:38   作者:撸码识途  
这篇文章主要给大家介绍了关于spring boot + mybatis实现动态切换数据源的相关资料,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧

前言

前几天有个需求,需要使用不同的数据源,例如某业务要用A数据源,另一个业务要用B数据源。我上网收集了一些资料整合了一下,虽然最后这个需求不了了之了,但是多数据源动态切换还是蛮好用的,所以记录一下,或许以后有用呢?或者自己感兴趣又想玩呢!

下面话不多说了,随着小编来一起看看详细的介绍吧

方法如下:

1.加个依赖

 <dependency>
  <groupId>org.mybatis.spring.boot</groupId>
  <artifactId>mybatis-spring-boot-starter</artifactId>
       <version>1.3.1</version>
 </dependency>

2.application.properties配置文件

#主从数据库
master.db.driverClassName=com.mysql.jdbc.Driver
master.db.url=jdbc:mysql://localhost:3306/cbd?characterEncoding=UTF-8&useUnicode=true&useSSL=false
master.db.username=root
master.db.password=admin
slave.db.driverClassName=com.mysql.jdbc.Driver
slave.db.url=jdbc:mysql://localhost:3306/cbd_test?characterEncoding=UTF-8&useUnicode=true&useSSL=false
slave.db.username=root
slave.db.password=admin

mybatis.config-location= classpath:config/mybatis-config.xml
mybatis.mapper-locations=classpath:mapper/**/*.xml

3.禁用springboot默认加载数据源配置

@SpringBootApplication(exclude = {DataSourceAutoConfiguration.class})
public class Application {
 
 public static void main(String[] args) throws Exception {
  SpringApplication.run(Application.class, args);
 }
}

4.数据源配置类

/**
 * 主数据源
 */
@Configuration
@ConfigurationProperties(prefix = "master.db")
public class MasterDataSourceConfig {
 private String url;
 private String username;
 private String password;
 private String driverClassName;
}
/**
 * 从数据源配置
 */
@Configuration
@ConfigurationProperties(prefix = "slave.db")
public class SlaveDataSourceConfig {
 private String url;
 private String username;
 private String password;
 private String driverClassName;
}
/**
 * 数据源配置类
 */
@Configuration
public class DataSourceComponent {

 @Resource
 private MasterDataSourceConfig masterDataSourceConfig;

 @Resource
 private SlaveDataSourceConfig slaveDataSourceConfig;


  @Bean(name = "master")
 public DataSource masterDataSource() {
  DataSource dataSource = new DataSource();
  dataSource.setUrl(masterDataSourceConfig.getUrl());
  dataSource.setUsername(masterDataSourceConfig.getUsername());
  dataSource.setPassword(masterDataSourceConfig.getPassword());
  dataSource.setDriverClassName(masterDataSourceConfig.getDriverClassName());
  return dataSource;
 }

 @Bean(name = "slave")
 public DataSource slaveDataSource() {
  DataSource dataSource = new DataSource();
  dataSource.setUrl(slaveDataSourceConfig.getUrl());
  dataSource.setUsername(slaveDataSourceConfig.getUsername());
  dataSource.setPassword(slaveDataSourceConfig.getPassword());
  dataSource.setDriverClassName(slaveDataSourceConfig.getDriverClassName());
  return dataSource;
 }

 @Primary//不加这个会报错。
 @Bean(name = "multiDataSource")
 public MultiRouteDataSource exampleRouteDataSource() {
  MultiRouteDataSource multiDataSource = new MultiRouteDataSource();
  Map<Object, Object> targetDataSources = new HashMap<>();
  targetDataSources.put("master", masterDataSource());
  targetDataSources.put("slave", slaveDataSource());
  multiDataSource.setTargetDataSources(targetDataSources);
  multiDataSource.setDefaultTargetDataSource(masterDataSource());
  return multiDataSource;
 }
}

5.数据源上下文

/**
 * 数据源上下文
 */
public class DataSourceContext {
 private static final ThreadLocal<String> contextHolder = new ThreadLocal<>();

 public static void setDataSource(String value) {
  contextHolder.set(value);
 }

 public static String getDataSource() {
  return contextHolder.get();
 }

 public static void clearDataSource() {
  contextHolder.remove();
 }
}

6.DataSource路由类

/*
* 重写的函数决定了最后选择的DataSource
*/
public class MultiRouteDataSource extends AbstractRoutingDataSource {

 @Override
 protected Object determineCurrentLookupKey() {
  //通过绑定线程的数据源上下文实现多数据源的动态切换,有兴趣的可以去查阅资料或源码
  return DataSourceContext.getDataSource();
 }

}

7.使用,修改上下文中的数据源就可以切换自己想要使用的数据源了。

 public UserVO findUser(String username) {
  DataSourceContext.setDataSource("slave");
  UserVO userVO = userMapper.findByVO(username);
  System.out.println(userVO.getName()+"=====================");
  return null;
 }

这种是在业务中使用代码设置数据源的方式,也可以使用AOP+注解的方式实现控制,方法多多!

总结

以上就是这篇文章的全部内容了,希望本文的内容对大家的学习或者工作具有一定的参考学习价值,如果有疑问大家可以留言交流,谢谢大家对脚本之家的支持。

相关文章

  • FastJSON字段智能匹配踩坑的解决

    FastJSON字段智能匹配踩坑的解决

    这篇文章主要介绍了FastJSON字段智能匹配踩坑的解决方案,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2021-06-06
  • JFinal实现伪静态的方法

    JFinal实现伪静态的方法

    JFinal 是基于 Java 语言的极速 WEB + ORM 框架,其核心设计目标是开发迅速、代码量少、学习简单、功能强大、轻量级、易扩展、Restful。这篇文章主要介绍了JFinal实现伪静态,需要的朋友可以参考下
    2018-04-04
  • Java实现的可选择及拖拽图片的面板功能【基于swing组件】

    Java实现的可选择及拖拽图片的面板功能【基于swing组件】

    这篇文章主要介绍了Java实现的可选择及拖拽图片的面板功能,涉及java基于swing组件选择与操作图片元素的相关实现技巧,需要的朋友可以参考下
    2018-01-01
  • Java代码实现循环队列的示例代码

    Java代码实现循环队列的示例代码

    队列作为基础的数据结构,是程序员的入门课。也是所有程序员必须掌握的一种数据结构,队列在程序中广泛应用,因此我们应该对队列有深入的了解,接下来我们通过代码来对队列这种数据结构进行深度解析,感兴趣的朋友一起看看吧
    2021-09-09
  • Java实现排列组合算法的两种方案

    Java实现排列组合算法的两种方案

    Java排列组合算法是一种用于生成所有可能的排列和组合的算法,在Java中,可以使用递归或迭代的方式实现排列组合算法,本文给大家介绍了Java实现排列组合算法的两种方案,需要的朋友可以参考下
    2024-04-04
  • 为什么JDK8中HashMap依然会死循环

    为什么JDK8中HashMap依然会死循环

    这篇文章主要介绍了为什么JDK8中HashMap依然会死循环,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2020-09-09
  • Springboot-Starter造轮子之自动锁组件lock-starter实现

    Springboot-Starter造轮子之自动锁组件lock-starter实现

    这篇文章主要为大家介绍了Springboot-Starter造轮子之自动锁组件lock-starter实现详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2023-05-05
  • BeanUtils.copyProperties复制不生效的解决

    BeanUtils.copyProperties复制不生效的解决

    这篇文章主要介绍了BeanUtils.copyProperties复制不生效的解决方案,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2021-09-09
  • SpringBoot多种场景传参模式

    SpringBoot多种场景传参模式

    传参是非常常见的,本文主要介绍了SpringBoot多种场景传参模式,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2021-07-07
  • Idea 中控制启动命令的详细过程 区分环境案例详解

    Idea 中控制启动命令的详细过程 区分环境案例详解

    这篇文章主要介绍了Idea 中控制启动命令的详细过程 区分环境案例详解,本文通过实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2023-08-08

最新评论