java實(shí)現(xiàn)對(duì)兩張表進(jìn)行數(shù)據(jù)同步
java對(duì)sqlserver兩張表進(jìn)行同步操作
功能描述
在大型項(xiàng)目中，我們經(jīng)常會(huì)用到讀寫(xiě)分離技術(shù)來(lái)進(jìn)行優(yōu)化，及一張主表僅用來(lái)查詢(xún)。
一張附表用來(lái)增刪改。我們現(xiàn)在要做的功能就是當(dāng)附表數(shù)據(jù)變動(dòng)后，要同步更新主表。
這里使用的就是sqlserver的 MERGE 來(lái)進(jìn)行操作。該關(guān)鍵詞就是合并Update和insert使用，直接上代碼
sql語(yǔ)句
MERGE A表 AS a USING ( SELECT x.id, x.field_2, x.field_3,x.field_4 FROM B表 x )//查詢(xún)有用的字段 AS b ON a.id= b.id //匹配條件 WHEN MATCHED THEN //當(dāng)匹配時(shí)執(zhí)行update UPDATE SET a.field_2 = b.field_2 WHEN NOT MATCHED THEN //當(dāng)不匹配時(shí)執(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("準(zhǔn)備同步至Detail表");
logger.info("開(kāi)始");
String sql = "MERGE A表 AS a
USING ( SELECT x.id, x.field_2, x.field_3,x.field_4 FROM B表 x )//查詢(xún)有用的字段
AS b
ON a.id= b.id //匹配條件
WHEN MATCHED THEN //當(dāng)匹配時(shí)執(zhí)行update
UPDATE
SET a.field_2 = b.field_2
WHEN NOT MATCHED THEN //當(dāng)不匹配時(shí)執(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來(lái)執(zhí)行sql，但是對(duì)于這條語(yǔ)句會(huì)返回受影響行數(shù)，statement會(huì)拋異常。可以在sql語(yǔ)句上加上 就可。
SET NOCOUNT ON
我們這個(gè)功能寫(xiě)的是在這個(gè)增刪改的接口上標(biāo)注我們自定義的注解。然后就會(huì)在方法返回之后執(zhí)行我們這步同步的操作
MERGE目前適用于 Orcale sqlserver，不適用mysql，postgresql。不適用的可以采用觸發(fā)器來(lái)實(shí)現(xiàn)。
總結(jié)
以上為個(gè)人經(jīng)驗(yàn)，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。
相關(guān)文章
Spring Security JWT 鑒權(quán)鏈路完整解析
文章詳細(xì)解析了SpringSecurity結(jié)合JWT實(shí)現(xiàn)鑒權(quán)的完整鏈路,從配置到代碼,涵蓋了從請(qǐng)求到業(yè)務(wù)層的每一個(gè)步驟,包括配置資源服務(wù)器模式、JWT編解碼、自定義JWT服務(wù)、請(qǐng)求過(guò)濾和Controller層的注入機(jī)制2026-02-02
springboot項(xiàng)目開(kāi)啟https協(xié)議的項(xiàng)目實(shí)現(xiàn)
本文主要介紹了springboot項(xiàng)目開(kāi)啟https協(xié)議的項(xiàng)目實(shí)現(xiàn)，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2023-07-07
Spring Cache的基本使用與實(shí)現(xiàn)原理詳解
緩存是實(shí)際工作中非經(jīng)常常使用的一種提高性能的方法, 我們會(huì)在很多場(chǎng)景下來(lái)使用緩存。下面這篇文章主要給大家介紹了關(guān)于Spring Cache的基本使用與實(shí)現(xiàn)原理的相關(guān)資料，文中通過(guò)示例代碼介紹的非常詳細(xì)，需要的朋友可以參考下2018-05-05
SpringBoot中的定時(shí)調(diào)度服務(wù)使用詳解
本文介紹了SpringBoot中定時(shí)任務(wù)的實(shí)踐應(yīng)用,包括pom包配置、啟動(dòng)類(lèi)啟用定時(shí)調(diào)度、創(chuàng)建定時(shí)任務(wù)、異步執(zhí)行定時(shí)任務(wù)、自定義任務(wù)線(xiàn)程池等內(nèi)容,SpringBoot內(nèi)置的@Scheduled注解可以滿(mǎn)足大部分業(yè)務(wù)需求2026-04-04
Android Studio中ButterKnife插件的安裝與使用詳解
本篇文章主要介紹了Android Studio中ButterKnife插件的安裝與使用詳解，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2018-01-01
Netty如何設(shè)置為Https訪(fǎng)問(wèn)
這篇文章主要介紹了Netty如何設(shè)置為Https訪(fǎng)問(wèn)，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2022-06-06
相信使用過(guò)redis的，或者正在做分布式開(kāi)發(fā)的童鞋都知道redisson組件，它的功能很多，但我們使用最頻繁的應(yīng)該還是它的分布式鎖功能，少量的代碼，卻實(shí)現(xiàn)了加鎖、鎖續(xù)命(看門(mén)狗)、鎖訂閱、解鎖、鎖等待（自旋）等功能，我們來(lái)看看都是如何實(shí)現(xiàn)的2022-11-11
Spring中的ClassPathXmlApplicationContext源碼詳解
這篇文章主要介紹了Spring中的ClassPathXmlApplicationContext源碼詳解,ApplicationContext的主要實(shí)現(xiàn)類(lèi)是ClassPathXmlApplicationContext和FileSystemXmlApplicationContext,前者默認(rèn)從類(lèi)路徑加載配置文件,后者默認(rèn)從文件系統(tǒng)中裝載配置文件,需要的朋友可以參考下2023-12-12
Java高級(jí)-反射&動(dòng)態(tài)代理詳解
這篇文章主要介紹了Java高級(jí)-反射&動(dòng)態(tài)代理詳解,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2025-03-03
新手小白看過(guò)來(lái)學(xué)JAVA必過(guò)IO流File字節(jié)流字符流
這篇文章主要介紹了新手小白學(xué)JAVA到IO流File字節(jié)流字符流的重點(diǎn),對(duì)流不清楚的新手同學(xué)快進(jìn)來(lái)學(xué)習(xí)吧,大佬也可以進(jìn)來(lái)溫故一下2021-08-08