当前位置：首页 > article >正文

问题清单：@DS数据库配置注解失效

article 2025/1/11 7:35:30

DAO 层已经配置了 @DS("data_base") 注解来指定数据源，但是数据仍然被保存到其他数据库，可能存在以下几种常见的原因：

1. 数据源配置未正确加载

@DS("data_base") 注解依赖于正确的数据源配置。检查以下几个方面：

配置文件：确保 application.properties 或 application.yml 中正确配置了名为 data_base 的数据源。例如：

spring:
  datasource:
    data_base:
      url: jdbc:mysql://localhost:3306/your_database
      username: your_username
      password: your_password
      driver-class-name: com.mysql.cj.jdbc.Driver

数据源配置类：如果使用了自定义的数据源配置，确保 @DS 的数据源名称 data_base 与配置中的一致。

2. 多个数据源的自动装配问题

如果项目中使用了多个数据源（例如 core_hr_ps 和 data_base），确保 @DS("data_base") 注解在正确的类或方法上生效。有时，多个数据源的配置会导致注解不生效。

方法级注解优先级：确保将 @DS("data_base") 注解放在了需要指定数据源的方法上。如果在类上加了 @DS("data_base")，但是某个方法仍然使用默认数据源，可能导致数据插入到默认数据库。
全局数据源配置：如果项目中使用了全局数据源配置（例如 Spring @Primary 注解），可能会覆盖 @DS 注解的配置，导致默认数据源被使用。

3. 事务管理配置

如果使用事务管理，确保事务配置没有覆盖数据源。可以使用 @Transactional 注解来明确指定事务管理器。确保在使用多数据源时，事务管理器也是针对指定数据源进行配置的。

例如，在 Spring 中指定事务管理器：

@Transactional(value = "data_baseTransactionManager")
public void yourMethod() {
    // 方法体
}

4. 动态数据源切换问题

如果使用了动态数据源切换（例如，使用 DynamicDataSource 或 AbstractRoutingDataSource），确保切换逻辑正确。如果数据源切换的实现存在问题，可能导致数据被写入到错误的数据库。

可以检查 DynamicDataSource 配置类，确保它正确识别并切换到指定的数据源。

5. `@DS` 注解的使用位置

如果 @DS 注解在 DAO 层的类上使用，确保它没有被其他注解覆盖。例如，有时 @Mapper 或 @Repository 等注解可能与 @DS 配合不当，导致数据源无法切换。

可以尝试在具体的 DAO 方法上单独标注 @DS，确保每个方法都正确使用了指定的数据源：

@Repository
@DS("data_base")
public class YourDaoImpl {

    @DS("data_base")
    public void insertData(YourEntity entity) {
        // 插入操作
    }
}

6. Spring AOP 或代理问题

@DS 注解通常依赖 Spring AOP（面向切面编程）来动态切换数据源。如果 AOP 配置不正确或代理未生效，也可能导致数据源切换失败，默认数据源被使用。

代理模式：检查 @DS 注解是否被代理生效，确保 Spring AOP 配置正确。

7. 数据库连接池的问题

如果数据库连接池（例如 HikariCP、Druid 等）配置不正确，可能会导致连接池从错误的数据库中获取连接。检查数据库连接池配置，确保它与 @DS("data_base") 的指定数据源一致。

排查步骤

检查 @DS 配置：确保 @DS("data_base") 指向的数据库配置正确。
查看 AOP 配置：检查是否存在 AOP 切面配置，确保数据源切换逻辑生效。
检查事务管理器配置：如果使用事务，确保事务配置与数据源一致，防止事务管理器覆盖数据源。
数据库连接池检查：确保数据库连接池的配置与 @DS 注解中指定的数据库一致。

示例配置

假设有两个数据源 data_base 和 core_hr_ps，以下是一个简化的配置例子：

spring:
  datasource:
    data_base:
      url: jdbc:mysql://localhost:3306/data_base
      username: root
      password: root
      driver-class-name: com.mysql.cj.jdbc.Driver

    core_hr_ps:
      url: jdbc:mysql://localhost:3306/core_hr_ps
      username: root
      password: root
      driver-class-name: com.mysql.cj.jdbc.Driver

在 DAO 层：

@Repository
@Slf4j
@DS("data_base")
public class PeoplesoftStaffJobChangeDAOImpl extends ServiceImpl<PeoplesoftStaffJobChangeMapper, PeoplesoftStaffJobChangeEntity> implements PeoplesoftStaffJobChangeDAO {

    @Override
    public void insertPeoplesoftStaffJobChange(PeoplesoftStaffJobChangeEntity entity) {
        // 确保此操作保存到 data_base 数据库
        this.baseMapper.insert(entity);
    }
}

