Транзакция MongoDB4 проста и понятна 🌰

задняя часть MongoDB
Транзакция MongoDB4 проста и понятна 🌰

Введение

Транзакция mongodb реализуется сеансом клиента, подключенным к mongodb, и процесс выполнения транзакции примерно выглядит следующим образом. Установите сеанс и начните транзакцию с помощью startTransaction сеанса.Если серия транзакций завершена, то commitTransaction завершает операцию транзакции и завершает текущий сеанс транзакции; если какое-либо событие в серии транзакций терпит неудачу, тогда abortTransaction прерывает транзакцию и возвращает завершенные внутренние задачи. Вернитесь к состоянию до изменения и завершите текущий сеанс транзакции.

session = client.startSession(); 
session.startTransaction();
session.commitTransaction();
session.abortTransaction();
session.endSession();

описание сцены

В настоящее время есть два пользователя, пользователь A имеет баланс в 50 мягких сестринских монет, пользователь B имеет баланс в 10 мягких сестринских монет, а пользователь A переводит 10 в B. Передача настроек сцены очень безопасна, сеть также очень плавная. , нет хакерского перехвата, нет случайностей, перевод прошел успешно.В это время у пользователя А баланс 40, а у пользователя Б баланс 20. A чувствует себя в полной безопасности, а затем снова переводит деньги B. A забывает, сколько у него на балансе, и переводит 50 B, но в результате получается ошибка.

В случае отсутствия транзакции база данных операций выглядит следующим образом: 1. Баланс счета А равен -50, 2. Баланс счета Б увеличивается на 50. Когда баланса А недостаточно или после операции возникает сетевая ошибка учетной записи A успешно, сумма учетной записи B не может быть изменена правильно.

В случае транзакции, даже если возникает ошибка после манипулирования суммой счета A, транзакция откатит весь процесс перевода до модификации.

Загрузите mongodb4 и распакуйте его.

Woohoo. MongoDB.com/download-testing…

wget https://fastdl.mongodb.org/osx/mongodb-osx-ssl-x86_64-4.0.0.tgz

tar -xzvf mongodb-osx-ssl-x86_64-4.0.0.tgz

cd mongodb-osx-ssl-x86_64-4.0.0

!!! Транзакция применима только к набору реплик Replica Set, поэтому сначала создайте набор реплик mongodb

Запустить несколько экземпляров mongodb


// 创建data目录
mkdir -p data/1301
mkdir -p data/1302 
mkdir -p data/1303

// 起三个 mongodb 实例
./bin/mongod --replSet shard1  --dbpath=./data/1301 --port=1301
./bin/mongod --replSet shard1  --dbpath=./data/1302 --port=1302
./bin/mongod --replSet shard1  --dbpath=./data/1303 --port=1303


// 配置复制集
./bin/mongo --port 1301
rsconf = {_id: "shard1", members: [ { _id: 0, host: "127.0.0.1:1301" } ] }
rs.initiate( rsconf )
rs.add("127.0.0.1:1302")
rs.add("127.0.0.1:1303")


//查看是否是主节点
rs.isMaster() 

// 查看复制集状态
rs.status()

кодирование

mkdir mongodb4
cd mongodb4
npm init
npm i mongodb -S
vi app.js

//app.js

(async function()  {

  // 连接DB
  const { MongoClient } = require('mongodb');
  const uri = 'mongodb://localhost:1301/dbfour';
  const client = await MongoClient.connect(uri, { useNewUrlParser: true });

  const db = client.db();
  await db.dropDatabase();
  console.log('(1) 首先 删库 dbfour, then 跑路\n')

  // 插入两个账户并充值一些金额
  await db.collection('Account').insertMany([
    { name: 'A', balance: 50 },
    { name: 'B', balance: 10 }
  ]);
  console.log('(2) 执行 insertMany,  A 充值 50, B 充值 10\n')


  await transfer('A', 'B', 10); // 成功
  console.log('(3) 然后 A 给 B 转账 10\n')

  try {
    // 余额不足 转账失败
    console.log('(4) A 再次转账给 B 50\n')
    await transfer('A', 'B', 50);

  } catch (error) {
    //error.message; // "Insufficient funds: 40"
    console.log(error.message)
    console.log('\n(5) A 余额不够啊，所以这次转账操作不成功')
  }

  // 转账逻辑
  async function transfer(from, to, amount) {
    const session = client.startSession();
    session.startTransaction();
    try {
      const opts = { session, returnOriginal: false };
      const A = await db.collection('Account').
        findOneAndUpdate({ name: from }, { $inc: { balance: -amount } }, opts).
        then(res => res.value);
      if (A.balance < 0) {
        // 如果 A 的余额不足，转账失败 中止事务
        // `session.abortTransaction()` 会撤销上面的 `findOneAndUpdate()` 操作
        throw new Error('Insufficient funds: ' + (A.balance + amount));
      }

      const B = await db.collection('Account').
        findOneAndUpdate({ name: to }, { $inc: { balance: amount } }, opts).
        then(res => res.value);

      await session.commitTransaction();
      session.endSession();
      return { from: A, to: B };
    } catch (error) {
      // 如果错误发生，中止全部事务并回退到修改之前
      await session.abortTransaction();
      session.endSession();
      throw error; //使其调用者 catch error
    }
  }

})()

Посмотреть Результаты

node app.js

Категории