使用SpringBoot实现动态数据源配置

一、什么是动态数据源配置

传统的数据源配置方式是在应用程序启动时，通过配置文件定义数据源。此时，所有的数据源都已经被指定，数据源的使用是固定的。而动态数据源配置则可以在应用程序运行时动态地创建新的数据源或切换已有的数据源，从而提高了应用程序的灵活性和可扩展性。

二、使用SpringBoot实现动态数据源配置的原理

SpringBoot中实现动态数据源配置的关键是借助于AOP和Spring的事务管理。在应用启动时，通过动态代理使用AOP增强了DataSource的实现，使得在每次数据源的获取时，可以根据当前的事务类型选择不同的数据源。这些数据源可以在运行时动态创建，并配置到数据源路由中，供后续的数据访问使用。

三、实现动态数据源配置的步骤

1、引入相关依赖

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-jdbc</artifactId>
        </dependency>
        <dependency>
            <groupId>org.apache.commons</groupId>
            <artifactId>commons-dbcp2</artifactId>
        </dependency>
        <dependency>
            <groupId>org.aspectj</groupId>
            <artifactId>aspectjweaver</artifactId>
        </dependency>
    </dependencies>

2、定义数据源路由

public class DynamicDataSource extends AbstractRoutingDataSource {
    @Override
    protected Object determineCurrentLookupKey() {
        return DynamicDataSourceHolder.getDataSource();
    }
}

3、配置数据源信息

@Configuration
public class DataSourceConfig {
    @Bean
    public DataSource dataSource() {
        Map<Object, Object> targetDataSources = new HashMap<>();
        DataSource dataSource1 = DataSourceBuilder.create().url("jdbc:mysql://localhost:3306/db1")
                .driverClassName("com.mysql.jdbc.Driver")
                .username("root")
                .password("123456")
                .build();
        DataSource dataSource2 = DataSourceBuilder.create().url("jdbc:mysql://localhost:3306/db2")
                .driverClassName("com.mysql.jdbc.Driver")
                .username("root")
                .password("123456")
                .build();
        targetDataSources.put("dataSource1", dataSource1);
        targetDataSources.put("dataSource2", dataSource2);
        DynamicDataSource dynamicDataSource = new DynamicDataSource();
        dynamicDataSource.setTargetDataSources(targetDataSources);
        dynamicDataSource.setDefaultTargetDataSource(dataSource1);
        return dynamicDataSource;
    }
}

4、配置切面和事务管理器

@Configuration
@EnableTransactionManagement
public class AOPConfig {
    @Bean(name = "txManager")
    public DataSourceTransactionManager txManager(DataSource dataSource) {
        return new DataSourceTransactionManager(dataSource);
    }

    @Bean
    @ConditionalOnMissingBean
    public DynamicDataSourceInterceptor dynamicDataSourceInterceptor() {
        return new DynamicDataSourceInterceptor();
    }

    @Bean
    public Advisor dynamicAdvisor() {
        AspectJExpressionPointcut pointcut = new AspectJExpressionPointcut();
        pointcut.setExpression("execution(* org.example..service.*.*(..))");
        return new DefaultPointcutAdvisor(pointcut, dynamicDataSourceInterceptor());
    }
}

四、如何使用动态数据源

在具体的业务逻辑中，只需要在需要使用不同数据源的方法上增加@TargetDataSource注解即可：

@Service
public class UserService {

    @Autowired
    private UserMapper userMapper;

    @TargetDataSource(value = "dataSource1")
    public void addUser(User user) {
        userMapper.insert(user);
    }

    @TargetDataSource(value = "dataSource2")
    public void updateUser(User user) {
        userMapper.update(user);
    }
}

总结

通过以上的步骤，我们已经可以实现动态数据源配置了。使用动态数据源配置可以让我们的应用程序更加灵活和可扩展，能够更好地适应业务变化的需求。