關鍵字: MongoDB,Replace,forEach 近日接到一個開發需求,因業務調整,需要DBA協助,將MongoDB資料庫中某集合的進行替換。例如我們需要將集合A中B欄位中,有關《美好》的字元替換為 《非常美好》。個人感覺這個需求如果是在SQL Server 或MySQL 資料庫上處理是小菜 ...
關鍵字: MongoDB,Replace,forEach
近日接到一個開發需求,因業務調整,需要DBA協助,將MongoDB資料庫中某集合的進行替換。例如我們需要將集合A中B欄位中,有關《美好》的字元替換為 《非常美好》。個人感覺這個需求如果是在SQL Server 或MySQL 資料庫上處理是小菜一碟,如果是針對MongoDB數據,可能要費神了。
1.常見關係數據資料庫中的替換函數
在SQL Server資料庫中,我們用Replace函數來實現字元的替換。
語法
REPLACE ( ''string_replace1'' , ''string_replace2'' , ''string_replace3'' )
參數
''string_replace1''
待搜索的字元串表達式。string_replace1 可以是字元數據或二進位數據。
''string_replace2''
待查找的字元串表達式。string_replace2 可以是字元數據或二進位數據。
''string_replace3''
替換用的字元串表達式。string_replace3 可以是字元數據或二進位數據。
例如將 字元串 SQL Server 資料庫 中的 SQL Server 替換為 MongoDB。
實現語句如下:
在MySQL資料庫中語法類似。
2 在MongoDB中實現替換方法
很可惜,到目前為止還沒有找到類似SQL Server的替換函數,那麼我們怎麼去實現文檔中的數據替換呢?特別是集合中的文檔數量比較大時。
假設現在有用戶信息文檔,如下。註意其中有聯繫地址。
{ "_id" : ObjectId("5c77e5f85f53771b74bc87e0"), "username" : "hanmeimei", "email" : "123456@126.com", "tel" : 7891233, "addresses" : { "provice" : "山東省", "city" : "菏澤市鄄城縣曹集鎮", "stree" : "武狀元街道28號" } }, /* 2 createdAt:2019/2/28 下午9:45:28*/ { "_id" : ObjectId("5c77e5f85f53771b74bc87df"), "username" : "Lily", "email" : "123456@126.com", "tel" : 123455, "addresses" : [ { "provice" : "河南省", "city" : "鄭州市登封縣李集鎮", "stree" : "少林街道28號" } ] }, /* 3 createdAt:2019/2/28 下午9:45:28*/ { "_id" : ObjectId("5c77e5f85f53771b74bc87de"), "username" : "Lily", "email" : "123456@126.com", "tel" : 123455, "addresses" : { "provice" : "山東省", "city" : "菏澤市定陶縣曹集鎮", "stree" : "武狀元街道28號" } }, /* 4 createdAt:2019/2/28 下午9:45:28*/ { "_id" : ObjectId("5c77e5f85f53771b74bc87dd"), "username" : "jack", "email" : "123456@126.com", "tel" : 123455, "addresses" : { "provice" : "山東省", "city" : "菏澤市定陶縣", "stree" : "武狀元街道28號" } }
現在因為行政區域劃分,將 菏澤市定陶縣劃為定陶縣區。那麼怎麼進行批量修改呢? MongoDB中沒有Replace。
Update,也不好寫代碼。
最終.......我們還是找到了一個方法。
大家是先看看執行的代碼及實現的結果。
db.user.find({'addresses.city':{'$regex': /菏澤市定陶縣/ }}).forEach( function(item) { var tmp = String(item.addresses.city) tmp = tmp.replace('菏澤市定陶縣','菏澤市定陶縣區') if (tmp == null){ print(item.addresses.city) } item.addresses.city = tmp ; db.user.save(item); } );
執行後,再次查看數據,結果如下:
/* 1 createdAt:2019/2/28 下午9:45:28*/ { "_id" : ObjectId("5c77e5f85f53771b74bc87e0"), "username" : "hanmeimei", "email" : "123456@126.com", "tel" : 7891233, "addresses" : { "provice" : "山東省", "city" : "菏澤市鄄城縣曹集鎮", "stree" : "武狀元街道28號" } }, /* 2 createdAt:2019/2/28 下午9:45:28*/ { "_id" : ObjectId("5c77e5f85f53771b74bc87df"), "username" : "Lily", "email" : "123456@126.com", "tel" : 123455, "addresses" : [ { "provice" : "河南省", "city" : "鄭州市登封縣李集鎮", "stree" : "少林街道28號" } ] }, /* 3 createdAt:2019/2/28 下午9:45:28*/ { "_id" : ObjectId("5c77e5f85f53771b74bc87de"), "username" : "Lily", "email" : "123456@126.com", "tel" : 123455, "addresses" : { "provice" : "山東省", "city" : "菏澤市定陶縣區曹集鎮", "stree" : "武狀元街道28號" } }, /* 4 createdAt:2019/2/28 下午9:45:28*/ { "_id" : ObjectId("5c77e5f85f53771b74bc87dd"), "username" : "jack", "email" : "123456@126.com", "tel" : 123455, "addresses" : { "provice" : "山東省", "city" : "菏澤市定陶縣區", "stree" : "武狀元街道28號" } }
集合文檔中addresses.city中的’菏澤市定陶縣' 全部被 '菏澤市定陶縣區’ 替換,符合設計要求。
3.知識補充與回顧
(1)作為一個資料庫,MongoDB有一個很大的優勢—它使用js管理資料庫,所以也能夠使用js腳本進行複雜的管理。MongoDB自帶JavaScript shell,可在shell中使用命令行與MongoDB進行交互。shell是一個功能完備的JavaScript解釋器,可運行任意JavaScript程式。
mongodb 的shell是javascript實現的,如果直接使用js實現相應的功能則顯得很直觀和簡便。比如我們對一些數據進行 統計計算,除了使用mapreduce和aggreate框架之外,直接使用js也是很好的選擇。還有一些批處理,數據同步都可以使用js例如將集合中所有的文檔,列印出來-- db.collectionname.find().forEach(printjson)。
註意:在上面演示的MongoDB替換字元的腳本,都在mongodb shell 和 nosqlbooster 工具裡面驗證過,沒有問題。但是相同的代碼在mongodb shell中要註意格式要求,最好要符合Javascript 格式要求,否則,可能報錯,如:E QUERY [thread1] SyntaxError: missing ; before statement @(shell):1:138
(2)forEach:MongoDB資料庫使用游標返回find的執行結果。客戶端對游標的實現通常能夠對最終結果進行有效的控制。可以限制結果的數量,略過部分結果,根據任意鍵按任意順序的組合對結果進行各種排序,或者是執行其他一些強大的操作。游標有一個重要的迭代函數---cursor.forEach(回調函數),允許我們自定義回調函數來逐個處理每個單元.
(3)$regex :正則表達式是使用單個字元串來描述、匹配一系列符合某個句法規則的字元串。MongoDB 使用 $regex 操作符來設置匹配字元串的正則表達式。
(4)集合的save用法:根據主鍵_id 判斷,要保存的數據是否在集合中,在的話,則替換;不存在的話,在直接insert。
本文版權歸作者所有,未經作者同意不得轉載,謝謝配合!!!
本文版權歸作者所有,未經作者同意不得轉載,謝謝配合!!!