java实现对两张表进行数据同步

 更新时间:2026年05月17日 10:17:52   作者:卧槽甜  
文章描述了在Java中使用SQL Server的MERGE语句实现两张表的同步操作,适用于主表查询、附表增删改的场景,MERGE语句可以同时执行插入和更新操作,适用于Oracle和SQL Server,但不适用于MySQL和PostgreSQL,可通过自定义注解实现接口调用后的同步操作

java对sqlserver两张表进行同步操作

功能描述

在大型项目中,我们经常会用到读写分离技术来进行优化,及一张主表仅用来查询。

一张附表用来增删改。我们现在要做的功能就是当附表数据变动后,要同步更新主表。

这里使用的就是sqlserver的 MERGE 来进行操作。该关键词就是合并Updateinsert使用,直接上代码

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。不适用的可以采用触发器来实现。

总结

以上为个人经验,希望能给大家一个参考,也希望大家多多支持脚本之家。

相关文章

  • Spring Security JWT 鉴权链路完整解析

    Spring Security JWT 鉴权链路完整解析

    文章详细解析了SpringSecurity结合JWT实现鉴权的完整链路,从配置到代码,涵盖了从请求到业务层的每一个步骤,包括配置资源服务器模式、JWT编解码、自定义JWT服务、请求过滤和Controller层的注入机制
    2026-02-02
  • springboot项目开启https协议的项目实现

    springboot项目开启https协议的项目实现

    本文主要介绍了springboot项目开启https协议的项目实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2023-07-07
  • Spring Cache的基本使用与实现原理详解

    Spring Cache的基本使用与实现原理详解

    缓存是实际工作中非经常常使用的一种提高性能的方法, 我们会在很多场景下来使用缓存。下面这篇文章主要给大家介绍了关于Spring Cache的基本使用与实现原理的相关资料,文中通过示例代码介绍的非常详细,需要的朋友可以参考下
    2018-05-05
  • SpringBoot中的定时调度服务使用详解

    SpringBoot中的定时调度服务使用详解

    本文介绍了SpringBoot中定时任务的实践应用,包括pom包配置、启动类启用定时调度、创建定时任务、异步执行定时任务、自定义任务线程池等内容,SpringBoot内置的@Scheduled注解可以满足大部分业务需求
    2026-04-04
  • Android Studio中ButterKnife插件的安装与使用详解

    Android Studio中ButterKnife插件的安装与使用详解

    本篇文章主要介绍了Android Studio中ButterKnife插件的安装与使用详解,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2018-01-01
  • Netty如何设置为Https访问

    Netty如何设置为Https访问

    这篇文章主要介绍了Netty如何设置为Https访问,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2022-06-06
  • 一文带你剖析Redisson分布式锁的原理

    一文带你剖析Redisson分布式锁的原理

    相信使用过redis的,或者正在做分布式开发的童鞋都知道redisson组件,它的功能很多,但我们使用最频繁的应该还是它的分布式锁功能,少量的代码,却实现了加锁、锁续命(看门狗)、锁订阅、解锁、锁等待(自旋)等功能,我们来看看都是如何实现的
    2022-11-11
  • Spring中的ClassPathXmlApplicationContext源码详解

    Spring中的ClassPathXmlApplicationContext源码详解

    这篇文章主要介绍了Spring中的ClassPathXmlApplicationContext源码详解,ApplicationContext的主要实现类是ClassPathXmlApplicationContext和FileSystemXmlApplicationContext,前者默认从类路径加载配置文件,后者默认从文件系统中装载配置文件,需要的朋友可以参考下
    2023-12-12
  • Java高级-反射&动态代理详解

    Java高级-反射&动态代理详解

    这篇文章主要介绍了Java高级-反射&动态代理详解,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
    2025-03-03
  • 新手小白看过来学JAVA必过IO流File字节流字符流

    新手小白看过来学JAVA必过IO流File字节流字符流

    这篇文章主要介绍了新手小白学JAVA到IO流File字节流字符流的重点,对流不清楚的新手同学快进来学习吧,大佬也可以进来温故一下
    2021-08-08

最新评论