Springboot mybais配置多数据源过程解析

下面就详细讲解“Springboot mybais配置多数据源过程解析”的完整攻略。

一、引入依赖

首先,我们需要在pom.xml文件中引入相关的依赖,具体如下:

<dependencies>
    <!--SpringBoot启动器-->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter</artifactId>
        <version>2.5.5</version>
    </dependency>
    <!--Mybatis依赖-->
    <dependency>
        <groupId>org.mybatis.spring.boot</groupId>
        <artifactId>mybatis-spring-boot-starter</artifactId>
        <version>2.2.0</version>
    </dependency>
    <!--Mysql驱动-->
    <dependency>
        <groupId>mysql</groupId>
        <artifactId>mysql-connector-java</artifactId>
        <version>8.0.25</version>
    </dependency>
</dependencies>

二、配置application.properties

application.properties文件中,我们需要配置相关的数据源信息,具体如下所示:

# 主数据源
spring.datasource.master.url=jdbc:mysql://localhost:3306/master_database?useSSL=false&serverTimezone=UTC
spring.datasource.master.username=root
spring.datasource.master.password=123456
spring.datasource.master.driver-class-name=com.mysql.jdbc.Driver

# 从数据源
spring.datasource.slave.url=jdbc:mysql://localhost:3306/slave_database?useSSL=false&serverTimezone=UTC
spring.datasource.slave.username=root
spring.datasource.slave.password=123456
spring.datasource.slave.driver-class-name=com.mysql.jdbc.Driver

三、配置DataSource及SqlSessionFactory

@Configuration
@MapperScan(basePackages = {"com.example.demo.mapper"})
public class DataSourceConfiguration {

    @Bean(name = "masterDataSource")
    @Qualifier("masterDataSource")
    @ConfigurationProperties(prefix = "spring.datasource.master")
    public DataSource masterDataSource() {
        return DataSourceBuilder.create().build();
    }

    @Bean(name = "slaveDataSource")
    @Qualifier("slaveDataSource")
    @ConfigurationProperties(prefix = "spring.datasource.slave")
    public DataSource slaveDataSource() {
        return DataSourceBuilder.create().build();
    }

    @Bean(name = "dynamicDataSource")
    public DynamicDataSource dynamicDataSource(@Qualifier("masterDataSource") DataSource masterDataSource,
                                               @Qualifier("slaveDataSource") DataSource slaveDataSource) {
        Map<Object, Object> targetDataSources = new HashMap<>();
        targetDataSources.put(DataSourceEnum.MASTER.getName(), masterDataSource);
        targetDataSources.put(DataSourceEnum.SLAVE.getName(), slaveDataSource);
        DynamicDataSource dynamicDataSource = new DynamicDataSource(masterDataSource, targetDataSources);
        return dynamicDataSource;
    }

    @Bean(name = "sqlSessionFactory")
    public SqlSessionFactory sqlSessionFactory(@Qualifier("dynamicDataSource") DynamicDataSource dataSource) throws Exception {
        SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
        bean.setDataSource(dataSource);
        Resource[] resources = new PathMatchingResourcePatternResolver().getResources("classpath*:mapper/*.xml");
        bean.setMapperLocations(resources);
        return bean.getObject();
    }

    @Bean(name = "sqlSessionTemplate")
    public SqlSessionTemplate sqlSessionTemplate(@Qualifier("sqlSessionFactory") SqlSessionFactory sqlSessionFactory) {
        return new SqlSessionTemplate(sqlSessionFactory);
    }

}

四、自定义DynamicDataSource

public class DynamicDataSource extends AbstractRoutingDataSource {

    private static final ThreadLocal<String> contextHolder = new ThreadLocal<>();

    private Object defaultDataSource;
    private Object readDataSource;
    private Map<Object, Object> targetDataSources;

    public DynamicDataSource(Object defaultDataSource, Map<Object, Object> targetDataSources) {
        this.defaultDataSource = defaultDataSource;
        this.targetDataSources = targetDataSources;
    }

    public void setReadDataSource(Object readDataSource) {
        this.readDataSource = readDataSource;
    }

    @Override
    protected Object determineCurrentLookupKey() {
        return contextHolder.get();
    }

    @Override
    public void afterPropertiesSet() {
        setDefaultTargetDataSource(defaultDataSource);
        setTargetDataSources(targetDataSources);
        super.afterPropertiesSet();
    }

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

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

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

}

五、定义数据源枚举类

public enum DataSourceEnum {

    MASTER("masterDataSource"),
    SLAVE("slaveDataSource");

    private String name;

    DataSourceEnum(String name) {
        this.name = name;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }
}

六、使用

在需要使用的方法上标注使用哪个数据源,如下所示:

@Service
public class UserServiceImpl implements UserService {

    @Autowired
    UserDao userDao;

    @Override
    public List<User> getUsers() {
        DynamicDataSource.setDataSource(DataSourceEnum.MASTER.getName());
        return userDao.getUsers();
    }

