@@ -10,25 +10,25 @@ suite.test('pipelining property can be set and retrieved', (cb) => {
1010
1111 // Initially false
1212 helper . assert . equal ( client . pipelining , false )
13-
13+
1414 client . connect ( ( err ) => {
1515 if ( err ) return cb ( err )
16-
16+
1717 // Can be set to true after connection
1818 client . pipelining = true
1919 helper . assert . equal ( client . pipelining , true )
20-
20+
2121 // Can be set back to false
2222 client . pipelining = false
2323 helper . assert . equal ( client . pipelining , false )
24-
24+
2525 client . end ( cb )
2626 } )
2727} )
2828
2929suite . test ( 'cannot enable pipelining before connection' , ( cb ) => {
3030 const client = new Client ( helper . config )
31-
31+
3232 try {
3333 client . pipelining = true
3434 helper . assert . fail ( 'Should have thrown error' )
@@ -40,55 +40,55 @@ suite.test('cannot enable pipelining before connection', (cb) => {
4040
4141suite . test ( 'pipelining mode allows multiple parameterized queries' , ( cb ) => {
4242 const client = new Client ( helper . config )
43-
43+
4444 client . connect ( ( err ) => {
4545 if ( err ) return cb ( err )
46-
46+
4747 client . pipelining = true
48-
48+
4949 let completed = 0
5050 const results = [ ]
51-
51+
5252 // Send multiple queries in pipeline mode
5353 client . query ( 'SELECT $1::text as message' , [ 'Hello' ] , ( err , result ) => {
5454 if ( err ) return cb ( err )
5555 results [ 0 ] = result
5656 completed ++
5757 if ( completed === 3 ) checkResults ( )
5858 } )
59-
59+
6060 client . query ( 'SELECT $1::int as number' , [ 42 ] , ( err , result ) => {
6161 if ( err ) return cb ( err )
6262 results [ 1 ] = result
6363 completed ++
6464 if ( completed === 3 ) checkResults ( )
6565 } )
66-
66+
6767 client . query ( 'SELECT $1::text as greeting' , [ 'World' ] , ( err , result ) => {
6868 if ( err ) return cb ( err )
6969 results [ 2 ] = result
7070 completed ++
7171 if ( completed === 3 ) checkResults ( )
7272 } )
73-
73+
7474 function checkResults ( ) {
7575 helper . assert . equal ( results [ 0 ] . rows [ 0 ] . message , 'Hello' )
7676 helper . assert . equal ( results [ 1 ] . rows [ 0 ] . number , 42 )
7777 helper . assert . equal ( results [ 2 ] . rows [ 0 ] . greeting , 'World' )
78-
78+
7979 client . end ( cb )
8080 }
8181 } )
8282} )
8383
8484suite . test ( 'pipelining mode rejects simple queries' , ( cb ) => {
8585 const client = new Client ( helper . config )
86-
86+
8787 client . connect ( ( err ) => {
8888 if ( err ) return cb ( err )
89-
89+
9090 client . pipelining = true
91-
91+
9292 client . query ( 'SELECT 1' , ( err , result ) => {
9393 helper . assert ( err )
9494 helper . assert . equal ( err . message , 'Simple query protocol is not allowed in pipeline mode. Use parameterized queries.' )
@@ -99,12 +99,12 @@ suite.test('pipelining mode rejects simple queries', (cb) => {
9999
100100suite . test ( 'pipelining mode rejects multi-statement queries' , ( cb ) => {
101101 const client = new Client ( helper . config )
102-
102+
103103 client . connect ( ( err ) => {
104104 if ( err ) return cb ( err )
105-
105+
106106 client . pipelining = true
107-
107+
108108 client . query ( 'SELECT $1; SELECT $2' , [ 1 , 2 ] , ( err , result ) => {
109109 helper . assert ( err )
110110 helper . assert . equal ( err . message , 'Multiple SQL commands in a single query are not allowed in pipeline mode' )
0 commit comments