@@ -4,6 +4,41 @@ var util = require('util');
44
55var suite = new helper . Suite ( ) ;
66
7+ suite . test ( 'client end during query execution of prepared statement' , function ( done ) {
8+ var client = new Client ( helper . args ) ;
9+ client . connect ( assert . success ( function ( ) {
10+
11+ var sleepQuery = 'select pg_sleep($1)' ;
12+
13+ var queryConfig = {
14+ name : 'sleep query' ,
15+ text : sleepQuery ,
16+ values : [ 5 ] ,
17+ }
18+
19+ var queryInstance = new Query ( queryConfig , assert . calls ( function ( err , result ) {
20+ assert . equal ( err . message , 'Connection terminated' ) ;
21+ } ) )
22+
23+ var query1 = client . query ( queryInstance ) ;
24+
25+
26+ query1 . on ( 'error' , function ( err ) {
27+ assert . fail ( 'Prepared statement should not emit error' ) ;
28+ } ) ;
29+
30+ query1 . on ( 'row' , function ( row ) {
31+ assert . fail ( 'Prepared statement should not emit row' ) ;
32+ } ) ;
33+
34+ query1 . on ( 'end' , function ( err ) {
35+ assert . fail ( 'Prepared statement when executed should not return before being killed' ) ;
36+ } ) ;
37+
38+ client . end ( done ) ;
39+ } ) ) ;
40+ } ) ;
41+
742function killIdleQuery ( targetQuery , cb ) {
843 var client2 = new Client ( helper . args ) ;
944 var pidColName = 'procpid'
@@ -61,37 +96,3 @@ suite.test('query killed during query execution of prepared statement', function
6196 killIdleQuery ( sleepQuery , done ) ;
6297 } ) ) ;
6398} ) ;
64-
65- suite . test ( 'client end during query execution of prepared statement' , function ( done ) {
66- var client = new Client ( helper . args ) ;
67- client . connect ( assert . success ( function ( ) {
68- var sleepQuery = 'select pg_sleep($1)' ;
69-
70- var queryConfig = {
71- name : 'sleep query' ,
72- text : sleepQuery ,
73- values : [ 5 ] ,
74- }
75-
76- var queryInstance = new Query ( queryConfig , assert . calls ( function ( err , result ) {
77- assert . equal ( err . message , 'Connection terminated' ) ;
78- } ) )
79-
80- var query1 = client . query ( queryInstance ) ;
81-
82-
83- query1 . on ( 'error' , function ( err ) {
84- assert . fail ( 'Prepared statement should not emit error' ) ;
85- } ) ;
86-
87- query1 . on ( 'row' , function ( row ) {
88- assert . fail ( 'Prepared statement should not emit row' ) ;
89- } ) ;
90-
91- query1 . on ( 'end' , function ( err ) {
92- assert . fail ( 'Prepared statement when executed should not return before being killed' ) ;
93- } ) ;
94-
95- client . end ( done ) ;
96- } ) ) ;
97- } ) ;
0 commit comments