Method executeQuery

packages/libsql/src/LibSqlDialect.ts:49–77

(compiledQuery: any)

  }

  async executeQuery<R>(compiledQuery: any): Promise<QueryResult<R>> {
    const { sql, parameters } = compiledQuery;
    const stmt = this.#db.prepare(sql);

    if (stmt.reader) {
      return {
        rows: stmt.all(parameters) as R[],
      };
    }

    const query = sql.trim().toLowerCase();

    /* v8 ignore next */
    if (
      query.startsWith('select') ||
      ((query.startsWith('insert into') || query.startsWith('update ')) && query.includes(' returning '))
    ) {
      return {
        rows: stmt.all(parameters) as R[],
      };
    }

    const { changes, lastInsertRowid } = stmt.run(parameters);
    return {
      numAffectedRows: changes as any,
      insertId: lastInsertRowid as any,
      rows: [],
    };
  }

  async *streamQuery<R>(compiledQuery: any): AsyncIterableIterator<QueryResult<R>> {
    const { sql, parameters } = compiledQuery;