前言
最近在平臺推送業(yè)務的特性開發(fā)中幢痘,使用到了MySQL的"ON DUPLICATE KEY UPDATE"語法向拆,這里結合業(yè)務場景對該語法的使用做個介紹屠阻。
業(yè)務場景
使用平臺的推送服務之前炕贵,需要注冊設備于置。對于終端的注冊信息穿香,主要有玩家的user_id亭引、對應于某渠道的客戶端包名bundle_id、以及其它相關信息皮获,例如當前設備的推送類型(FCM焙蚓、APNS、Baidu等)洒宝、設備的device_token购公、依托于AWS推送服務的Amazon 資源名稱 (ARN)、 該終端設備對應玩家的默認語言雁歌、所在國家或地區(qū)等信息宏浩。
不同游戲終端設備的注冊邏輯大同小異,基本都是在玩家每次上線時由游戲服務器向平臺的推送服務發(fā)起注冊請求靠瞎。如果當前終端設備之前注冊過比庄,則只是更新該終端設備的其它注冊信息(例如推送渠道更改、設備device_token變更乏盐、默認語言佳窑、國家地區(qū)信息的變更等);假若當前終端設備未注冊過時父能,就寫入一條新的記錄神凑。
對于iOS、應用寶以外的渠道下載的客戶端(以bundle_id作區(qū)分)法竞,原則上玩家賬號(user_id)是可以互通的耙厚。也就是說强挫,某個游戲中同一個user_id可以對應多個bundle_id,一條終端設備的注冊記錄以自增id作為PRIMARY KEY薛躬,同時以(user_id, bundle_id)作為UNIQUE KEY俯渤,一組(user_id, bundle_id)可以唯一標識一條注冊記錄。
描述到這里就清楚了型宝,當前業(yè)務可以抽象描述為:
1.對于每條終端設備的注冊信息八匠,通過user_id和bundle_id確定其唯一性;
2.對于已注冊的終端設備趴酣,每次重新注冊時可能會更新其它字段(update)梨树;
3.對于未注冊的終端設備,則在注冊時新寫入一條注冊信息(insert)岖寞。
用法實踐
不太好的處理方法
對于上文所述的業(yè)務場景抡四,如果想要插入或更新一條注冊信息,使用功能單一的SQL語句仗谆,需要怎么做呢指巡?
1.執(zhí)行SELECT語句,條件為user_id & bundle_id隶垮,確認待插入的記錄是否已存在藻雪;
2.若記錄已存在,則執(zhí)行UPDATE語句更新相應記錄其它字段值狸吞,條件依然為user_id & bundle_id勉耀;
3.若記錄不存在,則執(zhí)行INSERT語句蹋偏,插入一條新記錄便斥。
可見前后需要執(zhí)行三條SQL語句才能完成一個功能,而且為確保業(yè)務邏輯的前后一致暖侨,可能還需要將此三條SQL組合成一個事務椭住,確保中間操作出現(xiàn)異吵缟可以回滾到最初狀態(tài)字逗,不會造成臟數(shù)據(jù)等問題。比較繁瑣宅广。
使用ON DUPLICATE KEY UPDATE
鑒于此葫掉,我們采用以下sql語句進行設備注冊時新設備注冊信息的寫入,或已有設備的信息更新:
INSERT INTO `table_name`(`section1`,`section2`,`section3`)VALUES(`value1`,`value2`,`value3`) ON DUPLICATE KEY UPDATE `section3`=`value3`
具體含義就是:
1.當字段section1跟狱、section2俭厚、section3對應的值value1、value2驶臊、value3不存在時挪挤,便插入一條新記錄叼丑,其中字段section1、section2扛门、section3對應的值分別為value1鸠信、value2、value3论寨,如果表中有其它未顯式指定的字段星立,則使用默認值;
2.當字段section1葬凳、section2绰垂、section3中包含PRIMARY KEY或UNIQUE KEY時,跳轉至UPDATE部分火焰,執(zhí)行部分字段的更新操作劲装。
相比之前的SELECT + UPDATE/INSERT方案,簡單明了昌简。
補充說明
1.該用法對mysql表的影響行數(shù)計算:
如果是作為一條新記錄寫入表中酱畅,則影響的行數(shù)為1;
如果是對原有記錄的更新操作江场,則受影響的行數(shù)為2(update操作完成后纺酸,主鍵id也會自增1);
2.與PRIMARY KEY或UNIQUE KEY的關系:
如果該條INSERT語句插入表中會導致當前PRIMRAY KEY或某個已存在的UNIQUE KEY出現(xiàn)重復值址否,那么就執(zhí)行后半段的UPDATE語句餐蔬,更新被命中記錄的部分字段值;
3.寫法的簡化:
若當前被插入的記錄共有5個字段佑附,其中section1和section2組成了表的聯(lián)合索引樊诺,則SQL語句時傳統(tǒng)寫法是:
INSERT INTO `table_name`(`section1`,`section2`,`section3`,`section4`,`section5`)VALUES('?','?','?','?','?') ON DUPLICATE KEY UPDATE `section3`='?',`section4`='?',`section5`='?';
本文所遇的真實業(yè)務場景,需要插入的字段不止5個音同,而是20+词爬,可想而知以現(xiàn)在的方式寫出來的sql語句,光變量需要填40個权均,有重復不說顿膨,還可能把變量順序填返,造成數(shù)據(jù)錯誤叽赊,又不好修復恋沃。
相對精簡的寫法,省去了后面update部分重復手寫的變量必指,使得傳入的參數(shù)數(shù)量少了一半囊咏,代碼可讀性提高,變量填錯位的可能性也會大大降低:
INSERT INTO `table_name`(`section1`,`section2`,`section3`,`section4`,`section5`)VALUES('?','?','?','?','?') ON DUPLICATE KEY UPDATE `section3`=VALUES(`section3`),`section4`=VALUES(`section4`),`section5`=VALUES(`section5`);
更進一步,對于一次性需要插入或更新多條記錄的場景梅割,該UPDATE部分的精簡寫法可以動態(tài)傳入要修改的值給對應某行霜第,這樣就可以滿足需要給不同的記錄插入不同的值的情況,例如:
INSERT INTO `table_name`(`section1`,`section2`,`section3`,`section4`,`section5`)VALUES('?','?','?','?','?'),('?','?','?','?','?') ON DUPLICATE KEY UPDATE `section3`=VALUES(`section3`),`section4`=VALUES(`section4`),`section5`=VALUES(`section5`);
4.特殊之處
該語法是MySQL特有的語法户辞,不是SQL的標準語法??
小結
使用前需要根據(jù)實際業(yè)務場景評估是否使用該語法庶诡,并且確認目標表的字段、主鍵咆课、聯(lián)合索引等符合(或改造后符合)該語法的使用場景末誓。
總體感覺該語法挺好用的,其它沒了书蚪。