end.coffee

assert   = require 'assert'
fs       = require 'fs'
{ from } = require 'pg-copy-streams'
knex     = require './knex' # knex instance with dbConfig

module.exports = (done) ->
  runner = new knex.client.Runner(knex.client)
  runner.ensureConnection().then (conn) ->
    sql = "copy import_data from stdin with csv header null '' delimiter '|' encoding 'windows-1251';"
    sqlStream = conn.query(from(sql)).on 'end', ->
      knex.raw('select count(*) from import_data').then (results) ->
        runner.cleanupConnection()
        done(results.rows[0].count)

    fs.createReadStream('import_data.txt').pipe(sqlStream)

finish.coffee

assert   = require 'assert'
fs       = require 'fs'
{ from } = require 'pg-copy-streams'
knex     = require './knex' # knex instance with dbConfig

module.exports = (done) ->
  runner = new knex.client.Runner(knex.client)
  runner.ensureConnection().then (conn) ->
    sql = "copy import_data from stdin with csv header null '' delimiter '|' encoding 'windows-1251';"
    sqlStream = conn.query(from(sql))

    fs.createReadStream('import_data.txt').pipe(sqlStream).on 'finish', ->
      knex.raw('select count(*) from import_data').then (results) ->
        runner.cleanupConnection()
        done(results.rows[0].count)