數(shù)據(jù)庫(kù)征文】M4 Mac上把Spring Boot + MyBatis接到KingbaseES:一次帶事務(wù)和并發(fā)扣庫(kù)存的實(shí)測(cè))
承淵政道個(gè)人主頁(yè)??個(gè)人專(zhuān)欄:《C語(yǔ)言基礎(chǔ)語(yǔ)法知識(shí)》 《數(shù)據(jù)結(jié)構(gòu)與算法》 《C知識(shí)內(nèi)容》 《Linux系統(tǒng)知識(shí)》 《算法刷題指南》 《測(cè)評(píng)文章活動(dòng)推廣》 《大模型語(yǔ)言路線學(xué)習(xí)》 《MySQL數(shù)據(jù)庫(kù)學(xué)習(xí)》 《Python知識(shí)內(nèi)容》?逆境不吐心中苦,順境不忘來(lái)時(shí)路!? 博主簡(jiǎn)介:過(guò)去做數(shù)據(jù)庫(kù)適配時(shí),我最常見(jiàn)的做法是修改 JDBC 驅(qū)動(dòng)和連接地址,應(yīng)用能夠啟動(dòng)、SELECT 1可以執(zhí)行,就先把數(shù)據(jù)庫(kù)已適配打上勾.但真正把業(yè)務(wù)代碼跑起來(lái)后才會(huì)發(fā)現(xiàn),連接成功只是第一關(guān):主鍵生成方式、分頁(yè)語(yǔ)法、保留字、標(biāo)識(shí)符大小寫(xiě)、事務(wù)回滾以及并發(fā)更新,都可能在后面埋坑.這次我選擇了一個(gè)更貼近實(shí)際開(kāi)發(fā)的場(chǎng)景:在M4 Mac上運(yùn)行 KingbaseES,用Spring Boot 3.5 MyBatis 3.0實(shí)現(xiàn)商品庫(kù)存和訂單接口.除了完成基本CRUD,我還特意制造了庫(kù)存不足和并發(fā)搶購(gòu)兩個(gè)失敗場(chǎng)景,檢查訂單能否正確回滾,以及庫(kù)存會(huì)不會(huì)被扣成負(fù)數(shù).整個(gè)過(guò)程并非一路順利.我原以為M4需要通過(guò)AMD64模擬運(yùn)行數(shù)據(jù)庫(kù),實(shí)際卻在官網(wǎng)下載到了原生 aarch64 鏡像;按照平時(shí)的習(xí)慣啟動(dòng)容器,又在日志中碰到了權(quán)限告警;把MySQL DDL 直接搬過(guò)來(lái)時(shí),AUTO_INCREMENT、保留字和大小寫(xiě)問(wèn)題也接連出現(xiàn).本文記錄的就是這些真實(shí)操作、排查過(guò)程和解決辦法,希望能給正在進(jìn)行國(guó)產(chǎn)數(shù)據(jù)庫(kù)適配的Java開(kāi)發(fā)者提供一份可以直接參考的實(shí)測(cè)記錄.目錄一、我想驗(yàn)證的,不只是能不能連上二、環(huán)境準(zhǔn)備:M4可以直接跑ARM64版本三、第一次啟動(dòng)的小坑:容器能跑,不代表啟動(dòng)參數(shù)規(guī)范四、表結(jié)構(gòu)先適配:別把MySQL DDL原封不動(dòng)搬過(guò)來(lái)五、接入JDBC:我踩到的不是代碼坑,而是依賴(lài)來(lái)源坑六、數(shù)據(jù)源配置:驅(qū)動(dòng)類(lèi)和URL都要換,密碼不要落盤(pán)七、CRUD核心:主鍵回填、分頁(yè)和安全更新都走一遍八、事務(wù)實(shí)測(cè):先寫(xiě)訂單、后扣庫(kù)存,失敗時(shí)能否一起撤銷(xiāo)九、并發(fā)實(shí)測(cè):10個(gè)庫(kù)存,同時(shí)來(lái)兩個(gè)買(mǎi)7個(gè)十、三個(gè)遷移時(shí)很容易撞上的SQL坑1. AUTO_INCREMENT不能照搬2. order是保留字3. 未加引號(hào)的標(biāo)識(shí)符會(huì)折疊為小寫(xiě)十一、我是怎樣判斷這次適配真的完成了十二、回頭看:框架改動(dòng)不大,驗(yàn)證方式才是重點(diǎn)參考資料一、我想驗(yàn)證的,不只是能不能連上接觸一個(gè)不熟悉的數(shù)據(jù)庫(kù)時(shí),最容易寫(xiě)出的文章是建一個(gè) Spring Boot 項(xiàng)目,改四行數(shù)據(jù)源配置,執(zhí)行一條SELECT 1,然后宣布適配完成.但做過(guò)業(yè)務(wù)系統(tǒng)遷移的人都知道,連接成功只是起點(diǎn).真正容易出問(wèn)題的地方,往往藏在建表語(yǔ)法、主鍵回填、分頁(yè)、保留字、事務(wù)邊界和并發(fā)更新里.所以這次我沒(méi)有做Hello World,而是給自己定了一個(gè)更接近真實(shí)需求的小題目:用Spring Boot MyBatis寫(xiě)一套商品庫(kù)存和訂單接口,覆蓋商品的增刪改查,再驗(yàn)證兩個(gè)關(guān)鍵場(chǎng)景:訂單寫(xiě)入后扣庫(kù)存失敗,訂單能否跟著回滾;兩個(gè)請(qǐng)求同時(shí)搶庫(kù)存時(shí),會(huì)不會(huì)扣成負(fù)數(shù).我原先還有一個(gè)判斷:M4是ARM架構(gòu),可能只能拉 x86 鏡像后用模擬運(yùn)行.實(shí)際下載時(shí)這個(gè)判斷就被推翻了——金倉(cāng)官網(wǎng)已經(jīng)提供 aarch64 Docker 包.這個(gè)小插曲也提醒我,數(shù)據(jù)庫(kù)適配不要憑過(guò)去的印象寫(xiě)方案,先以當(dāng)前版本的官方介質(zhì)為準(zhǔn).二、環(huán)境準(zhǔn)備:M4可以直接跑ARM64版本我的本機(jī)環(huán)境如下.JDK選擇17,是因?yàn)楸疚氖褂肧pring Boot 3.5.x;Docker 服務(wù)端本身也是 arm64.Hardware: Apple M4 / arm64 macOS: 26.6 Docker Engine: 29.6.2 / linux-arm64 Java: OpenJDK 17.0.20 Maven: 3.9.16我從金倉(cāng)數(shù)據(jù)庫(kù)官網(wǎng)下載中心取得兩個(gè)文件KingbaseES_V009R001C010B0004_aarch64_Docker.tarKingbaseES_V009R001C010B0004_JDBC.zip這里要留意,Docker 數(shù)據(jù)庫(kù)鏡像和 JDBC 驅(qū)動(dòng)是兩個(gè)獨(dú)立下載項(xiàng),不能假設(shè)鏡像包里一定帶著應(yīng)用側(cè)要用的 jar.下載后我先校驗(yàn)了官網(wǎng)給出的 MD5,再加載鏡像md5 KingbaseES_V009R001C010B0004_aarch64_Docker.tar md5 KingbaseES_V009R001C010B0004_JDBC.zipdockerload-iKingbaseES_V009R001C010B0004_aarch64_Docker.tardockerimage inspect kingbase_v009r001c010b0004_single_arm:v1\--format{{.Os}}/{{.Architecture}}最后一條返回linux/arm64,不是通過(guò) Rosetta 或 QEMU 跑起來(lái)的 AMD64 鏡像.對(duì)M系列Mac 來(lái)說(shuō),少一層模擬,啟動(dòng)速度和資源占用都更踏實(shí).三、第一次啟動(dòng)的小坑:容器能跑,不代表啟動(dòng)參數(shù)規(guī)范我第一次照著常見(jiàn)數(shù)據(jù)庫(kù)容器的方式啟動(dòng),沒(méi)有加--privileged.數(shù)據(jù)庫(kù)最終雖然起來(lái)了,日志中卻出現(xiàn)sudo: pam_open_session: Permission denied這類(lèi)告警很容易被數(shù)據(jù)庫(kù)已經(jīng)能連接掩蓋.我回看官方 Docker 安裝手冊(cè),重新按容器運(yùn)行要求創(chuàng)建,并把宿主機(jī) 54321 映射到容器 54321dockerrun-d\--namekes-v9-dev\--privileged\-p54321:54321\-eDB_MODEpg\-eDB_USERsystem\-eDB_PASSWORD初始化強(qiáng)密碼\-eNEED_STARTyes\-v本機(jī)數(shù)據(jù)目錄:/home/kingbase/userdata\kingbase_v009r001c010b0004_single_arm:v1DB_MODEpg表示這次按 PG 兼容模式驗(yàn)證.掛載目錄不要隨便指向臨時(shí)路徑,否則刪容器后測(cè)試數(shù)據(jù)也一起沒(méi)了.口令也不要寫(xiě)進(jìn) Git、文章附件或鏡像層,本文后面的應(yīng)用配置統(tǒng)一從環(huán)境變量讀取.重新啟動(dòng)后,日志出現(xiàn)server started.我又進(jìn)入容器核對(duì)架構(gòu)和客戶(hù)端版本,結(jié)果分別是aarch64與ksql (KingbaseES) V009R001C010.接著創(chuàng)建獨(dú)立業(yè)務(wù)用戶(hù)和數(shù)據(jù)庫(kù).開(kāi)發(fā)項(xiàng)目不要長(zhǎng)期拿初始化管理員賬號(hào)直連,哪怕只是本機(jī)演示也應(yīng)把這個(gè)習(xí)慣保留下來(lái).CREATEUSERorder_appWITHPASSWORD業(yè)務(wù)賬號(hào)強(qiáng)密碼;CREATEDATABASEorder_demo OWNER order_app;四、表結(jié)構(gòu)先適配:別把MySQL DDL原封不動(dòng)搬過(guò)來(lái)示例只有兩張表product_stock保存可用庫(kù)存,purchase_order保存訂單.主鍵使用標(biāo)準(zhǔn)的 identity 寫(xiě)法,庫(kù)存和數(shù)量則用CHECK保住數(shù)據(jù)底線.CREATETABLEproduct_stock(idBIGINTGENERATEDBYDEFAULTASIDENTITYPRIMARYKEY,skuVARCHAR(64)NOTNULLUNIQUE,product_nameVARCHAR(128)NOTNULL,available_stockINTEGERNOTNULLCHECK(available_stock0),versionINTEGERNOTNULLDEFAULT0,updated_atTIMESTAMPNOTNULLDEFAULTCURRENT_TIMESTAMP);CREATETABLEpurchase_order(idBIGINTGENERATEDBYDEFAULTASIDENTITYPRIMARYKEY,order_noVARCHAR(64)NOTNULLUNIQUE,skuVARCHAR(64)NOTNULL,quantityINTEGERNOTNULLCHECK(quantity0),statusVARCHAR(32)NOTNULL,created_atTIMESTAMPNOTNULLDEFAULTCURRENT_TIMESTAMP);CREATEINDEXidx_purchase_order_skuONpurchase_order(sku);這里我沒(méi)有給兩表加外鍵.不是說(shuō)外鍵不能用,而是訂單記錄往往要保留業(yè)務(wù)發(fā)生時(shí)的 SKU,即使商品后來(lái)下架也不能讓歷史訂單消失.是否加外鍵應(yīng)該服從業(yè)務(wù)生命周期,不能為了讓演示看起來(lái)規(guī)范硬綁關(guān)系.version字段也要解釋清楚本文只是讓它隨庫(kù)存變化遞增,方便觀察更新次數(shù);真正防止超賣(mài)的是后面那條帶庫(kù)存條件的原子UPDATE,不能把這個(gè)字段包裝成已經(jīng)實(shí)現(xiàn)了完整的樂(lè)觀鎖.五、接入JDBC:我踩到的不是代碼坑,而是依賴(lài)來(lái)源坑按慣性在 Maven Central 中寫(xiě)一個(gè)驅(qū)動(dòng)坐標(biāo),很可能得到依賴(lài)不存在的錯(cuò)誤.我實(shí)際檢查時(shí),com.kingbase8:kingbase8:9.0.0并不能從 Maven Central 直接取得.解決方法是使用官網(wǎng)下載的 JDBC 包,并把 jar 安裝到本機(jī) Maven 倉(cāng)庫(kù);團(tuán)隊(duì)環(huán)境則更適合上傳到公司 Nexus/Artifactory,統(tǒng)一管理版本.mvn install:install-file\-Dfilekingbase8-9.0.0.jar\-DgroupIdcom.kingbase8\-DartifactIdkingbase8\-Dversion9.0.0\-Dpackagingjarpom.xml的核心依賴(lài)如下parentgroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-parent/artifactIdversion3.5.16/version/parentpropertiesjava.version17/java.versionmybatis-spring-boot.version3.0.5/mybatis-spring-boot.version/propertiesdependenciesdependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-web/artifactId/dependencydependencygroupIdorg.mybatis.spring.boot/groupIdartifactIdmybatis-spring-boot-starter/artifactIdversion${mybatis-spring-boot.version}/version/dependencydependencygroupIdcom.kingbase8/groupIdartifactIdkingbase8/artifactIdversion9.0.0/version/dependency/dependenciesSpring Boot 與 MyBatis 的版本并不是隨手拼的.Spring Boot 3.5.x 要求至少 Java 17;MyBatis Spring Boot Starter 3.0 系列覆蓋 Boot 3.23.5 和 Java 17 及以上.跨數(shù)據(jù)庫(kù)適配時(shí),先把框架版本關(guān)系固定住,能避免把框架兼容問(wèn)題誤診成數(shù)據(jù)庫(kù)問(wèn)題.六、數(shù)據(jù)源配置:驅(qū)動(dòng)類(lèi)和URL都要換,密碼不要落盤(pán)我的application.yml如下spring:datasource:url:jdbc:kingbase8://localhost:54321/order_demousername:${KES_USERNAME:order_app}password:${KES_PASSWORD}driver-class-name:com.kingbase8.Driverhikari:maximum-pool-size:5minimum-idle:1connection-timeout:3000connection-test-query:SELECT 1mybatis:mapper-locations:classpath:/mapper/*.xmlconfiguration:map-underscore-to-camel-case:truelog-impl:org.apache.ibatis.logging.stdout.StdOutImpl啟動(dòng)前用環(huán)境變量傳入口令exportKES_USERNAMEorder_appexportKES_PASSWORD業(yè)務(wù)賬號(hào)強(qiáng)密碼mvn spring-boot:run一開(kāi)始我只看見(jiàn) Spring Boot 正常啟動(dòng),還不敢把它算作驗(yàn)證通過(guò),于是專(zhuān)門(mén)寫(xiě)了一個(gè)/api/database/info接口,從當(dāng)前連接查詢(xún)數(shù)據(jù)庫(kù)版本、數(shù)據(jù)庫(kù)名和用戶(hù).實(shí)際返回的是KingbaseES V009R001C010、order_demo、order_app.這一步能排除“應(yīng)用其實(shí)連到了本機(jī)另一個(gè) PostgreSQL 實(shí)例”之類(lèi)的低級(jí)誤判.七、CRUD核心:主鍵回填、分頁(yè)和安全更新都走一遍MyBatis 接口沒(méi)有特殊注解技巧,真正決定適配性的仍然是SQL.新增商品使用 identity 主鍵,并讓驅(qū)動(dòng)把生成的 id 回填到 Java 對(duì)象insertidinsertuseGeneratedKeystruekeyPropertyidINSERT INTO product_stock (sku, product_name, available_stock) VALUES (#{sku}, #{productName}, #{availableStock})/insertselectidselectPageresultTypecom.example.kingbase.domain.ProductStockSELECT id, sku, product_name, available_stock, version, updated_at FROM product_stock ORDER BY id LIMIT #{limit} OFFSET #{offset}/selectupdateidadjustStockUPDATE product_stock SET available_stock available_stock #{delta}, version version 1, updated_at CURRENT_TIMESTAMP WHERE sku #{sku} AND available_stock #{delta} 0/updatedeleteiddeleteBySkuDELETE FROM product_stock WHERE sku #{sku}/delete我給 REST 層準(zhǔn)備了五組動(dòng)作新增商品、按 SKU 查詢(xún)、分頁(yè)查詢(xún)、調(diào)整庫(kù)存、刪除商品.page和size沒(méi)有直接原樣傳給 SQL頁(yè)碼最小為1,每頁(yè)限制在 1100 之間,再計(jì)算OFFSET.這不是金倉(cāng)獨(dú)有的要求,而是換庫(kù)時(shí)很容易順手遺漏的輸入邊界.# 新增curl-XPOST http://localhost:8080/api/products\-HContent-Type: application/json\-d{sku:KB-DEMO-001,productName:金倉(cāng)數(shù)據(jù)庫(kù)實(shí)戰(zhàn)課,initialStock:10}# 加 5 個(gè)庫(kù)存curl-XPATCH http://localhost:8080/api/products/KB-DEMO-001/stock\-HContent-Type: application/json\-d{delta:5}# 分頁(yè)、刪除curlhttp://localhost:8080/api/products?page1size20curl-XDELETE http://localhost:8080/api/products/KB-TEMP-001實(shí)測(cè)中,首條商品返回id1,說(shuō)明生成主鍵成功回填;庫(kù)存從10調(diào)到15,version從0變?yōu)?;臨時(shí)商品刪除返回 204,再查詢(xún)返回 404;重復(fù)SKU被統(tǒng)一映射為409,沒(méi)有把長(zhǎng)串?dāng)?shù)據(jù)庫(kù)異常直接甩給前端.到這里可以確認(rèn)普通 CRUD 沒(méi)問(wèn)題,但這仍然只完成了基本可用.對(duì)訂單系統(tǒng)來(lái)說(shuō),下面兩項(xiàng)才是我最關(guān)心的.八、事務(wù)實(shí)測(cè):先寫(xiě)訂單、后扣庫(kù)存,失敗時(shí)能否一起撤銷(xiāo)訂單創(chuàng)建故意采用先插入訂單,再扣庫(kù)存的順序.這樣只要扣減失敗,最容易暴露事務(wù)是否真的生效.核心服務(wù)代碼如下ServicepublicclassOrderService{privatefinalPurchaseOrderMapperpurchaseOrderMapper;privatefinalProductStockMapperproductStockMapper;publicOrderService(PurchaseOrderMapperpurchaseOrderMapper,ProductStockMapperproductStockMapper){this.purchaseOrderMapperpurchaseOrderMapper;this.productStockMapperproductStockMapper;}TransactionalpublicPurchaseOrdercreate(CreateOrderRequestrequest){PurchaseOrderordernewPurchaseOrder();order.setOrderNo(request.orderNo());order.setSku(request.sku());order.setQuantity(request.quantity());order.setStatus(CREATED);purchaseOrderMapper.insert(order);intaffectedproductStockMapper.deductStock(request.sku(),request.quantity());if(affected!1){thrownewAppException(HttpStatus.CONFLICT,庫(kù)存不足或商品不存在);}returnrequireByOrderNo(request.orderNo());}}扣庫(kù)存不是先查余額,再在Java里判斷,再更新.那種寫(xiě)法在并發(fā)下有時(shí)間窗口.我把條件放進(jìn)同一條 SQLupdateiddeductStockUPDATE product_stock SET available_stock available_stock - #{quantity}, version version 1, updated_at CURRENT_TIMESTAMP WHERE sku #{sku} AND available_stock #{quantity}/update先用數(shù)量 3 創(chuàng)建訂單,HTTP 返回 201,庫(kù)存由15變?yōu)?2.隨后用數(shù)量99創(chuàng)建ORD-ROLLBACK-001,接口返回 409.關(guān)鍵不是報(bào)錯(cuò)本身,而是我再進(jìn)數(shù)據(jù)庫(kù)查該訂單數(shù)量為 0,庫(kù)存仍是 12.說(shuō)明前面已經(jīng)執(zhí)行的INSERT確實(shí)隨運(yùn)行時(shí)異?；貪L了,Spring 事務(wù)管理器、JDBC 驅(qū)動(dòng)和 KingbaseES 的事務(wù)協(xié)作符合預(yù)期.這里還有一個(gè)常見(jiàn)誤區(qū)把Transactional加在同類(lèi)內(nèi)部調(diào)用的方法上,然后從另一個(gè)普通方法用this.create()調(diào)它.此時(shí)可能繞過(guò) Spring 代理,注解看著在,事務(wù)卻沒(méi)進(jìn)去.我的事務(wù)方法放在獨(dú)立Service的 public 方法上,由 Controller 經(jīng) Spring Bean 調(diào)用,避免了自調(diào)用失效.九、并發(fā)實(shí)測(cè):10個(gè)庫(kù)存,同時(shí)來(lái)兩個(gè)買(mǎi)7個(gè)事務(wù)回滾通過(guò)后,我把庫(kù)存重置為10,同時(shí)發(fā)出兩筆各買(mǎi)7個(gè)的請(qǐng)求.理論上最多只能成功一筆;如果代碼存在先查后改的競(jìng)態(tài),兩筆都可能讀到10,最終產(chǎn)生超賣(mài).curl-s-o/tmp/order-a.json-w%{http_code}\-XPOST http://localhost:8080/api/orders\-HContent-Type: application/json\-d{orderNo:ORD-CONCURRENT-A,sku:KB-DEMO-001,quantity:7}curl-s-o/tmp/order-b.json-w%{http_code}\-XPOST http://localhost:8080/api/orders\-HContent-Type: application/json\-d{orderNo:ORD-CONCURRENT-B,sku:KB-DEMO-001,quantity:7}wait實(shí)測(cè)結(jié)果是一筆 201、一筆 409;數(shù)據(jù)庫(kù)里只留下成功訂單,最終庫(kù)存為3,沒(méi)有負(fù)數(shù),也沒(méi)有失敗訂單殘留.具體是哪一筆成功并不重要,調(diào)度順序本來(lái)就不應(yīng)成為業(yè)務(wù)假設(shè).這個(gè)方案依賴(lài)數(shù)據(jù)庫(kù)對(duì)單條條件更新的原子性,簡(jiǎn)單而有效.如果業(yè)務(wù)還要處理多 SKU 鎖定、限時(shí)釋放、跨服務(wù)消息等場(chǎng)景,就需要繼續(xù)設(shè)計(jì)鎖順序、冪等鍵和補(bǔ)償機(jī)制;不能因?yàn)檫@個(gè)小測(cè)試通過(guò),就推導(dǎo)出所有并發(fā)問(wèn)題都解決了.十、三個(gè)遷移時(shí)很容易撞上的SQL坑為了確認(rèn)兼容邊界,我沒(méi)有只跑正確 SQL,還把幾段常見(jiàn)的遷移語(yǔ)句故意送進(jìn)數(shù)據(jù)庫(kù).1. AUTO_INCREMENT不能照搬在本次 PG 兼容模式下執(zhí)行CREATETABLEmysql_style(idBIGINTAUTO_INCREMENTPRIMARYKEY);數(shù)據(jù)庫(kù)在AUTO_INCREMENT附近報(bào)語(yǔ)法錯(cuò)誤.我的處理是改成GENERATED BY DEFAULT AS IDENTITY.如果從MySQL遷移,除了 DDL,還要全量檢查ON DUPLICATE KEY UPDATE、反引號(hào)、無(wú)符號(hào)類(lèi)型、時(shí)間函數(shù)等方言,不要等應(yīng)用上線后逐條踩雷.2. order是保留字CREATE TABLE order (...)直接報(bào)錯(cuò).可以寫(xiě)成帶雙引號(hào)的order,但之后每條 SQL 都得正確引用,維護(hù)成本很高.我最終把表名改成purchase_order.數(shù)據(jù)庫(kù)遷移里,改一個(gè)不沖突的業(yè)務(wù)名通常比到處加引號(hào)穩(wěn)妥.3. 未加引號(hào)的標(biāo)識(shí)符會(huì)折疊為小寫(xiě)我創(chuàng)建了CaseDemo,再執(zhí)行不帶引號(hào)的SELECT * FROM CaseDemo,實(shí)際查找的是casedemo,于是報(bào)關(guān)系不存在;寫(xiě)成SELECT * FROM CaseDemo才成功.解決辦法不是要求團(tuán)隊(duì)記住每一個(gè)大小寫(xiě),而是從建表開(kāi)始統(tǒng)一使用小寫(xiě)蛇形命名,MyBatis 再通過(guò)map-underscore-to-camel-case映射為 Java 駝峰字段.這三項(xiàng)都不是數(shù)據(jù)庫(kù)不好用,而是源庫(kù)方言和目標(biāo)庫(kù)規(guī)則不同.有效的遷移流程應(yīng)該先掃描對(duì)象和 SQL,再做兼容改寫(xiě),最后用回歸測(cè)試驗(yàn)證,而不是把連接串換完就上線.十一、我是怎樣判斷這次適配真的完成了最終我給自己列了一張比應(yīng)用啟動(dòng)成功更嚴(yán)格的驗(yàn)收表檢查項(xiàng)實(shí)測(cè)結(jié)果關(guān)注點(diǎn)原生架構(gòu)通過(guò)鏡像與容器均為 aarch64JDBC 連接通過(guò)返回 KingbaseES 版本、業(yè)務(wù)庫(kù)和業(yè)務(wù)用戶(hù)新增與主鍵回填通過(guò)identity 主鍵回填id1查詢(xún)與分頁(yè)通過(guò)LIMIT/OFFSET正常參數(shù)有限界更新與刪除通過(guò)庫(kù)存不降為負(fù)數(shù)刪除后返回 404唯一鍵異常通過(guò)重復(fù) SKU 轉(zhuǎn)為 409未暴露內(nèi)部異常本地事務(wù)通過(guò)扣庫(kù)存失敗后訂單行回滾并發(fā)扣減通過(guò)10 個(gè)庫(kù)存下兩筆 7 個(gè)僅一筆成功構(gòu)建與上下文測(cè)試通過(guò)1 個(gè)測(cè)試0 失敗、0 錯(cuò)誤項(xiàng)目最后執(zhí)行mvn test,Spring 上下文能夠用 JDK 17 啟動(dòng),測(cè)試結(jié)果為T(mén)ests run: 1, Failures: 0, Errors: 0,構(gòu)建成功.如果要把這個(gè)示例推進(jìn)到生產(chǎn),我還會(huì)補(bǔ)四件事第一,用 Flyway 或 Liquibase 管理版本化 DDL,而不是人工執(zhí)行腳本;第二,在測(cè)試環(huán)境用Testcontainers 或?qū)Ｓ?KingbaseES 實(shí)例跑集成測(cè)試;第三,根據(jù)壓測(cè)結(jié)果設(shè)置連接池、慢 SQL 與超時(shí),不照抄本文的5個(gè)連接;第四,梳理原系統(tǒng)的數(shù)據(jù)庫(kù)特有語(yǔ)法、存儲(chǔ)過(guò)程和類(lèi)型映射,建立可重復(fù)執(zhí)行的兼容清單.十二、回頭看:框架改動(dòng)不大,驗(yàn)證方式才是重點(diǎn)這次實(shí)測(cè)給我的結(jié)論很樸素對(duì)于采用常規(guī) SQL 的 Spring Boot MyBatis 項(xiàng)目,接入 KingbaseES 的 Java 代碼改動(dòng)并不大,主要變化集中在官方 JDBC 驅(qū)動(dòng)、連接 URL 和目標(biāo)庫(kù)方言.真正花時(shí)間的地方,不是把數(shù)據(jù)源配上,而是確認(rèn)那些以前默認(rèn)成立的事情在新數(shù)據(jù)庫(kù)上仍然成立.比如,M4 是否只能模擬 x86,要用鏡像架構(gòu)回答;主鍵能不能回填,要看新增接口返回;事務(wù)有沒(méi)有生效,要制造一次中途失敗再查庫(kù);并發(fā)會(huì)不會(huì)超賣(mài),要讓兩個(gè)請(qǐng)求真的撞在一起.把這些問(wèn)題變成可觀察、可復(fù)現(xiàn)的小實(shí)驗(yàn),數(shù)據(jù)庫(kù)適配才從我覺(jué)得可以變成我驗(yàn)證過(guò)可以.這也是我認(rèn)為國(guó)產(chǎn)數(shù)據(jù)庫(kù)適配最值得保留的方法少一點(diǎn)根據(jù)相似性做推斷,多一點(diǎn)以官方介質(zhì)、真實(shí) SQL 和失敗場(chǎng)景為證據(jù).連接成功值得高興,但敢于主動(dòng)制造失敗,才更接近生產(chǎn)可用.參考資料KingbaseES 官網(wǎng)下載中心KingbaseES Docker 安裝手冊(cè)KingbaseES JDBC 使用文檔Spring Boot 3.5 系統(tǒng)要求MyBatis Spring Boot Starter 官方說(shuō)明真正的勇者不是流淚的人,而是含淚奔跑的人!敬請(qǐng)期待下一篇文章內(nèi)容每日心靈雞湯: 當(dāng)你開(kāi)始害怕別人不開(kāi)心,其實(shí)是在保護(hù)過(guò)去的自己!當(dāng)你因?yàn)樗苏Z(yǔ)氣不好、態(tài)度不耐煩而下意識(shí)緊張、自我懷疑時(shí),這往往不是當(dāng)下的問(wèn)題,而是過(guò)去經(jīng)驗(yàn)留下的自動(dòng)反應(yīng).你曾經(jīng)為了在不穩(wěn)定的環(huán)境中保護(hù)自己,學(xué)會(huì)把別人的情緒當(dāng)作一種危險(xiǎn)信號(hào),于是通過(guò)討好、壓抑來(lái)?yè)Q取安全感.但這種機(jī)制只是童年時(shí)期的生存策略,并不適用于現(xiàn)在的你.真正重要的是意識(shí)到:當(dāng)下的你已經(jīng)有能力區(qū)分現(xiàn)實(shí)與過(guò)去,不需要再用過(guò)度敏感來(lái)保護(hù)自己.別人的情緒屬于他們自己,你不需要為此負(fù)責(zé);你只需要穩(wěn)住自己,專(zhuān)注于自己的感受與選擇. 【金倉(cāng)數(shù)據(jù)庫(kù)征文】M4 Mac上把Spring Boot + MyBatis接到KingbaseES:一次帶事務(wù)和并發(fā)扣庫(kù)存的實(shí)測(cè)
承淵政道個(gè)人主頁(yè)??個(gè)人專(zhuān)欄:《C語(yǔ)言基礎(chǔ)語(yǔ)法知識(shí)》 《數(shù)據(jù)結(jié)構(gòu)與算法》 《C知識(shí)內(nèi)容》 《Linux系統(tǒng)知識(shí)》 《算法刷題指南》 《測(cè)評(píng)文章活動(dòng)推廣》 《大模型語(yǔ)言路線學(xué)習(xí)》 《MySQL數(shù)據(jù)庫(kù)學(xué)習(xí)》 《Python知識(shí)內(nèi)容》?逆境不吐心中苦,順境不忘來(lái)時(shí)路!? 博主簡(jiǎn)介:過(guò)去做數(shù)據(jù)庫(kù)適配時(shí),我最常見(jiàn)的做法是修改 JDBC 驅(qū)動(dòng)和連接地址,應(yīng)用能夠啟動(dòng)、SELECT 1可以執(zhí)行,就先把數(shù)據(jù)庫(kù)已適配打上勾.但真正把業(yè)務(wù)代碼跑起來(lái)后才會(huì)發(fā)現(xiàn),連接成功只是第一關(guān):主鍵生成方式、分頁(yè)語(yǔ)法、保留字、標(biāo)識(shí)符大小寫(xiě)、事務(wù)回滾以及并發(fā)更新,都可能在后面埋坑.這次我選擇了一個(gè)更貼近實(shí)際開(kāi)發(fā)的場(chǎng)景:在M4 Mac上運(yùn)行 KingbaseES,用Spring Boot 3.5 MyBatis 3.0實(shí)現(xiàn)商品庫(kù)存和訂單接口.除了完成基本CRUD,我還特意制造了庫(kù)存不足和并發(fā)搶購(gòu)兩個(gè)失敗場(chǎng)景,檢查訂單能否正確回滾,以及庫(kù)存會(huì)不會(huì)被扣成負(fù)數(shù).整個(gè)過(guò)程并非一路順利.我原以為M4需要通過(guò)AMD64模擬運(yùn)行數(shù)據(jù)庫(kù),實(shí)際卻在官網(wǎng)下載到了原生 aarch64 鏡像;按照平時(shí)的習(xí)慣啟動(dòng)容器,又在日志中碰到了權(quán)限告警;把MySQL DDL 直接搬過(guò)來(lái)時(shí),AUTO_INCREMENT、保留字和大小寫(xiě)問(wèn)題也接連出現(xiàn).本文記錄的就是這些真實(shí)操作、排查過(guò)程和解決辦法,希望能給正在進(jìn)行國(guó)產(chǎn)數(shù)據(jù)庫(kù)適配的Java開(kāi)發(fā)者提供一份可以直接參考的實(shí)測(cè)記錄.目錄一、我想驗(yàn)證的,不只是能不能連上二、環(huán)境準(zhǔn)備:M4可以直接跑ARM64版本三、第一次啟動(dòng)的小坑:容器能跑,不代表啟動(dòng)參數(shù)規(guī)范四、表結(jié)構(gòu)先適配:別把MySQL DDL原封不動(dòng)搬過(guò)來(lái)五、接入JDBC:我踩到的不是代碼坑,而是依賴(lài)來(lái)源坑六、數(shù)據(jù)源配置:驅(qū)動(dòng)類(lèi)和URL都要換,密碼不要落盤(pán)七、CRUD核心:主鍵回填、分頁(yè)和安全更新都走一遍八、事務(wù)實(shí)測(cè):先寫(xiě)訂單、后扣庫(kù)存,失敗時(shí)能否一起撤銷(xiāo)九、并發(fā)實(shí)測(cè):10個(gè)庫(kù)存,同時(shí)來(lái)兩個(gè)買(mǎi)7個(gè)十、三個(gè)遷移時(shí)很容易撞上的SQL坑1. AUTO_INCREMENT不能照搬2. order是保留字3. 未加引號(hào)的標(biāo)識(shí)符會(huì)折疊為小寫(xiě)十一、我是怎樣判斷這次適配真的完成了十二、回頭看:框架改動(dòng)不大,驗(yàn)證方式才是重點(diǎn)參考資料一、我想驗(yàn)證的,不只是能不能連上接觸一個(gè)不熟悉的數(shù)據(jù)庫(kù)時(shí),最容易寫(xiě)出的文章是建一個(gè) Spring Boot 項(xiàng)目,改四行數(shù)據(jù)源配置,執(zhí)行一條SELECT 1,然后宣布適配完成.但做過(guò)業(yè)務(wù)系統(tǒng)遷移的人都知道,連接成功只是起點(diǎn).真正容易出問(wèn)題的地方,往往藏在建表語(yǔ)法、主鍵回填、分頁(yè)、保留字、事務(wù)邊界和并發(fā)更新里.所以這次我沒(méi)有做Hello World,而是給自己定了一個(gè)更接近真實(shí)需求的小題目:用Spring Boot MyBatis寫(xiě)一套商品庫(kù)存和訂單接口,覆蓋商品的增刪改查,再驗(yàn)證兩個(gè)關(guān)鍵場(chǎng)景:訂單寫(xiě)入后扣庫(kù)存失敗,訂單能否跟著回滾;兩個(gè)請(qǐng)求同時(shí)搶庫(kù)存時(shí),會(huì)不會(huì)扣成負(fù)數(shù).我原先還有一個(gè)判斷:M4是ARM架構(gòu),可能只能拉 x86 鏡像后用模擬運(yùn)行.實(shí)際下載時(shí)這個(gè)判斷就被推翻了——金倉(cāng)官網(wǎng)已經(jīng)提供 aarch64 Docker 包.這個(gè)小插曲也提醒我,數(shù)據(jù)庫(kù)適配不要憑過(guò)去的印象寫(xiě)方案,先以當(dāng)前版本的官方介質(zhì)為準(zhǔn).二、環(huán)境準(zhǔn)備:M4可以直接跑ARM64版本我的本機(jī)環(huán)境如下.JDK選擇17,是因?yàn)楸疚氖褂肧pring Boot 3.5.x;Docker 服務(wù)端本身也是 arm64.Hardware: Apple M4 / arm64 macOS: 26.6 Docker Engine: 29.6.2 / linux-arm64 Java: OpenJDK 17.0.20 Maven: 3.9.16我從金倉(cāng)數(shù)據(jù)庫(kù)官網(wǎng)下載中心取得兩個(gè)文件KingbaseES_V009R001C010B0004_aarch64_Docker.tarKingbaseES_V009R001C010B0004_JDBC.zip這里要留意,Docker 數(shù)據(jù)庫(kù)鏡像和 JDBC 驅(qū)動(dòng)是兩個(gè)獨(dú)立下載項(xiàng),不能假設(shè)鏡像包里一定帶著應(yīng)用側(cè)要用的 jar.下載后我先校驗(yàn)了官網(wǎng)給出的 MD5,再加載鏡像md5 KingbaseES_V009R001C010B0004_aarch64_Docker.tar md5 KingbaseES_V009R001C010B0004_JDBC.zipdockerload-iKingbaseES_V009R001C010B0004_aarch64_Docker.tardockerimage inspect kingbase_v009r001c010b0004_single_arm:v1\--format{{.Os}}/{{.Architecture}}最后一條返回linux/arm64,不是通過(guò) Rosetta 或 QEMU 跑起來(lái)的 AMD64 鏡像.對(duì)M系列Mac 來(lái)說(shuō),少一層模擬,啟動(dòng)速度和資源占用都更踏實(shí).三、第一次啟動(dòng)的小坑:容器能跑,不代表啟動(dòng)參數(shù)規(guī)范我第一次照著常見(jiàn)數(shù)據(jù)庫(kù)容器的方式啟動(dòng),沒(méi)有加--privileged.數(shù)據(jù)庫(kù)最終雖然起來(lái)了,日志中卻出現(xiàn)sudo: pam_open_session: Permission denied這類(lèi)告警很容易被數(shù)據(jù)庫(kù)已經(jīng)能連接掩蓋.我回看官方 Docker 安裝手冊(cè),重新按容器運(yùn)行要求創(chuàng)建,并把宿主機(jī) 54321 映射到容器 54321dockerrun-d\--namekes-v9-dev\--privileged\-p54321:54321\-eDB_MODEpg\-eDB_USERsystem\-eDB_PASSWORD初始化強(qiáng)密碼\-eNEED_STARTyes\-v本機(jī)數(shù)據(jù)目錄:/home/kingbase/userdata\kingbase_v009r001c010b0004_single_arm:v1DB_MODEpg表示這次按 PG 兼容模式驗(yàn)證.掛載目錄不要隨便指向臨時(shí)路徑,否則刪容器后測(cè)試數(shù)據(jù)也一起沒(méi)了.口令也不要寫(xiě)進(jìn) Git、文章附件或鏡像層,本文后面的應(yīng)用配置統(tǒng)一從環(huán)境變量讀取.重新啟動(dòng)后,日志出現(xiàn)server started.我又進(jìn)入容器核對(duì)架構(gòu)和客戶(hù)端版本,結(jié)果分別是aarch64與ksql (KingbaseES) V009R001C010.接著創(chuàng)建獨(dú)立業(yè)務(wù)用戶(hù)和數(shù)據(jù)庫(kù).開(kāi)發(fā)項(xiàng)目不要長(zhǎng)期拿初始化管理員賬號(hào)直連,哪怕只是本機(jī)演示也應(yīng)把這個(gè)習(xí)慣保留下來(lái).CREATEUSERorder_appWITHPASSWORD業(yè)務(wù)賬號(hào)強(qiáng)密碼;CREATEDATABASEorder_demo OWNER order_app;四、表結(jié)構(gòu)先適配:別把MySQL DDL原封不動(dòng)搬過(guò)來(lái)示例只有兩張表product_stock保存可用庫(kù)存,purchase_order保存訂單.主鍵使用標(biāo)準(zhǔn)的 identity 寫(xiě)法,庫(kù)存和數(shù)量則用CHECK保住數(shù)據(jù)底線.CREATETABLEproduct_stock(idBIGINTGENERATEDBYDEFAULTASIDENTITYPRIMARYKEY,skuVARCHAR(64)NOTNULLUNIQUE,product_nameVARCHAR(128)NOTNULL,available_stockINTEGERNOTNULLCHECK(available_stock0),versionINTEGERNOTNULLDEFAULT0,updated_atTIMESTAMPNOTNULLDEFAULTCURRENT_TIMESTAMP);CREATETABLEpurchase_order(idBIGINTGENERATEDBYDEFAULTASIDENTITYPRIMARYKEY,order_noVARCHAR(64)NOTNULLUNIQUE,skuVARCHAR(64)NOTNULL,quantityINTEGERNOTNULLCHECK(quantity0),statusVARCHAR(32)NOTNULL,created_atTIMESTAMPNOTNULLDEFAULTCURRENT_TIMESTAMP);CREATEINDEXidx_purchase_order_skuONpurchase_order(sku);這里我沒(méi)有給兩表加外鍵.不是說(shuō)外鍵不能用,而是訂單記錄往往要保留業(yè)務(wù)發(fā)生時(shí)的 SKU,即使商品后來(lái)下架也不能讓歷史訂單消失.是否加外鍵應(yīng)該服從業(yè)務(wù)生命周期,不能為了讓演示看起來(lái)規(guī)范硬綁關(guān)系.version字段也要解釋清楚本文只是讓它隨庫(kù)存變化遞增,方便觀察更新次數(shù);真正防止超賣(mài)的是后面那條帶庫(kù)存條件的原子UPDATE,不能把這個(gè)字段包裝成已經(jīng)實(shí)現(xiàn)了完整的樂(lè)觀鎖.五、接入JDBC:我踩到的不是代碼坑,而是依賴(lài)來(lái)源坑按慣性在 Maven Central 中寫(xiě)一個(gè)驅(qū)動(dòng)坐標(biāo),很可能得到依賴(lài)不存在的錯(cuò)誤.我實(shí)際檢查時(shí),com.kingbase8:kingbase8:9.0.0并不能從 Maven Central 直接取得.解決方法是使用官網(wǎng)下載的 JDBC 包,并把 jar 安裝到本機(jī) Maven 倉(cāng)庫(kù);團(tuán)隊(duì)環(huán)境則更適合上傳到公司 Nexus/Artifactory,統(tǒng)一管理版本.mvn install:install-file\-Dfilekingbase8-9.0.0.jar\-DgroupIdcom.kingbase8\-DartifactIdkingbase8\-Dversion9.0.0\-Dpackagingjarpom.xml的核心依賴(lài)如下parentgroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-parent/artifactIdversion3.5.16/version/parentpropertiesjava.version17/java.versionmybatis-spring-boot.version3.0.5/mybatis-spring-boot.version/propertiesdependenciesdependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-web/artifactId/dependencydependencygroupIdorg.mybatis.spring.boot/groupIdartifactIdmybatis-spring-boot-starter/artifactIdversion${mybatis-spring-boot.version}/version/dependencydependencygroupIdcom.kingbase8/groupIdartifactIdkingbase8/artifactIdversion9.0.0/version/dependency/dependenciesSpring Boot 與 MyBatis 的版本并不是隨手拼的.Spring Boot 3.5.x 要求至少 Java 17;MyBatis Spring Boot Starter 3.0 系列覆蓋 Boot 3.23.5 和 Java 17 及以上.跨數(shù)據(jù)庫(kù)適配時(shí),先把框架版本關(guān)系固定住,能避免把框架兼容問(wèn)題誤診成數(shù)據(jù)庫(kù)問(wèn)題.六、數(shù)據(jù)源配置:驅(qū)動(dòng)類(lèi)和URL都要換,密碼不要落盤(pán)我的application.yml如下spring:datasource:url:jdbc:kingbase8://localhost:54321/order_demousername:${KES_USERNAME:order_app}password:${KES_PASSWORD}driver-class-name:com.kingbase8.Driverhikari:maximum-pool-size:5minimum-idle:1connection-timeout:3000connection-test-query:SELECT 1mybatis:mapper-locations:classpath:/mapper/*.xmlconfiguration:map-underscore-to-camel-case:truelog-impl:org.apache.ibatis.logging.stdout.StdOutImpl啟動(dòng)前用環(huán)境變量傳入口令exportKES_USERNAMEorder_appexportKES_PASSWORD業(yè)務(wù)賬號(hào)強(qiáng)密碼mvn spring-boot:run一開(kāi)始我只看見(jiàn) Spring Boot 正常啟動(dòng),還不敢把它算作驗(yàn)證通過(guò),于是專(zhuān)門(mén)寫(xiě)了一個(gè)/api/database/info接口,從當(dāng)前連接查詢(xún)數(shù)據(jù)庫(kù)版本、數(shù)據(jù)庫(kù)名和用戶(hù).實(shí)際返回的是KingbaseES V009R001C010、order_demo、order_app.這一步能排除“應(yīng)用其實(shí)連到了本機(jī)另一個(gè) PostgreSQL 實(shí)例”之類(lèi)的低級(jí)誤判.七、CRUD核心:主鍵回填、分頁(yè)和安全更新都走一遍MyBatis 接口沒(méi)有特殊注解技巧,真正決定適配性的仍然是SQL.新增商品使用 identity 主鍵,并讓驅(qū)動(dòng)把生成的 id 回填到 Java 對(duì)象insertidinsertuseGeneratedKeystruekeyPropertyidINSERT INTO product_stock (sku, product_name, available_stock) VALUES (#{sku}, #{productName}, #{availableStock})/insertselectidselectPageresultTypecom.example.kingbase.domain.ProductStockSELECT id, sku, product_name, available_stock, version, updated_at FROM product_stock ORDER BY id LIMIT #{limit} OFFSET #{offset}/selectupdateidadjustStockUPDATE product_stock SET available_stock available_stock #{delta}, version version 1, updated_at CURRENT_TIMESTAMP WHERE sku #{sku} AND available_stock #{delta} 0/updatedeleteiddeleteBySkuDELETE FROM product_stock WHERE sku #{sku}/delete我給 REST 層準(zhǔn)備了五組動(dòng)作新增商品、按 SKU 查詢(xún)、分頁(yè)查詢(xún)、調(diào)整庫(kù)存、刪除商品.page和size沒(méi)有直接原樣傳給 SQL頁(yè)碼最小為1,每頁(yè)限制在 1100 之間,再計(jì)算OFFSET.這不是金倉(cāng)獨(dú)有的要求,而是換庫(kù)時(shí)很容易順手遺漏的輸入邊界.# 新增curl-XPOST http://localhost:8080/api/products\-HContent-Type: application/json\-d{sku:KB-DEMO-001,productName:金倉(cāng)數(shù)據(jù)庫(kù)實(shí)戰(zhàn)課,initialStock:10}# 加 5 個(gè)庫(kù)存curl-XPATCH http://localhost:8080/api/products/KB-DEMO-001/stock\-HContent-Type: application/json\-d{delta:5}# 分頁(yè)、刪除curlhttp://localhost:8080/api/products?page1size20curl-XDELETE http://localhost:8080/api/products/KB-TEMP-001實(shí)測(cè)中,首條商品返回id1,說(shuō)明生成主鍵成功回填;庫(kù)存從10調(diào)到15,version從0變?yōu)?;臨時(shí)商品刪除返回 204,再查詢(xún)返回 404;重復(fù)SKU被統(tǒng)一映射為409,沒(méi)有把長(zhǎng)串?dāng)?shù)據(jù)庫(kù)異常直接甩給前端.到這里可以確認(rèn)普通 CRUD 沒(méi)問(wèn)題,但這仍然只完成了基本可用.對(duì)訂單系統(tǒng)來(lái)說(shuō),下面兩項(xiàng)才是我最關(guān)心的.八、事務(wù)實(shí)測(cè):先寫(xiě)訂單、后扣庫(kù)存,失敗時(shí)能否一起撤銷(xiāo)訂單創(chuàng)建故意采用先插入訂單,再扣庫(kù)存的順序.這樣只要扣減失敗,最容易暴露事務(wù)是否真的生效.核心服務(wù)代碼如下ServicepublicclassOrderService{privatefinalPurchaseOrderMapperpurchaseOrderMapper;privatefinalProductStockMapperproductStockMapper;publicOrderService(PurchaseOrderMapperpurchaseOrderMapper,ProductStockMapperproductStockMapper){this.purchaseOrderMapperpurchaseOrderMapper;this.productStockMapperproductStockMapper;}TransactionalpublicPurchaseOrdercreate(CreateOrderRequestrequest){PurchaseOrderordernewPurchaseOrder();order.setOrderNo(request.orderNo());order.setSku(request.sku());order.setQuantity(request.quantity());order.setStatus(CREATED);purchaseOrderMapper.insert(order);intaffectedproductStockMapper.deductStock(request.sku(),request.quantity());if(affected!1){thrownewAppException(HttpStatus.CONFLICT,庫(kù)存不足或商品不存在);}returnrequireByOrderNo(request.orderNo());}}扣庫(kù)存不是先查余額,再在Java里判斷,再更新.那種寫(xiě)法在并發(fā)下有時(shí)間窗口.我把條件放進(jìn)同一條 SQLupdateiddeductStockUPDATE product_stock SET available_stock available_stock - #{quantity}, version version 1, updated_at CURRENT_TIMESTAMP WHERE sku #{sku} AND available_stock #{quantity}/update先用數(shù)量 3 創(chuàng)建訂單,HTTP 返回 201,庫(kù)存由15變?yōu)?2.隨后用數(shù)量99創(chuàng)建ORD-ROLLBACK-001,接口返回 409.關(guān)鍵不是報(bào)錯(cuò)本身,而是我再進(jìn)數(shù)據(jù)庫(kù)查該訂單數(shù)量為 0,庫(kù)存仍是 12.說(shuō)明前面已經(jīng)執(zhí)行的INSERT確實(shí)隨運(yùn)行時(shí)異?；貪L了,Spring 事務(wù)管理器、JDBC 驅(qū)動(dòng)和 KingbaseES 的事務(wù)協(xié)作符合預(yù)期.這里還有一個(gè)常見(jiàn)誤區(qū)把Transactional加在同類(lèi)內(nèi)部調(diào)用的方法上,然后從另一個(gè)普通方法用this.create()調(diào)它.此時(shí)可能繞過(guò) Spring 代理,注解看著在,事務(wù)卻沒(méi)進(jìn)去.我的事務(wù)方法放在獨(dú)立Service的 public 方法上,由 Controller 經(jīng) Spring Bean 調(diào)用,避免了自調(diào)用失效.九、并發(fā)實(shí)測(cè):10個(gè)庫(kù)存,同時(shí)來(lái)兩個(gè)買(mǎi)7個(gè)事務(wù)回滾通過(guò)后,我把庫(kù)存重置為10,同時(shí)發(fā)出兩筆各買(mǎi)7個(gè)的請(qǐng)求.理論上最多只能成功一筆;如果代碼存在先查后改的競(jìng)態(tài),兩筆都可能讀到10,最終產(chǎn)生超賣(mài).curl-s-o/tmp/order-a.json-w%{http_code}\-XPOST http://localhost:8080/api/orders\-HContent-Type: application/json\-d{orderNo:ORD-CONCURRENT-A,sku:KB-DEMO-001,quantity:7}curl-s-o/tmp/order-b.json-w%{http_code}\-XPOST http://localhost:8080/api/orders\-HContent-Type: application/json\-d{orderNo:ORD-CONCURRENT-B,sku:KB-DEMO-001,quantity:7}wait實(shí)測(cè)結(jié)果是一筆 201、一筆 409;數(shù)據(jù)庫(kù)里只留下成功訂單,最終庫(kù)存為3,沒(méi)有負(fù)數(shù),也沒(méi)有失敗訂單殘留.具體是哪一筆成功并不重要,調(diào)度順序本來(lái)就不應(yīng)成為業(yè)務(wù)假設(shè).這個(gè)方案依賴(lài)數(shù)據(jù)庫(kù)對(duì)單條條件更新的原子性,簡(jiǎn)單而有效.如果業(yè)務(wù)還要處理多 SKU 鎖定、限時(shí)釋放、跨服務(wù)消息等場(chǎng)景,就需要繼續(xù)設(shè)計(jì)鎖順序、冪等鍵和補(bǔ)償機(jī)制;不能因?yàn)檫@個(gè)小測(cè)試通過(guò),就推導(dǎo)出所有并發(fā)問(wèn)題都解決了.十、三個(gè)遷移時(shí)很容易撞上的SQL坑為了確認(rèn)兼容邊界,我沒(méi)有只跑正確 SQL,還把幾段常見(jiàn)的遷移語(yǔ)句故意送進(jìn)數(shù)據(jù)庫(kù).1. AUTO_INCREMENT不能照搬在本次 PG 兼容模式下執(zhí)行CREATETABLEmysql_style(idBIGINTAUTO_INCREMENTPRIMARYKEY);數(shù)據(jù)庫(kù)在AUTO_INCREMENT附近報(bào)語(yǔ)法錯(cuò)誤.我的處理是改成GENERATED BY DEFAULT AS IDENTITY.如果從MySQL遷移,除了 DDL,還要全量檢查ON DUPLICATE KEY UPDATE、反引號(hào)、無(wú)符號(hào)類(lèi)型、時(shí)間函數(shù)等方言,不要等應(yīng)用上線后逐條踩雷.2. order是保留字CREATE TABLE order (...)直接報(bào)錯(cuò).可以寫(xiě)成帶雙引號(hào)的order,但之后每條 SQL 都得正確引用,維護(hù)成本很高.我最終把表名改成purchase_order.數(shù)據(jù)庫(kù)遷移里,改一個(gè)不沖突的業(yè)務(wù)名通常比到處加引號(hào)穩(wěn)妥.3. 未加引號(hào)的標(biāo)識(shí)符會(huì)折疊為小寫(xiě)我創(chuàng)建了CaseDemo,再執(zhí)行不帶引號(hào)的SELECT * FROM CaseDemo,實(shí)際查找的是casedemo,于是報(bào)關(guān)系不存在;寫(xiě)成SELECT * FROM CaseDemo才成功.解決辦法不是要求團(tuán)隊(duì)記住每一個(gè)大小寫(xiě),而是從建表開(kāi)始統(tǒng)一使用小寫(xiě)蛇形命名,MyBatis 再通過(guò)map-underscore-to-camel-case映射為 Java 駝峰字段.這三項(xiàng)都不是數(shù)據(jù)庫(kù)不好用,而是源庫(kù)方言和目標(biāo)庫(kù)規(guī)則不同.有效的遷移流程應(yīng)該先掃描對(duì)象和 SQL,再做兼容改寫(xiě),最后用回歸測(cè)試驗(yàn)證,而不是把連接串換完就上線.十一、我是怎樣判斷這次適配真的完成了最終我給自己列了一張比應(yīng)用啟動(dòng)成功更嚴(yán)格的驗(yàn)收表檢查項(xiàng)實(shí)測(cè)結(jié)果關(guān)注點(diǎn)原生架構(gòu)通過(guò)鏡像與容器均為 aarch64JDBC 連接通過(guò)返回 KingbaseES 版本、業(yè)務(wù)庫(kù)和業(yè)務(wù)用戶(hù)新增與主鍵回填通過(guò)identity 主鍵回填id1查詢(xún)與分頁(yè)通過(guò)LIMIT/OFFSET正常參數(shù)有限界更新與刪除通過(guò)庫(kù)存不降為負(fù)數(shù)刪除后返回 404唯一鍵異常通過(guò)重復(fù) SKU 轉(zhuǎn)為 409未暴露內(nèi)部異常本地事務(wù)通過(guò)扣庫(kù)存失敗后訂單行回滾并發(fā)扣減通過(guò)10 個(gè)庫(kù)存下兩筆 7 個(gè)僅一筆成功構(gòu)建與上下文測(cè)試通過(guò)1 個(gè)測(cè)試0 失敗、0 錯(cuò)誤項(xiàng)目最后執(zhí)行mvn test,Spring 上下文能夠用 JDK 17 啟動(dòng),測(cè)試結(jié)果為T(mén)ests run: 1, Failures: 0, Errors: 0,構(gòu)建成功.如果要把這個(gè)示例推進(jìn)到生產(chǎn),我還會(huì)補(bǔ)四件事第一,用 Flyway 或 Liquibase 管理版本化 DDL,而不是人工執(zhí)行腳本;第二,在測(cè)試環(huán)境用Testcontainers 或?qū)Ｓ?KingbaseES 實(shí)例跑集成測(cè)試;第三,根據(jù)壓測(cè)結(jié)果設(shè)置連接池、慢 SQL 與超時(shí),不照抄本文的5個(gè)連接;第四,梳理原系統(tǒng)的數(shù)據(jù)庫(kù)特有語(yǔ)法、存儲(chǔ)過(guò)程和類(lèi)型映射,建立可重復(fù)執(zhí)行的兼容清單.十二、回頭看:框架改動(dòng)不大,驗(yàn)證方式才是重點(diǎn)這次實(shí)測(cè)給我的結(jié)論很樸素對(duì)于采用常規(guī) SQL 的 Spring Boot MyBatis 項(xiàng)目,接入 KingbaseES 的 Java 代碼改動(dòng)并不大,主要變化集中在官方 JDBC 驅(qū)動(dòng)、連接 URL 和目標(biāo)庫(kù)方言.真正花時(shí)間的地方,不是把數(shù)據(jù)源配上,而是確認(rèn)那些以前默認(rèn)成立的事情在新數(shù)據(jù)庫(kù)上仍然成立.比如,M4 是否只能模擬 x86,要用鏡像架構(gòu)回答;主鍵能不能回填,要看新增接口返回;事務(wù)有沒(méi)有生效,要制造一次中途失敗再查庫(kù);并發(fā)會(huì)不會(huì)超賣(mài),要讓兩個(gè)請(qǐng)求真的撞在一起.把這些問(wèn)題變成可觀察、可復(fù)現(xiàn)的小實(shí)驗(yàn),數(shù)據(jù)庫(kù)適配才從我覺(jué)得可以變成我驗(yàn)證過(guò)可以.這也是我認(rèn)為國(guó)產(chǎn)數(shù)據(jù)庫(kù)適配最值得保留的方法少一點(diǎn)根據(jù)相似性做推斷,多一點(diǎn)以官方介質(zhì)、真實(shí) SQL 和失敗場(chǎng)景為證據(jù).連接成功值得高興,但敢于主動(dòng)制造失敗,才更接近生產(chǎn)可用.參考資料KingbaseES 官網(wǎng)下載中心KingbaseES Docker 安裝手冊(cè)KingbaseES JDBC 使用文檔Spring Boot 3.5 系統(tǒng)要求MyBatis Spring Boot Starter 官方說(shuō)明真正的勇者不是流淚的人,而是含淚奔跑的人!敬請(qǐng)期待下一篇文章內(nèi)容每日心靈雞湯: 當(dāng)你開(kāi)始害怕別人不開(kāi)心,其實(shí)是在保護(hù)過(guò)去的自己!當(dāng)你因?yàn)樗苏Z(yǔ)氣不好、態(tài)度不耐煩而下意識(shí)緊張、自我懷疑時(shí),這往往不是當(dāng)下的問(wèn)題,而是過(guò)去經(jīng)驗(yàn)留下的自動(dòng)反應(yīng).你曾經(jīng)為了在不穩(wěn)定的環(huán)境中保護(hù)自己,學(xué)會(huì)把別人的情緒當(dāng)作一種危險(xiǎn)信號(hào),于是通過(guò)討好、壓抑來(lái)?yè)Q取安全感.但這種機(jī)制只是童年時(shí)期的生存策略,并不適用于現(xiàn)在的你.真正重要的是意識(shí)到:當(dāng)下的你已經(jīng)有能力區(qū)分現(xiàn)實(shí)與過(guò)去,不需要再用過(guò)度敏感來(lái)保護(hù)自己.別人的情緒屬于他們自己,你不需要為此負(fù)責(zé);你只需要穩(wěn)住自己,專(zhuān)注于自己的感受與選擇.