这样，@DS("data_base") 注解会确保此方法或类使用 data_base 数据源进行操作。

解读3：

事务管理器（Transaction Manager）是管理数据库事务的核心组件，它负责开启、提交和回滚事务。当项目中使用多个数据源时，需要确保每个数据源对应的事务管理器是独立的，并且能够正确地控制每个数据源的事务。这就涉及到事务管理器的配置。

为什么事务管理器需要与数据源一致？

数据源和事务的绑定：每个数据源都需要有一个对应的事务管理器。如果事务管理器和数据源不匹配，事务可能不会在正确的数据库上生效，导致数据不一致或无法回滚。
多数据源的情况下：当使用多个数据源时，如果所有的数据源都使用一个全局的事务管理器，事务管理器可能无法正确地识别不同数据源的事务，导致事务管理失效，或者事务回滚时会出现问题。
防止事务覆盖：如果事务管理器配置错误，可能导致某个数据源的事务被另一个数据源的事务管理器覆盖，进而影响到数据提交和回滚。

如何确保事务配置与数据源一致？

每个数据源配置一个对应的事务管理器：需要为每个数据源配置一个独立的事务管理器。这可以通过自定义配置来实现。
指定事务管理器：当在代码中使用 @Transactional 注解时，可以显式指定使用哪个事务管理器，这样可以确保事务操作与指定的数据源一致。

示例：多数据源的事务管理器配置

假设应用中有两个数据源：data_base 和 core_hr_ps。需要为每个数据源配置一个独立的事务管理器。

1. 数据源配置

spring:
  datasource:
    data_base:
      url: jdbc:mysql://localhost:3306/data_base
      username: root
      password: root
      driver-class-name: com.mysql.cj.jdbc.Driver

    core_hr_ps:
      url: jdbc:mysql://localhost:3306/core_hr_ps
      username: root
      password: root
      driver-class-name: com.mysql.cj.jdbc.Driver

2. 事务管理器配置

在 Spring 配置类中，为每个数据源配置一个独立的 PlatformTransactionManager。

@Configuration
public class DataSourceConfig {

    @Bean(name = "dataBaseDataSource")
    @Primary
    @ConfigurationProperties(prefix = "spring.datasource.data_base")
    public DataSource dataBaseDataSource() {
        return DataSourceBuilder.create().build();
    }

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

    @Bean(name = "dataBaseTransactionManager")
    public PlatformTransactionManager dataBaseTransactionManager(
            @Qualifier("dataBaseDataSource") DataSource dataBaseDataSource) {
        return new DataSourceTransactionManager(dataBaseDataSource);
    }

    @Bean(name = "coreHrPsTransactionManager")
    public PlatformTransactionManager coreHrPsTransactionManager(
            @Qualifier("coreHrPsDataSource") DataSource coreHrPsDataSource) {
        return new DataSourceTransactionManager(coreHrPsDataSource);
    }
}

3. 使用 `@Transactional` 注解时指定事务管理器

当使用 @Transactional 注解时，可以通过 value 属性来指定使用哪个事务管理器。这样可以确保事务操作与正确的数据源一致。

@Repository
@DS("data_base") // 指定使用 data_base 数据源
public class PeoplesoftStaffJobChangeDAOImpl extends ServiceImpl<PeoplesoftStaffJobChangeMapper, PeoplesoftStaffJobChangeEntity> implements PeoplesoftStaffJobChangeDAO {

    @Transactional(value = "dataBaseTransactionManager") // 指定事务管理器
    public void insertPeoplesoftStaffJobChange(PeoplesoftStaffJobChangeEntity entity) {
        // 执行数据库插入操作
        this.baseMapper.insert(entity);
    }
}

@Repository
@DS("core_hr_ps") // 指定使用 core_hr_ps 数据源
public class AnotherDaoImpl extends ServiceImpl<AnotherMapper, AnotherEntity> implements AnotherDao {

    @Transactional(value = "coreHrPsTransactionManager") // 指定事务管理器
    public void insertAnotherData(AnotherEntity entity) {
        // 执行数据库插入操作
        this.baseMapper.insert(entity);
    }
}

4. 事务的传播行为

有时候，事务的传播行为也很重要，尤其是当有多个方法调用时。通过设置传播行为，确保在多个数据源之间切换时，事务能够正确传播。

@Transactional(value = "dataBaseTransactionManager", propagation = Propagation.REQUIRED)
public void someMethod() {
    // 调用其他方法，确保事务传播
    anotherMethod();
}