java项目实现多数据源实例

在Java项目中实现多数据源，可以使用Spring框架的注解和配置来实现。以下是一些实现多数据源的步骤：

1. 配置多个数据源的连接信息，可以在application.properties或application.yml文件中配置多个数据源的连接信息。

2. 在Spring Boot的启动类上添加@MapperScan注解，指定mapper接口所在的包路径。

3. 创建多个DataSource对象，并分别注入到对应的Mapper接口中，可以使用@Qualifier注解指定不同的数据源。

4. 在Mapper接口方法上使用@Mapper注解指定对应的Mapper接口和数据源。

5. 在需要切换数据源的地方，使用@Primary注解指定默认数据源，或者使用@Qualifier注解指定特定的数据源。

6. 在需要动态切换数据源的地方，使用AOP拦截Mapper接口的方法，通过ThreadLocal来保存数据源的信息，并在执行方法前切换数据源。

例如，以下是一个使用Spring Boot和MyBatis实现多数据源的示例代码：

@Configuration
@MapperScan(basePackages = {"com.example.mapper"})
public class DataSourceConfig {
 
    @Bean(name = "dataSource1")
    @ConfigurationProperties(prefix = "spring.datasource.db1")
    public DataSource dataSource1() {
        return DataSourceBuilder.create().build();
    }
 
    @Bean(name = "dataSource2")
    @ConfigurationProperties(prefix = "spring.datasource.db2")
    public DataSource dataSource2() {
        return DataSourceBuilder.create().build();
    }
 
    @Bean(name = "dynamicDataSource")
    @Primary
    public DynamicDataSource dataSource(@Qualifier("dataSource1") DataSource dataSource1,
                                         @Qualifier("dataSource2") DataSource dataSource2) {
        Map<Object, Object> targetDataSources = new HashMap<>();
        targetDataSources.put(DatabaseType.db1, dataSource1);
        targetDataSources.put(DatabaseType.db2, dataSource2);
        DynamicDataSource dataSource = new DynamicDataSource();
        dataSource.setTargetDataSources(targetDataSources);
        dataSource.setDefaultTargetDataSource(dataSource1);
        return dataSource;
    }
}
 
public enum DatabaseType {
    db1, db2;
}
 
public class DynamicDataSource extends AbstractRoutingDataSource {
 
    @Override
    protected Object determineCurrentLookupKey() {
        return DatabaseContextHolder.getCurrentDatabaseType();
    }
}
 
public class DatabaseContextHolder {
 
    private static final ThreadLocal<DatabaseType> contextHolder = new ThreadLocal<>();
 
    public static void setCurrentDatabaseType(DatabaseType type) {
        contextHolder.set(type);
    }
 
    public static DatabaseType getCurrentDatabaseType() {
        return contextHolder.get();
    }
 
    public static void clearDatabaseType() {
        contextHolder.remove();
    }
}
 
@Retention(RetentionPolicy.RUNTIME)
@Target({ElementType.METHOD})
public @interface DataSource {
    DatabaseType value() default DatabaseType.db1;
}
 
public interface UserMapper {
 
    @DataSource(value = DatabaseType.db1)
    List<User> selectAllUsers();
 
    @DataSource(value = DatabaseType.db2)
    List<User> selectAllUsersFromDb2();
}
 
@Aspect
@Component
public class DynamicDataSourceAspect {
 
    @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) {
            DatabaseContextHolder.setCurrentDatabaseType(dataSource.value());
        }
        try {
            return point.proceed();
        } finally {
            DatabaseContextHolder.clearDatabaseType();
        }
    }
}

以上是一个简单的多数据源的实现，通过注解和AOP实现数据源的动态切换。通过以上实现，可以轻松在Java项目中实现多数据源的功能。