File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed
Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -370,7 +370,7 @@ class Client extends EventEmitter {
370370 if ( completedQuery ) {
371371 completedQuery . handleReadyForQuery ( this . connection )
372372 }
373-
373+
374374 // Set next query as active if available
375375 if ( this . _pipelineQueue . length > 0 ) {
376376 this . _activeQuery = this . _pipelineQueue [ 0 ]
@@ -629,7 +629,7 @@ class Client extends EventEmitter {
629629 if ( typeof config === 'string' ) {
630630 throw new Error ( 'Simple query protocol is not allowed in pipeline mode. Use parameterized queries instead.' )
631631 }
632- if ( query . text && query . text . split ( ';' ) . filter ( s => s . trim ( ) ) . length > 1 ) {
632+ if ( query . text && query . text . split ( ';' ) . filter ( ( s ) => s . trim ( ) ) . length > 1 ) {
633633 throw new Error ( 'Multiple SQL commands in a single query are not allowed in pipeline mode.' )
634634 }
635635 }
@@ -803,12 +803,12 @@ class Client extends EventEmitter {
803803 while ( this . _queryQueue . length > 0 ) {
804804 const query = this . _queryQueue . shift ( )
805805 this . _pipelineQueue . push ( query )
806-
806+
807807 // Force extended query protocol for pipeline mode
808808 if ( ! query . requiresPreparation ( ) ) {
809809 query . queryMode = 'extended'
810810 }
811-
811+
812812 const queryError = query . submit ( this . connection )
813813 if ( queryError ) {
814814 process . nextTick ( ( ) => {
You can’t perform that action at this time.
0 commit comments