@@ -20,7 +20,7 @@ var NativeQuery = function(config, values, callback) {
20
20
this . text = config . text ;
21
21
this . values = config . values ;
22
22
this . callback = config . callback ;
23
-
23
+
24
24
this . _result = new Result ( ) ;
25
25
//normalize values
26
26
if ( this . values ) {
@@ -38,8 +38,9 @@ var p = NativeQuery.prototype;
38
38
var mapRowData = function ( row ) {
39
39
var result = { } ;
40
40
for ( var i = 0 , len = row . length ; i < len ; i ++ ) {
41
- var item = row [ i ] ;
42
- result [ item . name ] = item . value === null ? null : types . getTypeParser ( item . type , 'text' ) ( item . value ) ;
41
+ var item = row [ i ] ;
42
+ result [ item . name ] = item . value === null ? null :
43
+ types . getTypeParser ( item . type , 'text' ) ( item . value ) ;
43
44
}
44
45
return result ;
45
46
} ;
@@ -79,14 +80,14 @@ p.handleReadyForQuery = function(meta) {
79
80
} ;
80
81
p . streamData = function ( connection ) {
81
82
if ( this . stream ) this . stream . startStreamingToConnection ( connection ) ;
82
- else connection . sendCopyFail ( 'No source stream defined' ) ;
83
+ else connection . sendCopyFail ( 'No source stream defined' ) ;
83
84
} ;
84
85
p . handleCopyFromChunk = function ( chunk ) {
85
86
if ( this . stream ) {
86
87
this . stream . handleChunk ( chunk ) ;
87
88
}
88
89
//if there are no stream (for example when copy to query was sent by
89
- //query method instead of copyTo) error will be handled
90
- //on copyOutResponse event, so silently ignore this error here
90
+ //query method instead of copyTo) error will be handled
91
+ //on copyOutResponse event, so silently ignore this error here
91
92
} ;
92
93
module . exports = NativeQuery ;
0 commit comments