Method select

packages/database-pg/src/index.ts:171–211

(options: DB.SelectDatabaseOptions)

      return res;
    } catch (error) {
      await this.client!.query("ROLLBACK TO SAVEPOINT abap_stmt; RELEASE SAVEPOINT abap_stmt;");
      throw error;
    }
  }

  public async delete(options: DB.DeleteDatabaseOptions): Promise<{ subrc: number; dbcnt: number; }> {
    this.checkFatal();
    if (this.lazy === true && this.pool === undefined) {
      await this.connect();
    }

    let sql = `DELETE FROM ${options.table}`;
    if (options.where !== "") {
      sql += ` WHERE ${options.where}`;
    }

    let subrc = 0;
    let dbcnt = 0;
    try {
      if (this.trace === true) {
        console.log(sql);
      }

      const res = await this.modifying(sql);
      dbcnt = res?.rowCount || 0;
      if (dbcnt === 0) {
        subrc = 4;
      }
    } catch (error) {
      subrc = 4;
    }

    return {subrc, dbcnt};
  }

  public async update(options: DB.UpdateDatabaseOptions): Promise<{ subrc: number; dbcnt: number; }> {
    this.checkFatal();
    if (this.lazy === true && this.pool === undefined) {
      await this.connect();
    }

    const sql = `UPDATE ${options.table} SET ${options.set.join(", ")} WHERE ${options.where}`;

    let subrc = 0;