Skip to content

Commit fe3cd2f

Browse files
dougwilsonseangarner
authored andcommitted
tests: add some query end event tests
closes mysqljs#964
1 parent 6eb389a commit fe3cd2f

File tree

3 files changed

+71
-0
lines changed

3 files changed

+71
-0
lines changed
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,27 @@
1+
var assert = require('assert');
2+
var common = require('../../common');
3+
var pool = common.createPool({port: common.fakeServerPort});
4+
5+
var server = common.createFakeServer();
6+
7+
process.on('uncaughtException', function (err) {
8+
if (err.code !== 'ER_PARSE_ERROR') throw err;
9+
});
10+
11+
server.listen(common.fakeServerPort, function (err) {
12+
assert.ifError(err);
13+
14+
pool.getConnection(function (err, conn) {
15+
assert.ifError(err);
16+
17+
var query = conn.query('SELECT INVALID');
18+
19+
query.on('end', function () {
20+
conn.release();
21+
pool.end(function (err) {
22+
assert.ifError(err);
23+
server.destroy();
24+
});
25+
});
26+
});
27+
});
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,22 @@
1+
var assert = require('assert');
2+
var common = require('../../common');
3+
var pool = common.createPool({port: common.fakeServerPort});
4+
5+
var server = common.createFakeServer();
6+
7+
process.on('uncaughtException', function (err) {
8+
if (err.code !== 'ER_PARSE_ERROR') throw err;
9+
});
10+
11+
server.listen(common.fakeServerPort, function (err) {
12+
assert.ifError(err);
13+
14+
var query = pool.query('SELECT INVALID');
15+
16+
query.on('end', function () {
17+
pool.end(function (err) {
18+
assert.ifError(err);
19+
server.destroy();
20+
});
21+
});
22+
});
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,22 @@
1+
var assert = require('assert');
2+
var common = require('../../common');
3+
var connection = common.createConnection({port: common.fakeServerPort});
4+
5+
var server = common.createFakeServer();
6+
7+
process.on('uncaughtException', function (err) {
8+
if (err.code !== 'ER_PARSE_ERROR') throw err;
9+
});
10+
11+
server.listen(common.fakeServerPort, function (err) {
12+
assert.ifError(err);
13+
14+
var query = connection.query('SELECT INVALID');
15+
16+
query.on('end', function () {
17+
connection.end(function (err) {
18+
assert.ifError(err);
19+
server.destroy();
20+
});
21+
});
22+
});

0 commit comments

Comments
 (0)