Function constructListSQLQuery

packages/store-fs/src/sqlite.ts:418–460

({
  tableExpression,
  idKey,
  orderKey,
  columns,
  options,
  predicates,
}: {
  tableExpression: SQLTableName | string;
  idKey: string;
  orderKey: string;
  columns: string[];
  options: DatabaseQueryOptions<any>;
  predicates: DatabaseQueryPredicate[];
})

}

function constructListSQLQuery({
  tableExpression,
  idKey,
  orderKey,
  columns,
  options,
  predicates,
}: {
  tableExpression: SQLTableName | string;
  idKey: string;
  orderKey: string;
  columns: string[];
  options: DatabaseQueryOptions<any>;
  predicates: DatabaseQueryPredicate[];
}): { statement: string; args: any[] } {
  const args: any[] = [];

  const whereExpressions: string[] = [];

  for (const predicate of predicates) {
    whereExpressions.push(`${predicate[0]} ${predicate[1]} ?`);
    args.push(predicate[2]);
  }

  if (options.afterID) {
    whereExpressions.push(
      `${orderKey} > (SELECT ${orderKey} FROM ${tableExpression} WHERE ${idKey}=?)`,
    );
    args.push(options.afterID);
  }

  const whereClause =
    whereExpressions.length > 0
      ? `WHERE ${whereExpressions.join(" AND ")}`
      : "";
  const limitClause =
    options.limit === undefined ? "" : `LIMIT ${options.limit}`;

  const query = `SELECT ${columns.join(
    ",",
  )} FROM ${tableExpression} ${whereClause} ${limitClause}`;
  return { statement: query, args };
}

export function constructGetByIDSQLQuery<Column, ID>(
  tableName: SQLTableName,