dbStreamer csv insert example

dbStreamerCsvInserter.js

var csv = require('csv'),
  dbStreamer = require('db-streamer'),
  fs = require('fs');

var input = fs.createReadStream(filename);
var parser = csv.parse({
  columns: true,
  relax: true
});

var sequelizeConfig = 'postgres://streamer:streamer@localhost:5432/streamer-test',
  inserterConfig = {
    dbConnString: sequelizeConfig,
    tableName: 'test_table',
    columns: ['a', 'b', 'c', 'createdAt', 'updatedAt']
  };

var inserter = dbStreamer.getInserter(inserterConfig);
inserter.connect(function(err) {

  parser.on('readable', function () {
    while(line = parser.read()) {
      inserter.push(line);
    }
  });
  
  parser.on('end', function (count) {
    inserter.setEndHandler(callback);
    inserter.end();
  });

  input.pipe(parser);

});