mirror of
https://github.com/brianc/node-postgres.git
synced 2026-01-18 15:55:05 +00:00
parent
54964ecff7
commit
0ad6c9b71e
@ -18,7 +18,7 @@ const Client = (module.exports = function (config) {
|
||||
this._reading = false
|
||||
this._read = this._read.bind(this)
|
||||
|
||||
// allow custom type converstion to be passed in
|
||||
// allow custom type conversion to be passed in
|
||||
this._types = config.types || types
|
||||
|
||||
// allow config to specify returning results
|
||||
|
||||
@ -323,7 +323,7 @@ class Client extends EventEmitter {
|
||||
this._pulseQueryQueue()
|
||||
}
|
||||
|
||||
// if we receieve an error event or error message
|
||||
// if we receive an error event or error message
|
||||
// during the connection process we handle it here
|
||||
_handleErrorWhileConnecting(err) {
|
||||
if (this._connectionError) {
|
||||
|
||||
@ -19,7 +19,7 @@ const NativeQuery = (module.exports = function (config, values, callback) {
|
||||
// then emit them as they come in
|
||||
// without setting singleRowMode to true
|
||||
// this has almost no meaning because libpq
|
||||
// reads all rows into memory befor returning any
|
||||
// reads all rows into memory before returning any
|
||||
this._emitRowEvents = false
|
||||
this.on(
|
||||
'newListener',
|
||||
|
||||
@ -112,7 +112,7 @@ class Query extends EventEmitter {
|
||||
// if a named prepared statement is created with empty query text
|
||||
// the backend will send an emptyQuery message but *not* a command complete message
|
||||
// since we pipeline sync immediately after execute we don't need to do anything here
|
||||
// unless we have rows specified, in which case we did not pipeline the intial sync call
|
||||
// unless we have rows specified, in which case we did not pipeline the initial sync call
|
||||
handleEmptyQuery(connection) {
|
||||
if (this.rows) {
|
||||
connection.sync()
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user