yujunjun/knex
1
0
Fork 0
mirror of https://github.com/knex/knex.git synced 2025-11-05 04:09:41 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #851 from tgriesser/issue-849

Browse Source 
Issue 849
This commit is contained in:
Tim Griesser 2015-06-01 08:03:54 -04:00
commit c60b525e50
2 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
lib/dialects/postgres/index.js
View File

@ -108,9 +108,13 @@ assign(Client_PG.prototype, {
PGQueryStream = process.browser ? undefined : require('pg-query-stream'); PGQueryStream = process.browser ? undefined : require('pg-query-stream');
var sql = obj.sql = this.positionBindings(obj.sql); var sql = obj.sql = this.positionBindings(obj.sql);
return new Promise(function (resolver, rejecter) { return new Promise(function (resolver, rejecter) {
var queryStream = connection.query(new PGQueryStream(sql, obj.bindings, options));
// 'error' is not propagated by .pipe, but it breaks the pipe
queryStream.on('error', rejecter);
stream.on('error', rejecter); stream.on('error', rejecter);
// 'end' IS propagated by .pipe, by default
stream.on('end', resolver); stream.on('end', resolver);
connection.query(new PGQueryStream(sql, obj.bindings, options)).pipe(stream); queryStream.pipe(stream);
}); });
}, },

2
lib/runner.js
View File

@ -89,8 +89,6 @@ assign(Runner.prototype, {
if (hasHandler) throw err; if (hasHandler) throw err;
stream.emit('error', err); stream.emit('error', err);
} }
return sql;
}).then(function (sql) {
return runner.client.stream(runner.connection, sql, stream, options); return runner.client.stream(runner.connection, sql, stream, options);
}); });