Mybatis多数据源配置

一、Mybatis多数据源配置失效

在使用Mybatis配置多数据源的过程中，可能会出现配置失效的情况。这可能是由于以下原因导致的：

1. 数据源配置错误；

2. Mybatis版本不兼容；

3. 数据库连接池配置错误；

4. Mybatis配置文件错误。

以下为解决方案：

1. 检查数据源配置是否正确，比如用户名、密码、数据库名等；

2. 确认所使用的Mybatis版本是否兼容多数据源配置；

3. 检查数据库连接池配置是否正确，确认连接数、最大连接数是否适当；

4. 检查Mybatis配置文件是否正确，确认多数据源配置是否正确。

二、Mybatis多数据源配置实现

Mybatis多数据源配置方式有多种，可以通过配置XML文件或通过Java配置类实现。以下是通过XML文件实现的示例：

# 配置文件database.properties
db.driverClassName=com.mysql.jdbc.Driver
db.url=jdbc:mysql://localhost:3306/db1?useSSL=false&characterEncoding=utf-8&serverTimezone=GMT%2B8
db.username=username1
db.password=password1

db2.driverClassName=com.mysql.jdbc.Driver
db2.url=jdbc:mysql://localhost:3306/db2?useSSL=false&characterEncoding=utf-8&serverTimezone=GMT%2B8
db2.username=username2
db2.password=password2

# Mybatis配置文件

   
  
    
  
    
  
    
  
    

   


   
  
    
  
    
  
    
  
    

   

三、Mybatis多数据源

Mybatis多数据源配置有许多优势，包括但不限于：

1. 数据分离；

2. 多租户支持；

3. 性能优化。

Mybatis多数据源配置需要使用到多个数据源，每个数据源都需要配置数据库连接池。以下是一个常用的实现方式：

@Configuration
@MapperScan(basePackages = {"com.example.dao"})
@EnableTransactionManagement
public class MybatisConfig {
 
    @Bean(name = "db1")
    @ConfigurationProperties(prefix = "spring.datasource.db1")
    public DataSource dataSource1() {
        return DataSourceBuilder.create().build();
    }
 
    @Bean(name = "db2")
    @ConfigurationProperties(prefix = "spring.datasource.db2")
    public DataSource dataSource2() {
        return DataSourceBuilder.create().build();
    }
 
    @Bean
    public DataSource dynamicDataSource(@Qualifier("db1") DataSource db1,
                                         @Qualifier("db2") DataSource db2) {
        Map
    targetDataSources = new HashMap<>();
        targetDataSources.put("db1", db1);
        targetDataSources.put("db2", db2);
 
        DynamicDataSource dynamicDataSource = new DynamicDataSource();
        dynamicDataSource.setTargetDataSources(targetDataSources);
        dynamicDataSource.setDefaultTargetDataSource(db1);
        return dynamicDataSource;
    }
 
    @Bean
    public SqlSessionFactory sqlSessionFactory(@Qualifier("dynamicDataSource") DataSource dynamicDataSource) throws Exception {
        SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
        bean.setDataSource(dynamicDataSource);
        bean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath*:mapper/*.xml"));
        return bean.getObject();
    }
 
    @Bean
    public PlatformTransactionManager transactionManager(@Qualifier("dynamicDataSource") DataSource dynamicDataSource) {
        return new DataSourceTransactionManager(dynamicDataSource);
    }
}

   

四、Mybatis多数据源切换

在实际应用中，可能需要根据情况动态切换数据源，以下是一个典型的切换方式：

public class DataSourceContextHolder {
 
    /**
     * 默认数据源
     */
    public static final String DEFAULT_DS = "db1";
 
    private static final ThreadLocal
    contextHolder = new ThreadLocal<>();
 
    public static void setDataSource(String dbType) {
        contextHolder.set(dbType);
    }
 
    public static String getDataSource() {
        return contextHolder.get();
    }
 
    public static void clearDataSource() {
        contextHolder.remove();
    }
}

   

@Aspect
@Component
public class DataSourceAspect {
 
    @Pointcut("@annotation(com.example.annotation.DataSource)")
    public void dataSourcePointCut() {
 
    }
 
    @Around("dataSourcePointCut()")
    public Object around(ProceedingJoinPoint point) throws Throwable {
        MethodSignature signature = (MethodSignature) point.getSignature();
        DataSource dataSource = signature.getMethod().getAnnotation(DataSource.class);
        if (dataSource == null) {
            DataSourceContextHolder.setDataSource(DataSourceContextHolder.DEFAULT_DS);
        } else {
            DataSourceContextHolder.setDataSource(dataSource.value());
        }
 
        try {
            return point.proceed();
        } finally {
            DataSourceContextHolder.clearDataSource();
        }
    }
}

五、Mybatis plus官网

Mybatis plus是一个为Mybatis框架增加更多实用功能的扩展库，其官网提供了详细的使用文档和示例：

https://mp.baomidou.com/guide/

六、Mybatis plus数据源

Mybatis plus数据源的实现和Mybatis多数据源的实现类似，只需要在配置文件中指定数据源即可：

spring.datasource.dynamic.primary=db1
spring.datasource.dynamic.datasource.db1.driver-class-name=com.mysql.jdbc.Driver
spring.datasource.dynamic.datasource.db1.url=jdbc:mysql://localhost:3306/db1?useSSL=false&characterEncoding=utf-8&serverTimezone=GMT%2B8
spring.datasource.dynamic.datasource.db1.username=username1
spring.datasource.dynamic.datasource.db1.password=password1

spring.datasource.dynamic.datasource.db2.driver-class-name=com.mysql.jdbc.Driver
spring.datasource.dynamic.datasource.db2.url=jdbc:mysql://localhost:3306/db2?useSSL=false&characterEncoding=utf-8&serverTimezone=GMT%2B8
spring.datasource.dynamic.datasource.db2.username=username2
spring.datasource.dynamic.datasource.db2.password=password2

七、Mybatisplus事务配置

Mybatisplus的事务配置需要使用到Spring事务管理器，具体实现方法如下：

@Configuration
public class TransactionConfig {
 
    @Autowired
    private DataSource dataSource;
 
    @Bean
    public DataSourceTransactionManager transactionManager() {
        return new DataSourceTransactionManager(dataSource);
    }
 
    @Bean
    public SqlSessionTemplate sqlSessionTemplate(SqlSessionFactory sqlSessionFactory) {
        return new SqlSessionTemplate(sqlSessionFactory);
    }
}

以上就是关于Mybatis多数据源配置的详细说明，希望对大家有所帮助。