archive-gh-me/node-postgres
1
0
Fork 0
mirror of https://github.com/brianc/node-postgres.git synced 2025-12-08 20:16:25 +00:00
Code Issues Projects Releases Wiki Activity

make copy related events to have same names in native and libpq clients

Browse Source
This commit is contained in:
anton 2012-11-06 16:55:43 +02:00 committed by brianc
parent 98286152dd
commit 8bcd40595d
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
lib/native/index.js
View File

@ -193,12 +193,12 @@ var clientBuilder = function(config) {
connection._pulseQueryQueue();
}
});
connection.on('_copyInResponse', function () {
connection.on('copyInResponse', function () {
//connection is ready to accept chunks
//start to send data from stream
connection._activeQuery.streamData(connection);
});
connection.on('_copyData', function (chunk) {
connection.on('copyData', function (chunk) {
//recieve chunk from connection
//move it to stream
connection._activeQuery.handleCopyFromChunk(chunk);

4
src/binding.cc
View File

@ -439,7 +439,7 @@ protected:
while ((result = PQgetResult(connection_))) {
if (PGRES_COPY_IN == PQresultStatus(result)) {
didHandleResult = false;
Emit("_copyInResponse");
Emit("copyInResponse");
PQclear(result);
break;
} else if (PGRES_COPY_OUT == PQresultStatus(result)) {
@ -483,7 +483,7 @@ protected:
if (copied > 0) {
Buffer * chunk = Buffer::New(buffer, copied);
Handle<Value> node_chunk = chunk->handle_;
Emit("_copyData", &node_chunk);
Emit("copyData", &node_chunk);
PQfreemem(buffer);
//result was not handled copmpletely
return false;