Method selectTable

src/drivers/sqlite-base-driver.ts:320–386

(
    schemaName: string,
    tableName: string,
    options: SelectFromTableOptions
  )

  }

  async selectTable(
    schemaName: string,
    tableName: string,
    options: SelectFromTableOptions
  ): Promise<{ data: DatabaseResultSet; schema: DatabaseTableSchema }> {
    const schema = await this.tableSchema(schemaName, tableName);
    let injectRowIdColumn = false;

    // If there is no primary key, we will fallback to rowid.
    // But we need to make sure there is no rowid column
    if (
      schema.pk.length === 0 &&
      !schema.withoutRowId &&
      !schema.columns.find((c) => c.name === "rowid") &&
      schema.type === "table"
    ) {
      // Inject the rowid column
      injectRowIdColumn = true;
      schema.columns = [
        {
          name: "rowid",
          type: "INTEGER",
          constraint: {
            primaryKey: true,
            autoIncrement: true,
          },
        },
        ...schema.columns,
      ];
      schema.pk = ["rowid"];
      schema.autoIncrement = true;
    }

    const whereRaw = options.whereRaw?.trim();

    const orderPart =
      options.orderBy && options.orderBy.length > 0
        ? options.orderBy
            .map((r) => `${this.escapeId(r.columnName)} ${r.by}`)
            .join(", ")
        : "";

    const sql = `SELECT ${injectRowIdColumn ? "rowid, " : ""}* FROM ${this.escapeId(schemaName)}.${this.escapeId(tableName)}${
      whereRaw ? ` WHERE ${whereRaw} ` : ""
    } ${orderPart ? ` ORDER BY ${orderPart}` : ""} LIMIT ${escapeSqlValue(options.limit)} OFFSET ${escapeSqlValue(options.offset)};`;

    let data = await this.query(sql);

    // If data does not have any header, we will inject the header from schema
    if (data.headers.length === 0 && data.rows.length === 0) {
      data = {
        ...data,
        headers: schema.columns.map((col) => {
          return {
            name: col.name,
            originalType: col.type,
            displayName: col.name,
          };