Skip to content

Commit e22f366

Browse files
committed
test that pool_connection conect time error is propagated to pool user
1 parent 2674803 commit e22f366

File tree

1 file changed

+54
-0
lines changed

1 file changed

+54
-0
lines changed
Lines changed: 54 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,54 @@
1+
var util = require('util');
2+
var mysql = require('../../index.js');
3+
var Command = require('../../lib/commands/command.js');
4+
var Packets = require('../../lib/packets/index.js');
5+
6+
var assert = require('assert');
7+
8+
var server = mysql.createServer(function (conn) {
9+
conn.serverHandshake({
10+
protocolVersion: 10,
11+
serverVersion: '5.6.10', //'node.js rocks',
12+
connectionId: 1234,
13+
statusFlags: 2,
14+
characterSet: 8,
15+
capabilityFlags: 0xffffff,
16+
authCallback: function(params, cb) {
17+
cb(null, { message: 'too many connections', code: 1040});
18+
}
19+
});
20+
});
21+
22+
var err1, err2;
23+
24+
var portfinder = require('portfinder');
25+
portfinder.getPort(function (err, port) {
26+
27+
server.listen(port);
28+
var conn = mysql.createConnection({
29+
user: 'test_user',
30+
password: 'test',
31+
database: 'test_database',
32+
port: port
33+
});
34+
conn.on('error', function (err) {
35+
err1 = err
36+
});
37+
38+
var pool = mysql.createPool({
39+
user: 'test_user',
40+
password: 'test',
41+
database: 'test_database',
42+
port: port
43+
});
44+
45+
pool.query('test sql', function (err, res, rows) {
46+
err2 = err;
47+
});
48+
49+
});
50+
51+
process.on('exit', function() {
52+
assert.equal(err1.errno, 1040);
53+
assert.equal(err2.errno, 1040);
54+
});

0 commit comments

Comments
 (0)