'use strict';
const parse = require('epf-parser');
const pgImport = require('epf-pg-importer');
const fs = require('fs');
const pg = require('pg');
var client = new pg.Client;
client.connect(err => {
if (err) throw err;
console.log('Starting import...');
fs.createReadStream('/Users/julian/Downloads/itunes20160518/application')
.pipe(parse((meta, rows) => {
pgImport({
client,
table: 'application',
meta
}, (err, copy) => {
if (err) throw err;
rows.pipe(copy).on('finish', () => {
console.log('Done! Disconnecting...');
client.on('drain', () => client.end());
});
});
}));
});