@@ -37,7 +37,6 @@ var pg = require('pg');
|
|||||||
var copyFrom = require('pg-copy-streams').from;
|
var copyFrom = require('pg-copy-streams').from;
|
||||||
|
|
||||||
pg.connect(function(err, client, done) {
|
pg.connect(function(err, client, done) {
|
||||||
var text = 'COPY my_table FROM STDIN';
|
|
||||||
var stream = client.query(copyFrom('COPY my_table FROM STDIN'));
|
var stream = client.query(copyFrom('COPY my_table FROM STDIN'));
|
||||||
var fileStream = fs.createReadStream('some_file.tdv')
|
var fileStream = fs.createReadStream('some_file.tdv')
|
||||||
fileStream.pipe(stream);
|
fileStream.pipe(stream);
|
||||||
|
|||||||
Reference in New Issue
Block a user