Method beginTransaction

src/database-engines/sqlite-engine.ts:467–488

()

  }

  async beginTransaction(): Promise<Database> {
    try {
      const db = this.getConnection();
      if (!db) {
        return Promise.reject('Cannot connect to database')
      }

      return new Promise<Database>((resolve, reject) => {
        db.run('BEGIN TRANSACTION', (err) => {
          if (err) {
            reportError(`SQLite begin transaction error: ${err}`);
            reject(err);
            return;
          }
          resolve(db);
        });
      });
    } catch (err) {
      reportError(`SQLite begin transaction error: ${err}`);
      throw err;
    }
  }

  async commitTransaction(transaction: Database): Promise<void> {
    return new Promise<void>((resolve, reject) => {