Method executeQuery

services/db-proxy/src/app-db-do.ts:95–120

(sqlText: string, params: unknown[], method: QueryMethod)

  }

  executeQuery(sqlText: string, params: unknown[], method: QueryMethod): QuerySuccessResponse {
    const cursor = this.ctx.storage.sql.exec(sqlText, ...params);

    switch (method) {
      case 'get': {
        const rows = cursor.toArray();
        if (rows.length === 0) {
          return { rows: [] };
        }
        return { rows: Object.values(rows[0] as Record<string, unknown>) };
      }
      case 'all': {
        const rows = cursor.toArray();
        const valueRows = rows.map(row => Object.values(row as Record<string, unknown>));
        return { rows: valueRows };
      }
      case 'run': {
        return { rows: [] };
      }
      case 'values': {
        const rows = cursor.toArray();
        const valueRows = rows.map(row => Object.values(row as Record<string, unknown>));
        return { rows: valueRows };
      }
    }
  }

  /**
   * Execute a batch of queries in a transaction