Method getRows

src/database-engines/sqlite-engine.ts:290–324

(table: string, columns: Column[], limit: number, offset: number, whereClause?: Record<string, any>)

  }

  async getRows(table: string, columns: Column[], limit: number, offset: number, whereClause?: Record<string, any>): Promise<QueryResponse | undefined> {
    try {
      const db = this.getConnection();
      if (!db) {
        return Promise.reject('Cannot connect to database')
      }

      const columnNames = columns.map(col => this.escapeIdentifier(col.name)).join(', ');
      let query = `SELECT ${columnNames} FROM ${this.escapeIdentifier(table)}`;
      const params: any[] = [];

      if (whereClause && Object.keys(whereClause).length > 0) {
        const { whereString, whereParams } = this.buildWhereClause(whereClause, columns);
        query += whereString.trim() ? ` WHERE ${whereString}` : '';
        params.push(...whereParams);
      }

      query += ` LIMIT ? OFFSET ?`;
      params.push(limit, offset);

      return new Promise<QueryResponse | undefined>((resolve, reject) => {
        db.all(query, params, (err, rows: any[]) => {
          if (err) {
            reportError(`SQLite get rows error: ${err}`);
            reject(err);
            return;
          }

          resolve({ rows, sql: query });
        });
      });
    } catch (err) {
      reportError(`SQLite get rows error: ${err}`);
    }
  }

  async getVersion(): Promise<string> {
    try {