Method query

lib/connectors/postgres-connector.ts:72–84

(queryDescription: QueryDescription)

  // deno-lint-ignore no-explicit-any
  async query(queryDescription: QueryDescription): Promise<any | any[]> {
    await this._makeConnection();

    const query = this._translator.translateToQuery(queryDescription);
    const response = await this._client.queryObject(query);
    const results = response.rows as Values[];

    if (queryDescription.type === "insert") {
      return results.length === 1 ? results[0] : results;
    }

    return results;
  }

  async transaction(queries: () => Promise<void>) {
    const transaction = this._client.createTransaction("transaction");