117.info
人生若只如初见

mybatis中druid多数据源怎么配置

在MyBatis中配置Druid多数据源主要需要进行以下步骤:

  1. 首先,在pom.xml文件中添加Druid和MyBatis的依赖:

    com.alibaba
    druid
    1.1.23



    org.mybatis
    mybatis
    3.5.6

  1. 然后在application.properties或者application.yml文件中配置Druid的数据源信息,例如:
spring.datasource.druid.datasource1.url=jdbc:mysql://localhost:3306/test1
spring.datasource.druid.datasource1.username=root
spring.datasource.druid.datasource1.password=root

spring.datasource.druid.datasource2.url=jdbc:mysql://localhost:3306/test2
spring.datasource.druid.datasource2.username=root
spring.datasource.druid.datasource2.password=root
  1. 创建DruidDataSource配置类,用于配置Druid数据源:
@Configuration
public class DruidDataSourceConfig {

    @Bean(name = "dataSource1")
    @ConfigurationProperties(prefix = "spring.datasource.druid.datasource1")
    public DataSource dataSource1() {
        return DruidDataSourceBuilder.create().build();
    }

    @Bean(name = "dataSource2")
    @ConfigurationProperties(prefix = "spring.datasource.druid.datasource2")
    public DataSource dataSource2() {
        return DruidDataSourceBuilder.create().build();
    }

    @Bean
    @Primary
    public DynamicDataSource dataSource(@Qualifier("dataSource1") DataSource dataSource1, @Qualifier("dataSource2") DataSource dataSource2) {
        Map targetDataSources = new HashMap<>();
        targetDataSources.put("dataSource1", dataSource1);
        targetDataSources.put("dataSource2", dataSource2);

        DynamicDataSource dynamicDataSource = new DynamicDataSource();
        dynamicDataSource.setTargetDataSources(targetDataSources);
        dynamicDataSource.setDefaultTargetDataSource(dataSource1);

        return dynamicDataSource;
    }

    @Bean
    public SqlSessionFactory sqlSessionFactory(@Qualifier("dataSource") DataSource dataSource) throws Exception {
        SqlSessionFactoryBean sqlSessionFactoryBean = new SqlSessionFactoryBean();
        sqlSessionFactoryBean.setDataSource(dataSource);
        return sqlSessionFactoryBean.getObject();
    }

    @Bean
    public SqlSessionTemplate sqlSessionTemplate(SqlSessionFactory sqlSessionFactory) {
        return new SqlSessionTemplate(sqlSessionFactory);
    }
}
  1. 创建DynamicDataSource类,用于动态切换数据源:
public class DynamicDataSource extends AbstractRoutingDataSource {

    @Override
    protected Object determineCurrentLookupKey() {
        return DataSourceContextHolder.getDataSource();
    }
}
  1. 创建DataSourceContextHolder类,用于设置数据源的key:
public class DataSourceContextHolder {

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

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

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

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

通过以上步骤,就可以实现在MyBatis中配置Druid多数据源。在需要切换数据源的地方,可以通过调用DataSourceContextHolder.setDataSource("dataSource2")来切换到相应的数据源。

未经允许不得转载 » 本文链接:https://www.117.info/ask/fecfbAzsIBARXAFU.html

推荐文章

  • mybatis怎么添加数据返回对象

    MyBatis可以通过以下几种方式添加数据并返回对象: 使用insert语句添加数据并返回自动生成的主键值: // 定义一个mapper接口方法
    void insertUser(User use...

  • mybatis分页查询的方法是什么

    MyBatis提供了一种方便的方式来执行分页查询,使用的方法是使用插件PageHelper。
    使用PageHelper方法进行分页查询的步骤如下: 首先,在pom.xml文件中添加p...

  • mybatis无参数分页问题怎么解决

    当使用MyBatis进行无参数分页查询时,可以通过在SQL查询语句中使用LIMIT关键字来实现分页。具体步骤如下: 在Mapper接口中定义一个查询方法,例如List getUserLi...

  • mybatis怎么批量更新数据

    MyBatis 可以通过批量操作来更新数据。下面是一个示例代码,展示如何使用 MyBatis 进行批量更新数据: 首先,需要在 Mapper XML 文件中定义一个批量更新的 SQL 语...

  • java中entends的使用方法是什么

    在 Java 中,extends 是用来创建类的继承关系的关键字。通过使用 extends,一个子类可以继承一个父类的属性和方法。子类会继承父类的所有非私有成员,包括字段和...

  • spring事务传播行为怎么使用

    Spring事务传播行为用于控制事务的传播方式,即在一个事务方法调用另一个事务方法时,如何处理事务的传播。Spring框架提供了多种事务传播行为,例如REQUIRED、SU...

  • springboot收集日志的方法是什么

    Spring Boot 收集日志的方法通常使用日志框架,如 Logback 或 Log4j。Spring Boot 默认使用 Logback 作为日志框架,并提供了默认的日志配置文件 logback-spring....

  • springboot启动日志的方法是什么

    在Spring Boot应用程序启动时,会打印出一些启动日志信息,其中包括应用程序的配置信息、启动时间、应用程序的运行端口等。这些启动日志信息对于调试和排查问题非...