Added test cases for issue #699

This commit is contained in:
Kesav Kumar Kolla 2014-12-12 13:53:09 +05:30
parent 81d125fe18
commit 0994d6b795
2 changed files with 32 additions and 1 deletions

View File

@ -25,7 +25,8 @@
"pg-connection-string": "0.1.3",
"pg-types": "1.6.0",
"pgpass": "0.0.3",
"semver": "^4.1.0"
"semver": "^4.1.0",
"pg-copy-streams":"~0.3.0"
},
"devDependencies": {
"async": "0.9.0",

View File

@ -0,0 +1,30 @@
var helper = require('../test-helper');
var assert = require('assert');
var copyFrom = require('pg-copy-streams').from;
helper.pg.connect(function (err, client, done) {
if (err) throw err;
var c = 'CREATE TEMP TABLE employee (id integer, fname varchar(400), lname varchar(400))';
client.query(c, function (err) {
if (err) throw err;
var stream = con.query(copyFrom("COPY employee FROM STDIN"));
stream.on('end', function () {
done();
helper.pg.end();
});
stream.on('error', function () {
throw new Error('Error in copy stream');
});
for (var i = 1; i <= 5; i++) {
var line = ['1\ttest', i, '\tuser', i, '\n'];
stream.write(line.join(''));
}
stream.end();
});
});