@@ -6,33 +6,27 @@ var assert = require('assert')
6
6
7
7
const suite = new helper . Suite ( )
8
8
9
- // Test that the pool respects the maxResultSize option
10
- suite . test ( 'pool respects maxResultSize option' , ( done ) => {
9
+ suite . testAsync ( 'large result triggers error' , async ( ) => {
11
10
const pool = new pg . Pool ( {
12
11
...helper . args ,
13
12
maxResultSize : 1024 , // very small limit
14
13
} )
15
14
16
- pool . on ( 'error' , ( err ) => {
17
- if ( err . code === 'RESULT_SIZE_EXCEEDED' ) {
18
- return done ( )
19
- }
20
- } )
21
-
22
15
const largeQuery = `
23
16
SELECT generate_series(1, 1000) as num,
24
17
repeat('x', 100) as data
25
18
`
26
19
27
- pool . query ( largeQuery , ( err ) => {
28
- if ( ! err ) {
29
- return done ( new Error ( 'Expected query to fail with size limit error' ) )
30
- }
31
-
32
- if ( err . code !== 'RESULT_SIZE_EXCEEDED' ) {
33
- return done ( new Error ( `Expected RESULT_SIZE_EXCEEDED error but got: ${ err . message } (${ err . code } )` ) )
34
- }
20
+ pool . on ( 'error' , ( err ) => {
21
+ assert . equal ( err . code , 'RESULT_SIZE_EXCEEDED' )
35
22
} )
23
+
24
+ try {
25
+ await pool . query ( largeQuery )
26
+ throw new Error ( 'should have raised RESULT_SIZE_EXCEEDED error' )
27
+ } catch ( err ) {
28
+ assert . equal ( err . code , 'RESULT_SIZE_EXCEEDED' )
29
+ }
36
30
} )
37
31
38
32
suite . test ( 'pool query works with adequate maxResultSize' , ( done ) => {
0 commit comments