如何使用spring JPA在同一事务中维护不同数据库上的多个sql查询_如何使用Spring连接到两个不同的数据库，一个用于在同一应用程序中读取，另一个用于写入？ - 腾讯云开发者社区

使用Spring JPA在同一事务中维护不同数据库上的多个SQL查询可以通过以下步骤实现：

配置多个数据源：在Spring Boot的配置文件中，配置多个数据源，每个数据源对应一个数据库。可以使用@Configuration注解创建一个配置类，使用@Bean注解创建多个DataSource对象，并分别设置不同的数据库连接信息。
配置实体管理器工厂：使用@Configuration注解创建一个配置类，使用@Bean注解创建多个EntityManagerFactory对象，每个对象与一个数据源关联。在创建EntityManagerFactory时，需要指定对应的数据源和JPA的属性。
配置事务管理器：使用@Configuration注解创建一个配置类，使用@Bean注解创建一个PlatformTransactionManager对象，并指定对应的实体管理器工厂。
创建多个Repository接口：为每个数据库创建一个Repository接口，继承自JpaRepository或CrudRepository。在接口中定义需要的查询方法。
在Service层中使用多个Repository：创建一个Service类，在类中注入多个Repository对象，并使用@Transactional注解标记方法为事务方法。在方法中可以调用不同的Repository对象执行不同数据库的查询操作。

下面是一个示例代码：

@Configuration
public class DataSourceConfig {
    @Bean
    @ConfigurationProperties(prefix = "datasource.db1")
    public DataSource dataSource1() {
        return DataSourceBuilder.create().build();
    }

    @Bean
    @ConfigurationProperties(prefix = "datasource.db2")
    public DataSource dataSource2() {
        return DataSourceBuilder.create().build();
    }
}

@Configuration
@EnableJpaRepositories(
        basePackages = "com.example.repository.db1",
        entityManagerFactoryRef = "entityManagerFactory1",
        transactionManagerRef = "transactionManager1"
)
public class JpaConfig1 {
    @Autowired
    private DataSource dataSource1;

    @Bean
    public LocalContainerEntityManagerFactoryBean entityManagerFactory1() {
        LocalContainerEntityManagerFactoryBean em = new LocalContainerEntityManagerFactoryBean();
        em.setDataSource(dataSource1);
        em.setPackagesToScan("com.example.entity.db1");

        HibernateJpaVendorAdapter vendorAdapter = new HibernateJpaVendorAdapter();
        em.setJpaVendorAdapter(vendorAdapter);

        return em;
    }

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

@Configuration
@EnableJpaRepositories(
        basePackages = "com.example.repository.db2",
        entityManagerFactoryRef = "entityManagerFactory2",
        transactionManagerRef = "transactionManager2"
)
public class JpaConfig2 {
    @Autowired
    private DataSource dataSource2;

    @Bean
    public LocalContainerEntityManagerFactoryBean entityManagerFactory2() {
        LocalContainerEntityManagerFactoryBean em = new LocalContainerEntityManagerFactoryBean();
        em.setDataSource(dataSource2);
        em.setPackagesToScan("com.example.entity.db2");

        HibernateJpaVendorAdapter vendorAdapter = new HibernateJpaVendorAdapter();
        em.setJpaVendorAdapter(vendorAdapter);

        return em;
    }

    @Bean
    public PlatformTransactionManager transactionManager2() {
        JpaTransactionManager transactionManager = new JpaTransactionManager();
        transactionManager.setEntityManagerFactory(entityManagerFactory2().getObject());
        return transactionManager;
    }
}

@Repository
public interface UserRepository1 extends JpaRepository<User, Long> {
    // 定义需要的查询方法
}

@Repository
public interface UserRepository2 extends JpaRepository<User, Long> {
    // 定义需要的查询方法
}

@Service
@Transactional
public class UserService {
    @Autowired
    private UserRepository1 userRepository1;

    @Autowired
    private UserRepository2 userRepository2;

    public void performMultipleQueries() {
        // 在同一事务中执行不同数据库的查询操作
        List<User> users1 = userRepository1.findAll();
        List<User> users2 = userRepository2.findAll();

        // 其他业务逻辑处理
    }
}

在上述示例中，我们配置了两个数据源和两个实体管理器工厂，分别对应两个数据库。然后创建了两个Repository接口，分别对应两个数据库的查询操作。最后在Service类中注入了这两个Repository对象，并在事务方法中执行了不同数据库的查询操作。

这样，就可以使用Spring JPA在同一事务中维护不同数据库上的多个SQL查询了。