Nonstop Progressive Marxism


    0.11.0 • Public • Published


    Run queries with node-postgres with less boilerplate. node-posgres is low level by design and rather verbose.

    This is a simple abstraction I've spun into a module after implementing something like this in most of my projects.


    npm install pg-query


    var query = require('pg-query');
    query('SELECT NOW()', function(err, rows, result) {
      assert.equal(rows, result.rows);

    Notice the callback is called with 3 parameters. First the error argument. Next the rows returned by the query. Finally the full result object which contains the same reference to the rows at result.rows

    more examples

    var query = require('pg-query');
    query.connectionParameters = 'postgres://user:password@host:5432/database';
    //accepts optional array of values as 2nd parameter for parameterized queries
    query('SELECT $1::text as name', ['brian'], function(err, rows, result) {

    If a callback is not passed, a promise is returned that will be resolved with [rows, result]

    var query = require('pg-query');
    query.connectionParameters = 'postgres://user:password@host:5432/database';
    //accepts optional array of values as 2nd parameter for parameterized queries
    var promise = query('SELECT $1::text as name', ['brian']);
    function onSuccess(rows, result) {
    function onError(error) {
    promise.spread(onSuccess, onError);

    query.first(text, [values], [cb])

    Often I find I'm getting a single row by ID. query.first allows for easy composition into async structures by returning the first row of the query or null if there are no rows. Let me show you...

    //this is the old way:
    var getUserById = function(id, cb) {
      query('SELECT * FROM "user" WHERE id = $1', [id], function(err, rows) {
        cb(err, rows ? rows[0] : null)
    //this is much easier
    var getUserById = function(id, cb) {
      query.first('SELECT * FROM "user" WHERE id = $1', id, cb)
    //or even this if you're crazy
    var getUserById = query.first.bind(query, 'SELECT * FROM "user" WHERE id = $1')

    query.first does a bit of argument type checking. If you pass an array as the values argument it is passed to the query unchanged. If you pass anything else truthy it is wrapped inside an array. This makes query.first easier to compose and use.


    pg-query is domain aware so your callback will always be called in the correct domain. If you're not using domains it will gracefully ignore them.

    pg-query uses whichever version of node-postgres you have installed in your project.

    pg-query uses pg.defaults and/or environment variables to connect.

    pg-query uses a random pooled database client for each query. If you're using a transaction (eg BEGIN/COMMIT) you need to check out a client from the pool manually. Repeat: DO NOT USE THIS FOR RUNNING TRANSACTIONS


    • Accept query object
    • Accept anything that responds to .toQuery (node-sql queries, etc)
    • Possibly add some way to configure connection parameters




    npm i pg-query

    DownloadsWeekly Downloads






    Last publish


    • brianc