Postgresql + Highland

pg-highland.coffee

_ = require 'highland'
pg = require 'pg'
QueryStream = require 'pg-query-stream'

CONNECTION_STRING = "postgres://postgres:postgres@localhost/contacts"

rows = (stmt, params=[]) ->
  (push, next) ->
    pg.connect CONNECTION_STRING, (err, client, done) ->
      push err if (err)
      stream = client.query(new QueryStream(stmt, params))
      stream.on 'end', done
      next _(stream)
      push null, _.nil

_ rows 'select * from contact'
  .errors (err, push, next) -> console.log "ERR: #{err}"
  .filter (row) -> row.id > 14
  .toArray (arr) -> console.log arr