java实现对两张表进行数据同步
作者：卧槽甜
文章描述了在Java中使用SQL Server的MERGE语句实现两张表的同步操作,适用于主表查询、附表增删改的场景,MERGE语句可以同时执行插入和更新操作,适用于Oracle和SQL Server,但不适用于MySQL和PostgreSQL,可通过自定义注解实现接口调用后的同步操作
java对sqlserver两张表进行同步操作
功能描述
在大型项目中，我们经常会用到读写分离技术来进行优化，及一张主表仅用来查询。
一张附表用来增删改。我们现在要做的功能就是当附表数据变动后，要同步更新主表。
这里使用的就是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 //当匹配时执行update UPDATE SET a.field_2 = b.field_2 WHEN NOT MATCHED THEN //当不匹配时执行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("方法执行完执行...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 //当匹配时执行update
UPDATE
SET a.field_2 = b.field_2
WHEN NOT MATCHED THEN //当不匹配时执行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来执行sql，但是对于这条语句会返回受影响行数，statement会抛异常。可以在sql语句上加上 就可。
SET NOCOUNT ON
我们这个功能写的是在这个增删改的接口上标注我们自定义的注解。然后就会在方法返回之后执行我们这步同步的操作
MERGE目前适用于 Orcale sqlserver，不适用mysql，postgresql。不适用的可以采用触发器来实现。
总结
以上为个人经验，希望能给大家一个参考，也希望大家多多支持脚本之家。