Async PostgreSQL client for Nim.

Implements the PostgreSQL wire protocol v3 with full support for the extended query protocol, connection pooling, SSL/TLS, and binary format optimization.

Async Backend

Select at compile time with -d:asyncBackend=asyncdispatch (default) or -d:asyncBackend=chronos.

Quick Start

import pkg/async_postgres

proc main() {.async.} =
  let conn = await connect("postgresql://myuser:mypass@127.0.0.1:5432/mydb")
  defer: await conn.close()
  
  # Insert with typed parameters
  let name = "Alice"
  let age = 30'i32
  let cr = await conn.exec(sql"INSERT INTO users (name, age) VALUES ({name}, {age})")
  echo "Inserted: ", cr.affectedRows
  
  # Query multiple rows
  let minAge = 25'i32
  let row = await conn.query(sql"SELECT id, name, age FROM users WHERE age > {minAge}")
  for r in row:
    echo r.getStr("name"), " age=", r.getInt("age")
  
  # Query a single value
  let count = await conn.queryValueOrDefault("SELECT count(*) FROM users", default = "0")
  echo "Total users: ", count

waitFor main()

Modules

• pg_connection — Connection management, DSN parsing, SSL, LISTEN/NOTIFY
• pg_client — Query execution, prepared statements, cursors, pipelines, transactions, COPY, zero-alloc macros (queryDirect/execDirect)
• pg_pool — Connection pooling with health checks and maintenance
• pg_pool_cluster — Read replica pool cluster with automatic query routing
• pg_types — Type conversions (toPgParam, row accessors, arrays, ranges, composites, enums)
• pg_protocol — Wire protocol encoding/decoding
• pg_auth — MD5 and SCRAM-SHA-256 authentication
• pg_largeobject — Large Object API for streaming binary data
• pg_advisory_lock — Advisory lock API (session/transaction, exclusive/shared)
• pg_replication — Logical replication streaming with pgoutput decoder
• async_backend — Async framework abstraction (asyncdispatch / chronos)