new PostgresClient(service, client, done)
Create Postgres client
Parameters:
| Name | Type | Description |
|---|---|---|
service |
Postgres | Postgres service instance |
client |
object | Connected PG client |
done |
function | Client termination function |
Properties:
| Name | Type | Default | Description |
|---|---|---|---|
client |
object | PG client | |
maxTransactionRetries |
number | 59 | Max number of transaction retries on serialization failures |
minTransactionDelay |
number | 100 | Minimum time to wait before retrying transaction |
maxTransactionDelay |
number | 1000 | Maximum time to wait before retrying transaction |
Methods
-
done()
-
Client termination
-
<async> query(sql [, params])
-
Run Postgres query
Date/Moment params are converted to strings in UTC timezone.Parameters:
Name Type Argument Description sqlstring SQL query string paramsArray <optional>
Query parameters Returns:
Resolves to query result- Type
- Promise
-
<async> transaction( [params], cb)
-
Run a transaction
Parameters:
Name Type Argument Description paramsobject <optional>
Properties
Name Type Argument Default Description namestring <optional>
Transaction name for debugging isolationstring <optional>
'serializable' Isolation level cbPostgresTransaction The transaction Returns:
Resolves to transaction result- Type
- Promise