From 0994d6b7954cc4a63eb63b1fbcc1b5f3067429d2 Mon Sep 17 00:00:00 2001
From: Kesav Kumar Kolla <kesavkolla@gmail.com>
Date: Fri, 12 Dec 2014 13:53:09 +0530
Subject: [PATCH] Added test cases for issue #699

---
 package.json                            |  3 ++-
 test/integration/gh-issues/699-tests.js | 30 +++++++++++++++++++++++++
 2 files changed, 32 insertions(+), 1 deletion(-)
 create mode 100644 test/integration/gh-issues/699-tests.js

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();
+  });
+});