Postgres client

Pg wrapper for inlada-transaction-service

Usage

Initialization

import { transactionProcessor } from 'inlada-transaction-processor';
import { pgClientFactoryFactory, registerInTransactionService } from 'inlada-postgresql-client';
import { PoolConfig } from 'pg';

const clientParams: PoolConfig = {
  host: process.env.DB_HOST,
  port: +(process.env.DB_PORT || 0),
  database: process.env.DB_NAME,
  user: process.env.DB_USER,
  password: process.env.DB_PASS,
  idleTimeoutMillis: 0,
};

export const pgClientFactory = pgClientFactoryFactory(clientParams);
registerInTransactionService(pgClientFactory, transactionProcessor);

Query

  const { rows } = await (await pgClientFactory(event.uid)).query(query, params);

query method is simply proxy to pg.Client.query