Function executeQueryRaw

packages/adapter-ppg/src/ppg.ts:217–238

* Executes a raw SQL query and returns the result set.

(executor: Statements, params: SqlQuery)

 * Executes a raw SQL query and returns the result set.
 */
async function executeQueryRaw(executor: Statements, params: SqlQuery): Promise<SqlResultSet> {
  const { sql, args } = params

  try {
    const convertedArgs = convertArgs(args, params.argTypes)
    const result = await executor.query(sql, ...convertedArgs)

    // Collect all rows - the driver adapter interface requires synchronous access
    const rows = await result.rows.collect()
    // Map columns with type information
    const columnNames = result.columns.map((col) => col.name)
    const columnTypes = result.columns.map((col) => fieldToColumnType(col.oid))

    return {
      columnNames,
      columnTypes,
      rows: rows.map((row) => row.values),
    }
  } catch (error) {
    throw convertDriverError(error)
  }
}

/**
 * Executes a raw SQL statement and returns the number of affected rows.