Spring中如何用同一Repository和Entity实现双PostgreSQL库分布式事务写入？

首先明确：Spring没有开箱即用的方案能让单个Repository.save()直接同时写入两个不同数据库的同一张表。你需要通过多数据源配置+分布式事务管理来实现需求。

一、配置双数据源与对应Repository #

你需要为两个区域的PostgreSQL数据库分别配置独立的数据源、实体管理工厂和事务管理器，同时创建两个对应Repository接口：

• 分别定义两个DataSource Bean，用@Qualifier区分，其中一个可标记@Primary作为默认数据源
• 为每个数据源配置LocalContainerEntityManagerFactoryBean，指定对应的实体类包路径和数据源
• 配置两个PlatformTransactionManager Bean，分别绑定对应的实体管理工厂
• 创建两个Repository接口（比如RegionAPersonRepository和RegionBPersonRepository），都继承JpaRepository<Person, Long>，通过@Repository+@Qualifier绑定到对应的实体管理工厂

示例代码片段：

// 数据源配置示例
@Configuration
public class DataSourceConfig {
    @Bean("regionADatasource")
    @Primary
    public DataSource regionADatasource() {
        // 配置region-a数据库连接信息
        HikariDataSource ds = new HikariDataSource();
        ds.setJdbcUrl("jdbc:postgresql://region-a-db:5432/db");
        ds.setUsername("user");
        ds.setPassword("pass");
        return ds;
    }

    @Bean("regionBDatasource")
    public DataSource regionBDatasource() {
        // 配置region-b数据库连接信息
        HikariDataSource ds = new HikariDataSource();
        ds.setJdbcUrl("jdbc:postgresql://region-b-db:5432/db");
        ds.setUsername("user");
        ds.setPassword("pass");
        return ds;
    }
}

二、实现分布式事务下的原子写入 #

跨两个独立数据库的写入属于分布式事务，本地事务管理器无法保证原子性，需要引入分布式事务框架：

1. 基于JTA实现：使用支持JTA的事务管理器（比如Atomikos），配置JtaTransactionManager统一管理两个数据源的事务，在Service层方法上添加@Transactional注解
2. 基于Seata实现：如果是微服务架构，推荐用Seata的@GlobalTransactional注解，通过TC（事务协调器）来保证两个库的写入要么同时成功，要么同时回滚

Service层示例：

@Service
public class PersonService {
    private final RegionAPersonRepository regionARepo;
    private final RegionBPersonRepository regionBRepo;

    public PersonService(RegionAPersonRepository regionARepo, RegionBPersonRepository regionBRepo) {
        this.regionARepo = regionARepo;
        this.regionBRepo = regionBRepo;
    }

    @GlobalTransactional // 用Seata的全局事务注解，或JTA的@Transactional
    public Person saveToBothRegions(Person person) {
        // 先写入region-a库
        Person savedA = regionARepo.save(person);
        // 再写入region-b库
        Person savedB = regionBRepo.save(person);
        return savedA; // 或返回统一结果
    }
}

三、避坑提示 #

• AbstractRoutingDataSource是做单请求路由到单个库，无法实现同时写入多库，不符合你的需求
• 分片中间件（比如ShardingSphere）是按规则拆分数据到不同库，不是复制同一份数据到多库，也不适用

内容的提问来源于stack exchange，提问作者java_doctor_101