Как использовать транзакции в Mongoose?

Пользователь

hermina.hauck

от hermina.hauck , в категории: JavaScript , год назад

33 | 0

2 ответа

Пользователь

rudolph_senger

от rudolph_senger , год назад

@hermina.hauck

В Mongoose транзакции могут использоваться для группировки нескольких операций базы данных в единую транзакцию, которая должна быть либо полностью выполнена, либо откатиться при возникновении ошибки. Для использования транзакций в Mongoose следуйте приведенным ниже шагам:

Начните транзакцию с помощью метода startSession() и передайте ему объект опций.

1 2	const session = await mongoose.startSession(); session.startTransaction();

Выполните операции базы данных внутри транзакции. Например, создайте новый документ:

1 2	const doc = new Model({ name: 'John Doe' }); await doc.save({ session });

Если все операции прошли успешно, подтвердите транзакцию с помощью метода commitTransaction():

1	await session.commitTransaction();

Если при выполнении операций произошла ошибка, отмените транзакцию с помощью метода abortTransaction():

1	await session.abortTransaction();

Наконец, закройте сессию с помощью метода endSession():

1	session.endSession();

Полный пример использования транзакций в Mongoose может выглядеть следующим образом:

const session = await mongoose.startSession();
try {
  session.startTransaction();

  const doc = new Model({ name: 'John Doe' });
  await doc.save({ session });

  const doc2 = new Model({ name: 'Jane Doe' });
  await doc2.save({ session });

  await session.commitTransaction();
} catch (error) {
  await session.abortTransaction();
  console.error(error);
} finally {
  session.endSession();
}

В этом примере создаются два документа в базе данных MongoDB с использованием транзакций. Если все операции выполнены успешно, транзакция подтверждается. Если произошла ошибка, транзакция отменяется, и в консоль выводится ошибка. Наконец, сессия закрывается.

1 | 0

Пользователь

francis_schuster

от francis_schuster , 12 дней назад

@hermina.hauck

Вот пример использования множественных транзакций в модели Mongoose.(код для Node.js)

const mongoose = require('mongoose');
const uristring = 'mongodb://user:pass@host:port/dbname';
const ToDo = require("./models/todo");
const db = mongoose.createConnection(uristring);

try {
    const session = await db.startSession();
    session.startTransaction();

    // Create a new ToDo document
    const newTodo = new ToDo({
      task: 'Do homework',
      priority: 1
    });

    // Save the new ToDo document inside the transaction
    await newTodo.save({ session });

    // query all ToDo entries within transaction
    const todos = await ToDo.find({}).session(session);

    // perform other operations with the todos...

    await session.commitTransaction();
    session.endSession();

    db.close();
} catch (error) {
    console.error(error);
    await session.abortTransaction();
    session.endSession();
    db.close();
}

이 코드는 ToDo 모델 기반의 간단한 몇 가지 동작을 하나의 트랜잭션 안에 그룹핑 하는 예시입니다. 이를 통해 전체 트랜잭션이 성공적으로 완료되거나 실패할때 롤백되는 보장을 할 수 있습니다.

0 | 0

Как использовать транзакции в Mongoose?

2 ответа

Похожие обсуждения: