mongoose-transaction-decorator

A transactional decorator implementation is provided for Mongoose Transactions.

Quick Start

Install

$ npm install mongoose-transaction-decorator

Usage

import {
  set,
  plugin,
  Schema,
  model,
  connect,
  connection,
  Model,
} from 'mongoose';
import {
  transaction,
  TransactionConnection,
  Transactional,
} from 'mongoose-transaction-decorator';

interface IPerson {
  name: string;
  age: number;
  gender: boolean | null;
}

class Person {
  private readonly model: Model<IPerson>;

  constructor(model: Model<IPerson>) {
    this.model = model;
  }

  // Transactional Decorator that marks the method as a transaction method.
  @Transactional()
  async fun() {
    // do some transaction operations
    const doc = new this.model({ name: 'ZhangSan', age: 18 });
    await doc.save();
    await this.model.findOne();
    return;
  }
}

async function main() {
  set('debug', true);

  // use transaction plugin to support transactional decorator
  plugin(transaction);

  await connect('mongodb://localhost:27017/test?directConnection=true');

  // set connection
  new TransactionConnection().setConnection(connection);

  const personSchema = new Schema<IPerson>({
    name: { type: String, required: true },
    age: { type: Number, required: true },
    gender: { type: Boolean, default: null },
  });

  const personModel = model('persons', personSchema);

  const person = new Person(personModel);
  await person.fun();

  await connection.close();
}

main();

Code execution mongoose debug logs：

Mongoose: persons.insertOne({ name: 'ZhangSan', age: 18, gender: null, _id: new ObjectId("6240777d8d80087294f603da"), __v: 0}, { session: ClientSession("c68b32c60cdc4f4ea0b12255954100e3") })
Mongoose: persons.findOne({}, { session: ClientSession("c68b32c60cdc4f4ea0b12255954100e3"), projection: {}})

All operations within a method marked by a transaction decorator become the same transaction operation.

API

Plugin: transaction

The mongoose plugin to support transactional decorator.

Example:

import { plugin } from 'mongoose';
import { transaction } from 'mongoose-transaction-decorator';

plugin(transaction);

Class: TransactionConnection

This Class configures and saves Mongoose connections for use by the transaction decorator.

It is a Singleton Class.

new TransactionConnection()

Creates a new instance of TransactionConnection.

TransactionConnection.setConnection()

Name you mongoose connections.

Parameters：

• connection <mongoose.Connection> mongoose connection
• connectionName? <mongoose.Connection> Give a name for this connection, default name "default"

Example:

const transactionConnection = new TransactionConnection();

// set connection use default name "default"
transactionConnection.setConnection(connection);

// If you have multiple database connections
transactionConnection.setConnection(connection1, 'connection1');
transactionConnection.setConnection(connection2, 'connection2');

TransactionConnection.getConnection()

Get mongoose connection.

Parameters：

• connectionName <string> connection name

Decorator: Transactional

Decorator that marks the method as a transaction method.

note：

• Decorator normally use dependent the transaction plugin and TransactionConnection.setConnection().
• Decorator do not affect custom transactions that exist within the decorator method.

Parameters：

• connectionName? <string> connection name from you set by TransactionConnection.setConnection(), default name "default".

  The database connection used within the decorated method must be the same as the database connection corresponding to this connection name, otherwise a transaction exception may occur.

• options? <ClientSessionOptions> Optional settings for the transaction.

Example:

class Person {
  @Transactional('connectionName')
  async fun() {
    // do some database operations
    ...;
    return;
  }
}

License

MIT license.