diff --git a/package.json b/package.json
index e1d38479..65eaa314 100644
--- a/package.json
+++ b/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",
diff --git a/test/integration/gh-issues/699-tests.js b/test/integration/gh-issues/699-tests.js
new file mode 100644
index 00000000..d1d861a3
--- /dev/null
+++ b/test/integration/gh-issues/699-tests.js
@@ -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();
+  });
+});