java實現(xiàn)對兩張表進行數(shù)據(jù)同步

更新時間：2026年05月17日 10:17:52 作者：臥槽甜

文章描述了在Java中使用SQL Server的MERGE語句實現(xiàn)兩張表的同步操作,適用于主表查詢、附表增刪改的場景,MERGE語句可以同時執(zhí)行插入和更新操作,適用于Oracle和SQL Server,但不適用于MySQL和PostgreSQL,可通過自定義注解實現(xiàn)接口調用后的同步操作

java對sqlserver兩張表進行同步操作

功能描述

在大型項目中，我們經常會用到讀寫分離技術來進行優(yōu)化，及一張主表僅用來查詢。

一張附表用來增刪改。我們現(xiàn)在要做的功能就是當附表數(shù)據(jù)變動后，要同步更新主表。

這里使用的就是sqlserver的 MERGE 來進行操作。該關鍵詞就是合并Update和insert使用，直接上代碼

sql語句

MERGE A表 AS a 
USING ( SELECT x.id, x.field_2, x.field_3,x.field_4 FROM B表 x )//查詢有用的字段
AS b
 ON a.id= b.id  //匹配條件
WHEN MATCHED THEN //當匹配時執(zhí)行update
UPDATE 
	SET a.field_2 = b.field_2
WHEN NOT MATCHED  THEN  //當不匹配時執(zhí)行insert
	INSERT (id,field_2,field_3,field_4) VALUES (b.id,b.field_2,b.field_3,b.field_4);

java代碼

@Aspect
@Component
public class LogAspect {

    private static final Logger logger = LoggerFactory.getLogger(LogAspect.class);


    @Pointcut("@annotation(com.xxx.annotation.MyAction)")//注解路徑
    public void annotationPointCat() {
    }


    @Resource
    JdbcTemplate jdbcTemplate;


    @AfterReturning(pointcut = "annotationPointCat()")
    public void afterRunning() {
        System.out.println("方法執(zhí)行完執(zhí)行...afterRunning");
        logger.info("Buffer更新成功");
        logger.info("準備同步至Detail表");
        logger.info("開始");
        String sql = "MERGE A表 AS a 
USING ( SELECT x.id, x.field_2, x.field_3,x.field_4 FROM B表 x )//查詢有用的字段
AS b
 ON a.id= b.id  //匹配條件
WHEN MATCHED THEN //當匹配時執(zhí)行update
UPDATE 
	SET a.field_2 = b.field_2
WHEN NOT MATCHED  THEN  //當不匹配時執(zhí)行insert
	INSERT (id,field_2,field_3,field_4) VALUES (b.id,b.field_2,b.field_3,b.field_4);";
        jdbcTemplate.execute(sql);
        logger.info("同步完成");
        System.out.println("finish");

    }

}

這里也可以使用 Statement來執(zhí)行sql，但是對于這條語句會返回受影響行數(shù)，statement會拋異常?？梢栽趕ql語句上加上就可。