test(timeout): add connectTimeout test

Author: yuxizhe

test/common.js

@@ -121,7 +121,8 @@ exports.createConnection = function(args) {
     dateStrings: args && args.dateStrings,
     authSwitchHandler: args && args.authSwitchHandler,
     typeCast: args && args.typeCast,
-    namedPlaceholders: args && args.namedPlaceholders
+    namedPlaceholders: args && args.namedPlaceholders,
+    connectTimeout: args && args.connectTimeout,
   };
 
   const conn = driver.createConnection(params);

test/integration/connection/test-connect-timeout.js

@@ -0,0 +1,27 @@
+'use strict';
+
+const common = require('../../common');
+const connection = common.createConnection({ 
+  host: '10.255.255.1',
+  debug: false,
+  connectTimeout: 100, 
+});
+
+const assert = require('assert');
+
+connection.query('SELECT sleep(3) as a', (err, res) => {
+  assert.equal(res, null);
+  assert.ok(err);
+  assert.equal(err.code, 'ETIMEDOUT');
+  assert.equal(err.message, 'connect ETIMEDOUT');
+});
+
+connection.query({ sql: 'SELECT sleep(3) as a' , timeout: 50}, (err, res) => {
+  assert.equal(res, null);
+  assert.ok(err);
+  assert.equal(err.code, 'ETIMEDOUT');
+  assert.equal(err.message, 'connect ETIMEDOUT');
+});
+
+
+

test/integration/connection/test-query-timeout.js

@@ -34,3 +34,17 @@ connection.execute('SELECT sleep(1) as a', (err, res) => {
   assert.deepEqual(res, [{ a: 0 }]);
   connection.end();
 });
+
+const connectionTimeout = common.createConnection({ 
+  host: '10.255.255.1',
+  debug: false,
+  connectTimeout: 100, 
+});
+
+// return connect timeout error first
+connectionTimeout.query({ sql: 'SELECT sleep(3) as a', timeout: 50 }, (err, res) => {
+  assert.equal(res, null);
+  assert.ok(err);
+  assert.equal(err.code, 'ETIMEDOUT');
+  assert.equal(err.message, 'connect ETIMEDOUT');
+});