mongodb悲观锁怎么实现 - 问答

MongoDB是一个不支持悲观锁的数据库，它更倾向于使用乐观锁的方式来处理并发访问冲突。

乐观锁的实现方式如下：

在文档中添加一个版本号字段，例如version。
当读取文档时，将当前的版本号保存在客户端。
当更新文档时，将之前保存的版本号作为查询条件，并将新的版本号加1。
如果更新成功，表示没有冲突；如果更新失败，表示有冲突，需要处理冲突。

以下是一个使用MongoDB乐观锁的示例代码：

// 假设使用mongoose作为MongoDB的ODM（对象文档映射）工具
const mongoose = require('mongoose');

// 创建Schema
const bookSchema = new mongoose.Schema({
  name: String,
  author: String,
  version: { type: Number, default: 0 }
});

// 创建Model
const Book = mongoose.model('Book', bookSchema);

async function updateBook(bookId, newName) {
  // 查询文档
  const book = await Book.findById(bookId);

  // 更新文档
  book.name = newName;
  book.version += 1;

  // 使用版本号作为查询条件更新文档
  const result = await Book.updateOne({ _id: bookId, version: book.version - 1 }, { $set: { name: newName, version: book.version } });

  if (result.nModified === 0) {
    // 更新失败，处理冲突
    throw new Error('Update conflict');
  }
}

// 使用示例
updateBook('bookId', 'New Name').then(() => {
  console.log('Update success');
}).catch((error) => {
  console.error('Update failed:', error);
});

这种乐观锁的实现方式可以通过版本号来检测并发冲突，并在更新失败时处理冲突。

0 赞

0 踩