Method select

packages/database-sqlite/src/index.ts:135–167

(options: DB.SelectDatabaseOptions)

  public async insert(options: DB.InsertDatabaseOptions) {
    await this.beginTransaction();

    const sql = `INSERT INTO ${options.table} (${options.columns.map(c => "'" + c + "'").join(",")}) VALUES (${options.values.join(",")})`;

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

      this.sqlite!.exec(sql);
      dbcnt = 1;
    } catch (error) {
      if (this.trace === true) {
        console.dir(error);
      }
      // eg "UNIQUE constraint failed" errors
      subrc = 4;
    }
    return {subrc, dbcnt};
  }

  // // https://www.sqlite.org/lang_select.html
  public async select(options: DB.SelectDatabaseOptions) {
    let res: undefined | QueryExecResult[] = undefined;

    options.select = options.select.replace(/ UP TO (\d+) ROWS(.*)/i, "$2 LIMIT $1");
    if (options.primaryKey) {
      options.select = options.select.replace(/ ORDER BY PRIMARY KEY/i, " ORDER BY " + options.primaryKey.join(", "));
    } else {
      options.select = options.select.replace(/ ORDER BY PRIMARY KEY/i, "");
    }
    options.select = options.select.replace(/ ASCENDING/ig, " ASC");
    options.select = options.select.replace(/ DESCENDING/ig, " DESC");
    options.select = options.select.replace(/~/g, ".");