Skip to content

Commit 0db012f

Browse files
committed
add a test for #569
1 parent d40ffc8 commit 0db012f

File tree

1 file changed

+35
-0
lines changed

1 file changed

+35
-0
lines changed

test/integration/test-pool-release.js

Lines changed: 35 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,35 @@
1+
var createPool = require('../common.js').createPool;
2+
var assert = require('assert');
3+
4+
var pool = createPool();
5+
6+
pool.query('test sql', function(err, res, rows) {
7+
pool.query('test sql', [], function(err, res, rows) {
8+
pool.query('test sql', [], function(err, res, rows) {
9+
pool.query('test sql', [], function(err, res, rows) {
10+
pool.query('test sql', function(err, res, rows) {
11+
pool.query('test sql').on('error', function(err) {
12+
pool.query('test sql', function(err, res, rows) {
13+
pool.execute('test sql', function(err, res, rows) {
14+
pool.execute('test sql', function(err, res, rows) {
15+
pool.execute('test sql', [], function(err, res, rows) {
16+
pool.execute('test sql', function(err) {
17+
pool.execute('test sql', function(err, res, rows) {
18+
// TODO change order events are fires so that connection is released before callback
19+
// that way this number will be more deterministic
20+
assert(pool._allConnections.length < 3);
21+
assert(pool._freeConnections.length === 1);
22+
assert(pool._connectionQueue.length === 0);
23+
pool.end();
24+
});
25+
});
26+
});
27+
});
28+
});
29+
});
30+
});
31+
});
32+
});
33+
});
34+
});
35+
});

0 commit comments

Comments
 (0)