jpa动态切换数据源怎么实现

在JPA中实现动态切换数据源可以通过使用多个EntityManagerFactory来实现。下面是一种实现方式：

1. 配置多个数据源的连接信息：在配置文件中定义多个数据源的连接信息，例如数据库URL、用户名、密码等。可以使用application.properties或application.yml文件进行配置。

2. 创建多个EntityManagerFactory：根据配置文件中定义的数据源连接信息，创建多个EntityManagerFactory。可以通过使用@Configuration注解来创建EntityManagerFactory的Bean，同时指定对应的数据源连接信息。

@Configuration
public class DataSourceConfig {
    
    @Bean
    public DataSource dataSource1() {
        // 数据源1的连接信息
        // ...
    }

    @Bean
    public DataSource dataSource2() {
        // 数据源2的连接信息
        // ...
    }

    @Bean
    @Primary
    public EntityManagerFactory entityManagerFactory1() {
        LocalContainerEntityManagerFactoryBean factory = new LocalContainerEntityManagerFactoryBean();
        factory.setDataSource(dataSource1());
        // 设置其他配置信息
        // ...
        factory.afterPropertiesSet();
        return factory.getObject();
    }

    @Bean
    public EntityManagerFactory entityManagerFactory2() {
        LocalContainerEntityManagerFactoryBean factory = new LocalContainerEntityManagerFactoryBean();
        factory.setDataSource(dataSource2());
        // 设置其他配置信息
        // ...
        factory.afterPropertiesSet();
        return factory.getObject();
    }
}

3. 创建动态数据源：在Spring Boot中，可以通过AbstractRoutingDataSource类来实现动态数据源的切换。继承AbstractRoutingDataSource类，重写determineCurrentLookupKey()方法来返回当前要使用的数据源的名称。

import org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource;

public class DynamicDataSource extends AbstractRoutingDataSource {

    @Override
    protected Object determineCurrentLookupKey() {
        // 根据自定义的规则来返回当前要使用的数据源的名称
        // ...
    }
}

4. 配置动态数据源：在配置文件中配置动态数据源，并将多个EntityManagerFactory和动态数据源关联起来。

@Configuration
public class DataSourceConfig {
    
    // ...

    @Bean
    public DataSource dynamicDataSource() {
        DynamicDataSource dataSource = new DynamicDataSource();
        dataSource.setDefaultTargetDataSource(entityManagerFactory1().createEntityManager().getEntityManagerFactory().getDataSource());
        Map targetDataSources = new HashMap<>();
        targetDataSources.put("dataSource1", entityManagerFactory1().createEntityManager().getEntityManagerFactory().getDataSource());
        targetDataSources.put("dataSource2", entityManagerFactory2().createEntityManager().getEntityManagerFactory().getDataSource());
        dataSource.setTargetDataSources(targetDataSources);
        return dataSource;
    }

    @Bean
    public JpaTransactionManager transactionManager() {
        JpaTransactionManager transactionManager = new JpaTransactionManager();
        transactionManager.setEntityManagerFactory(entityManagerFactory1());
        return transactionManager;
    }
}

5. 使用动态数据源：在需要动态切换数据源的地方，通过设置当前要使用的数据源的名称来实现切换。可以使用ThreadLocal来保存当前要使用的数据源的名称，然后在determineCurrentLookupKey()方法中获取该名称并返回。

public class DataSourceContextHolder {
    private static final ThreadLocal contextHolder = new ThreadLocal<>();

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

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

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

// 使用动态数据源
@Service
public class UserServiceImpl implements UserService {

    @Autowired
    private UserRepository userRepository;

    @Override
    public User findById(Long id) {
        String dataSourceName = determineDataSourceName(id);
        DataSourceContextHolder.setDataSource(dataSourceName);
        User user = userRepository.findById(id);
        DataSourceContextHolder.clearDataSource();
        return user;
    }

    private String determineDataSourceName(Long id) {
        // 根据id判断要使用的数据源的名称
        // ...
    }
}

通过以上步骤，就可以实现在JPA中动态切换数据源了。注意在切换数据源时，要确保每次操作完之后，及时清除ThreadLocal中的数据源名称，以免影响后续的操作。