pgbouncer

Node.js wrapper for pgbouncer. All methods are asynchronous, using Q promises.

Basic usage

PgBouncer = require 'pgbouncer'
 
# create a new PgBouncer instance 
# pointing to the location of the pgbouncer.ini file 
pgb = new PgBouncer(configFile: '/etc/pgbouncer.ini')

Reading the INI file

pgb.read()
   .then (config) ->
 
  # [pgbouncer] section 
 
  # config.pgbouncer.listen_port:  5434 
  # config.pgbouncer.listen_addr:  '127.0.0.1' 
  # config.pgbouncer.auth_type:    'any'   
 
  # [databases] section 
 
  # config.databases.mydb1:  'postgresql://localhost/db1' 
  # config.databases.mydb2:  'postgresql://localhost/db2' 

Updating the INI file

config =
  pgbouncer:
    listen_port:  5434
    listen_addr:  '127.0.0.1'
    auth_type:    'any'  
  databases:
    mydb1:  'postgresql://localhost/db1'
    mydb2:  'postgresql://localhost/db2'
 
pgb.write(config)
   .then -> console.log('done')

Updating the database list only

If you don't need to change the [pgbouncer] section, you can also update the [databases] list only.

databases:
  mydb1:  'postgresql://localhost/db1'
  mydb2:  'postgresql://localhost/db2'
 
pgb.writeDatabases(databases)
   .then -> console.log('done')

Reloading the config

After updating the INI file, you need to manually trigger a reload command to update the live routing.

pbg.reload()
   .then -> console.log('done')

Getting the current routing status

You can get the current routing status from the pgbouncer show databases command:

pbg.status()
   .then (databases) ->
 
   # databases[0].name 
   # databases[0].host 
   # databases[0].port 
   # databases[0].database 
   # databases[0].force_user 
   # databases[0].pool_size 

Executing other commands

You can also execute any valid pgbouncer command:

pgb.execute('show users')
   .then (results) -> console.log(results.rows)

Please check pgbouncer documentation for a list of commands.