@@ -5,29 +5,31 @@ test('should return insert metadata', function() {
5
5
pg . connect ( helper . config , assert . calls ( function ( err , client , done ) {
6
6
assert . isNull ( err ) ;
7
7
8
- client . query ( "CREATE TEMP TABLE zugzug(name varchar(10))" , assert . calls ( function ( err , result ) {
9
- assert . isNull ( err ) ;
10
- assert . equal ( result . oid , null ) ;
11
- assert . equal ( result . command , 'CREATE' ) ;
8
+ helper . versionGTE ( client , '9.0.0' , assert . success ( function ( hasRowCount ) {
9
+ client . query ( "CREATE TEMP TABLE zugzug(name varchar(10))" , assert . calls ( function ( err , result ) {
10
+ assert . isNull ( err ) ;
11
+ assert . equal ( result . oid , null ) ;
12
+ assert . equal ( result . command , 'CREATE' ) ;
12
13
13
- var q = client . query ( "INSERT INTO zugzug(name) VALUES('more work?')" , assert . calls ( function ( err , result ) {
14
- assert . equal ( result . command , "INSERT" ) ;
15
- assert . equal ( result . rowCount , 1 ) ;
16
-
17
- client . query ( 'SELECT * FROM zugzug' , assert . calls ( function ( err , result ) {
18
- assert . isNull ( err ) ;
14
+ var q = client . query ( "INSERT INTO zugzug(name) VALUES('more work?')" , assert . calls ( function ( err , result ) {
15
+ assert . equal ( result . command , "INSERT" ) ;
19
16
assert . equal ( result . rowCount , 1 ) ;
20
- assert . equal ( result . command , 'SELECT' ) ;
21
- process . nextTick ( pg . end . bind ( pg ) ) ;
17
+
18
+ client . query ( 'SELECT * FROM zugzug' , assert . calls ( function ( err , result ) {
19
+ assert . isNull ( err ) ;
20
+ if ( hasRowCount ) assert . equal ( result . rowCount , 1 ) ;
21
+ assert . equal ( result . command , 'SELECT' ) ;
22
+ process . nextTick ( pg . end . bind ( pg ) ) ;
23
+ } ) ) ;
22
24
} ) ) ;
23
- } ) ) ;
24
25
25
- assert . emits ( q , 'end' , function ( result ) {
26
- assert . equal ( result . command , "INSERT" ) ;
27
- assert . equal ( result . rowCount , 1 ) ;
28
- done ( ) ;
29
- } ) ;
26
+ assert . emits ( q , 'end' , function ( result ) {
27
+ assert . equal ( result . command , "INSERT" ) ;
28
+ if ( hasRowCount ) assert . equal ( result . rowCount , 1 ) ;
29
+ done ( ) ;
30
+ } ) ;
30
31
32
+ } ) ) ;
31
33
} ) ) ;
32
34
} ) ) ;
33
35
} ) ;
0 commit comments