Function executeSingle

test/unit/persisters/common/databases.ts:95–146

(sql: string, bindings: any[])

  });

  const executeSingle = async (sql: string, bindings: any[]) => {
    const results = [];

    for await (const stmt of sqlite3.statements(db, sql)) {
      let columns;
      const wrappedBindings = bindings ? [bindings] : [[]];

      for (const binding of wrappedBindings) {
        binding.forEach((b, index, arr) => {
          if (typeof b == 'boolean') {
            arr[index] = b ? 1 : 0;
          }
        });
        sqlite3.reset(stmt);
        if (bindings) {
          sqlite3.bind_collection(stmt, binding);
        }
        const rows = [];

        while ((await sqlite3.step(stmt)) === SQLite.SQLITE_ROW) {
          const row = sqlite3.row(stmt);
          rows.push(row);
        }

        columns = columns ?? sqlite3.column_names(stmt);
        if (columns.length) {
          results.push({columns, rows});
        }
      }
      if (bindings) {
        break;
      }
    }
    const rows: any[] = [];
    for (const resultRows of results) {
      for (const row of resultRows.rows) {
        const outRow: any = {};
        resultRows.columns.forEach((key, index) => (outRow[key] = row[index]));
        rows.push(outRow);
      }
    }
    const result = {
      insertId: sqlite3.last_insert_id(db),
      rowsAffected: sqlite3.changes(db),
      rows: {
        _array: rows,
        length: rows.length,
        item: (index: number) => rows[index],
      },
    };
    return result;
  };
  const _acquireExecuteLock = (callback: any) => {
    return statementMutex.runExclusive(callback);
  };