Class Pool

The RxJS wrapper for pg.Pool.

Example

// Create a connection pool
const pool = new Pool();
Copy

Example

// Open a connection and query the database

pool.connect()
     .pipe(
         concatMap((val) => {
             const { poolClient } = val;

             return poolClient
                 .query(sql`SELECT * FROM animals`)
                 .pipe(concatMap((result) => poolClient.release(result)));
             }
         )
     )
     .subscribe({
         next: (result) => {
             console.log(
                 `Query succeeded. Returned ${result.rows.length} rows.`
             );
             console.table(result.rows);
         },
         error: (err) => {
             console.error('Query failed:');
             console.error(err);
         }
     });
Copy

Example

// Open a connection and stream from the database
pool
     .connect()
     .pipe(
         concatMap((poolClient) => {
             const { poolClient } = val;

             poolClient
                 .stream(sql`SELECT * FROM get_animals()`)
                 // Use finalize to release the pool connection after all rows are returned
                 .pipe(finalize(() => poolClient.release().subscribe()))
         })
     )
     .subscribe({
         next: (val) => {
             // Emits individual rows
         },
         complete: () => {
             // Complete is called when all rows have been read
         }
     });
Copy

Example

// Close a connection pool
pool.end().subscribe()
Copy

Public Api