Merge branch 'kesavkolla-master'

Author: brianc

lib/client.js

@@ -313,7 +313,9 @@ Client.prototype.query = function(config, values, callback) {
   if(this.binary && !query.binary) {
     query.binary = true;
   }
-  query._result._getTypeParser = this._types.getTypeParser.bind(this._types);
+  if(query._result) {
+    query._result._getTypeParser = this._types.getTypeParser.bind(this._types);
+  }
 
   this.queryQueue.push(query);
   this._pulseQueryQueue();

package.json

@@ -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",

test/integration/gh-issues/699-tests.js

@@ -0,0 +1,27 @@
+var helper = require('../test-helper');
+var assert = require('assert');
+var copyFrom = require('pg-copy-streams').from;
+
+if(helper.args.native) return;
+
+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 = client.query(copyFrom("COPY employee FROM STDIN"));
+    stream.on('end', function () {
+      done();
+      helper.pg.end();
+    });
+
+    for (var i = 1; i <= 5; i++) {
+      var line = ['1\ttest', i, '\tuser', i, '\n'];
+      stream.write(line.join(''));
+    }
+    stream.end();
+  });
+});