功能描述
在大型项目中，我们经常会用到读写分离技术来进行优化，及一张主表仅用来查询。一张附表用来增删改。我们现在要做的功能就是当附表数据变动后，要同步更新主表。这里使用的就是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。不适用的可以采用触发器来实现。