本篇文章為大家展示了mongoDB 4.0中怎么實(shí)現(xiàn)事務(wù)回滾,內(nèi)容簡明扼要并且容易理解,絕對能使你眼前一亮,通過這篇文章的詳細(xì)介紹希望你能有所收獲。
1.準(zhǔn)備工作
升級mongodb至4.0.0
$ brew upgrade mongodb
升級或安裝mongodb.js v3.1.0 以上
$ npm i mongodb --save-dev
坑
升級完上述后,db.js里連接mongo時,
會警告,讓你在connect的option里加一個字段
useNewUrlParser:true
,
這時如果有用戶驗(yàn)證,還需要在connect的option里再加一個字段
authSource:用戶所在的db,一般為admin
否則會報驗(yàn)證失敗,找不到用戶的錯誤,比如
const mongoClient = await MongoClient.connect(mongoClientUrl, { auth: { user: config.dbUserName, password: config.dbUserPassword, }, authSource:'admin', useNewUrlParser:true, });
2.將已有的數(shù)據(jù)庫改造成復(fù)制集
目前事務(wù)回滾只能在復(fù)制集上操作,單獨(dú)的mongodb server是不能操作事務(wù)的
關(guān)掉所有的mongod
在平時啟動mongod的命令后添加--replSet rs0,比如
$ mongod -dbpath ./db --port 27017 --replSet rs0
再開個shell,創(chuàng)一個不同端口的mongo實(shí)例,比如
$ mongod -dbpath ./db_repl --port 27018 --replSet rs0
連接27017的mongo實(shí)例,并設(shè)置
$ mongo $ rs.initiate() $ rs.add('localhost:27018');
完成
3.寫回滾代碼
在db.js里新增了一個方法
export const getSession = async function() { return await state.mongoClient.startSession(); };
每次在需要回滾的mongo代碼前調(diào)用這個方法拿到session,開始回滾的標(biāo)記
const session = await db.getSession(); session.startTransaction({ readConcern: {level: 'snapshot'}, writeConcern: {w: 'majority'}, });
在每次調(diào)用mongodb.js的方法操作數(shù)據(jù)庫時,都要帶上session,比如
db .collection(this.collecitonName) .insertOne(doc,{session});
在你處理錯誤并覺得需要回滾了,執(zhí)行
await session.abortTransaction();
在你覺得沒問題,一起正常結(jié)束時,執(zhí)行
await session.commitTransaction();
我的代碼里可能有一些封裝的代碼沒有放上去,導(dǎo)致不一定能理解。我只是舉個栗子去實(shí)現(xiàn),具體的代碼實(shí)現(xiàn)可以看參考鏈接1
4.總結(jié)
useNewUrlParser這個屬性會在url里識別驗(yàn)證用戶所需的db,未升級前是不需要指定的,升級到一定要指定,不管是在url后面,還是用authSource
事務(wù)回滾只能在復(fù)制集上操作,我猜測實(shí)現(xiàn)的原理可能是這樣:先記錄主節(jié)點(diǎn)的session,然后回滾的話,通過這個session查找副節(jié)點(diǎn)的數(shù)據(jù)快照,然后將這快照再應(yīng)用到主節(jié)點(diǎn)上,實(shí)現(xiàn)回滾。當(dāng)然,實(shí)際情況應(yīng)該相當(dāng)復(fù)雜,不然mongoDB也不會用3年時間來實(shí)現(xiàn)這個操作。
上述內(nèi)容就是mongoDB 4.0中怎么實(shí)現(xiàn)事務(wù)回滾,你們學(xué)到知識或技能了嗎?如果還想學(xué)到更多技能或者豐富自己的知識儲備,歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。
當(dāng)前名稱:mongoDB4.0中怎么實(shí)現(xiàn)事務(wù)回滾-創(chuàng)新互聯(lián)
網(wǎng)頁地址:http://chinadenli.net/article22/desejc.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供網(wǎng)站設(shè)計、網(wǎng)站策劃、定制開發(fā)、網(wǎng)站制作、虛擬主機(jī)、面包屑導(dǎo)航
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請盡快告知,我們將會在第一時間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時需注明來源: 創(chuàng)新互聯(lián)
猜你還喜歡下面的內(nèi)容