Method rollback

packages/mongodb/src/MongoConnection.ts:441–447

(ctx: ClientSession, eventBroadcaster?: TransactionEventBroadcaster)

  }

  override async rollback(ctx: ClientSession, eventBroadcaster?: TransactionEventBroadcaster): Promise<void> {
    await this.ensureConnection();
    await eventBroadcaster?.dispatchEvent(EventType.beforeTransactionRollback, ctx);
    await ctx.abortTransaction();
    this.logQuery('db.rollback();');
    await eventBroadcaster?.dispatchEvent(EventType.afterTransactionRollback, ctx);
  }

  private async runQuery<T extends object, U extends QueryResult<T> | number = QueryResult<T>>(
    method: 'insertOne' | 'insertMany' | 'updateMany' | 'bulkUpdateMany' | 'deleteMany' | 'countDocuments',