如何在Spring JPA中执行MERGE原生SQL实现两表数据合并更新

原生MERGE语句的正确实现方式 #

你不需要为这个合并操作新建专用POJO，JpaRepository的第一个泛型参数直接填table1对应的JPA实体类即可，主键类型参数和你实体类的id字段类型保持一致即可。
要让MERGE语句正常执行，必须补充两个关键配置：

• 加@Modifying注解：标识该方法执行的是DML修改操作，而非查询操作，否则JPA会按查询逻辑解析语句直接报错
• 加事务支持：可以在方法上加@Transactional，也可以在调用该方法的业务Service层加事务注解，否则会抛出无事务的异常
  另外建议给@Modifying加上自动刷新、清空持久化上下文的参数，避免同一事务内后续查询拿到一级缓存里的旧数据。
  正确的代码写法如下：

import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.Modifying;
import org.springframework.data.jpa.repository.Query;
import org.springframework.transaction.annotation.Transactional;

// 第一个泛型填table1映射的实体类，比如Table1Entity，第二个参数填id字段的类型
public interface Table1Repository extends JpaRepository<Table1Entity, Long> {

    @Modifying(clearAutomatically = true, flushAutomatically = true)
    @Transactional
    // nativeQuery设为true表示执行原生SQL
    @Query(value = MERGE_TABLE2_WITH_TABLE1, nativeQuery = true)
    void executeMergeTableQuery();

    // 建议去掉SQL末尾的分号，避免部分数据库驱动解析报错
    String MERGE_TABLE2_WITH_TABLE1 = """
            MERGE table1 t1
            USING table2 t2
            ON (t1.id = t2.id AND t1.date = t2.date)
            WHEN MATCHED
            THEN UPDATE SET
                t1.col1 = t2.col1,
                t1.col2 = t2.col2
            """;
}

如果你一定要单独建MergeTables接口而非把方法放在Table1的Repository里，泛型同样传入Table1Entity即可，不需要新建额外类。

其他替代实现方案 #

方案1：JPQL批量更新（跨数据库兼容） #

如果不想绑定特定数据库的原生语法，可以用JPA支持的JPQL写更新逻辑，先查出table2的待同步数据，再批量匹配更新，适合数据量不大的场景：

1. 先在Table1Repository定义更新方法：

@Modifying(clearAutomatically = true, flushAutomatically = true)
@Transactional
@Query("UPDATE Table1Entity t1 SET t1.col1 = :col1, t1.col2 = :col2 WHERE t1.id = :id AND t1.date = :date")
int updateMatchedRecord(String col1, String col2, Long id, LocalDate date);

2. 在业务层写合并逻辑：

@Service
public class MergeService {
    private final Table1Repository table1Repository;
    private final Table2Repository table2Repository;

    // 构造函数注入省略

    @Transactional
    public void doMerge() {
        // 查出所有table2的记录，数据量大可以分批查询处理
        List<Table2Entity> table2Records = table2Repository.findAll();
        table2Records.forEach(t2 -> 
            table1Repository.updateMatchedRecord(t2.getCol1(), t2.getCol2(), t2.getId(), t2.getDate())
        );
    }
}

这个方案不依赖数据库特定语法，兼容性最好，缺点是数据量极大时会产生多条UPDATE语句，性能不如单条原生SQL。

方案2：关联更新语法（更简洁） #

你的需求只有匹配后更新的逻辑，不需要处理不匹配插入的场景，完全可以用更简单的关联UPDATE语法替代MERGE，执行效率和MERGE一致，写法更不容易出错，比如MySQL/PostgreSQL都支持的写法：

UPDATE table1 t1
INNER JOIN table2 t2 ON t1.id = t2.id AND t1.date = t2.date
SET t1.col1 = t2.col1, t1.col2 = t2.col2

这个SQL的执行配置和前面MERGE的写法完全一致，替换掉@Query里的SQL字符串即可。
如果后续需要新增「不匹配则插入table1」的逻辑，再换回MERGE语法即可。

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