    @Override
    public List<User> getSlaveUsers() {
        DynamicDataSource.setDataSource(DataSourceEnum.SLAVE.getName());
        return userDao.getUsers();
    }
}

七、示例说明

示例一:查询主数据源

在使用主数据源查询用户列表时,我们可以去除@DataSource注解,使用默认数据源即可。代码示例如下:

@Service
public class UserServiceImpl implements UserService {

    @Autowired
    UserDao userDao;

    @Override
    public List<User> getUsers() {
        return userDao.getUsers();
    }

}

示例二:查询从数据源

在使用从数据源查询用户列表时,我们需要在方法上加上自定义的@DataSource注解,如下所示:

@Service
public class UserServiceImpl implements UserService {

    @Autowired
    UserDao userDao;

    @DataSource(name = DataSourceEnum.SLAVE)
    @Override
    public List<User> getSlaveUsers() {
        return userDao.getUsers();
    }
}

以上就是“Springboot mybais配置多数据源过程解析”的完整攻略。

本站文章如无特殊说明,均为本站原创,如若转载,请注明出处:Springboot mybais配置多数据源过程解析 - Python技术站

(0)
上一篇 2023年5月18日
下一篇 2023年5月18日

相关文章

  • 教你用springboot连接mysql并实现增删改查

    下面我来详细讲解“教你用springboot连接mysql并实现增删改查”的完整攻略。 一、概述 本攻略将介绍如何用Spring Boot连接Mysql数据库,并实现常见的增删改查操作。首先,你需要搭建Spring Boot环境,并对Mysql数据库进行简单的配置。随后,通过使用Spring Boot的开发架构进行编写代码,最终实现对Mysql数据库的增删改…

    database 2023年5月18日
    00
  • MySQL基本命令、常用命令总结

    MySQL基本命令、常用命令总结 MySQL是一款常用的关系型数据库管理系统,使用广泛,为了能够更好地使用MySQL,以下是MySQL基本命令和常用命令的总结,希望对你有所帮助。 基本命令 连接MySQL 使用以下命令连接到MySQL服务器: mysql -u 用户名 -p 其中,用户名为数据库用户的名称,例如: mysql -u root -p 连接成功后…

    database 2023年5月22日
    00
  • PHP mysql事务问题实例分析

    PHP mysql事务问题实例分析 什么是事务 数据库事务是指批量操作中的所有单个操作作为整体的执行过程。事务可以被视为某个进程或线程执行的所有数据库操作的逻辑集合,这些操作被视为一个单独的工作单元,这些操作要么全部完成,要么全部不执行。 在PHP mysql事务中,要使用Begin、Rollback和Commit三个命令来控制事务的结果。 事务的关键点 B…

    database 2023年5月21日
    00
  • Redis高可用二( 哨兵sentinel)

    1、主从配置 2、配置哨兵 sentinel.conf # Example sentinel.conf bind 0.0.0.0 protected-mode no # 关闭安全模式 port 26380 # 哨兵端口 sentinel monitor mymaster 127.0.0.1 6380 # mymaster默认 127.0.0.1:主redis…

    Redis 2023年4月12日
    00
  • linux安装mysql和使用c语言操作数据库的方法 c语言连接mysql

    首先,安装MySQL需要以下几个步骤: 安装MySQL 1. 下载MySQL 首先需要去MySQL官网下载MySQL的安装包,在下载页面选择适合自己系统的安装包进行下载。 2. 安装MySQL 下载好的安装包,需要使用命令行安装。首先需要使用以下命令,解压安装包: tar -zxvf mysql-5.7.29-linux-glibc2.12-x86_64.t…

    database 2023年5月22日
    00
  • MySQL 数据库两台主机同步实战(linux)

    我将为您详细讲解“MySQL 数据库两台主机同步实战(linux)”的完整攻略,过程中将包含两条示例说明。以下是步骤: 准备工作 在两台需要同步的主机上安装 MySQL 数据库; 确保两台主机之间已经能够通过网络互相访问; 设置主机 A 和主机 B 的 MySQL 数据库的参数,使得两台主机的 MySQL 数据库版本、字符集、大小端模式等参数相同。 步骤一:…

    database 2023年5月22日
    00
  • Centos6.6 安装Redis

    一.介绍   redis在做数据库缓存,session存储,消息队列上用的比较多   二.安装 $ yum install -y wget gcc make tcl $ wget http://download.redis.io/releases/redis-3.0.2.tar.gz $ tar zxvf redis-3.0.2.tar.gz $ cd re…

    Redis 2023年4月13日
    00
  • 如何利用MySQL添加联合唯一索引

    添加联合唯一索引可以确保数据库中的多个列的组合不重复,这在确保数据完整性和减少重复数据方面非常有用。下面是利用MySQL添加联合唯一索引的完整攻略: 1. 创建联合唯一索引 要创建联合唯一索引,我们可以使用以下MySQL代码: ALTER TABLE table_name ADD CONSTRAINT constraint_name UNIQUE (colu…

    database 2023年5月22日
    00
合作推广
合作推广
分享本页
返回顶部