[misc] add maxscale CI testing

Author: rusher

test/integration/batch.test.js

@@ -1473,29 +1473,31 @@ describe.sequential(
             { affectedRows: 1, insertId: 0n, warningStatus: 0 }
           ]);
         } else {
-          assert.deepEqual(res, { affectedRows: 4, insertId: 0n, warningStatus: 0 });
-        }
-        if (supportBulkUnitResults) {
-          res = await connBulk.batch({ sql: 'INSERT INTO bufLength VALUES (?)', fullResult: true }, [
-            ['abc'],
-            ['cde'],
-            [1],
-            [new Date('2001-12-31 23:59:58')]
-          ]);
           assert.deepEqual(res, [
-            { affectedRows: 1, insertId: 0n, warningStatus: 0 },
-            { affectedRows: 1, insertId: 0n, warningStatus: 0 },
+            { affectedRows: 2, insertId: 0n, warningStatus: 0 },
             { affectedRows: 1, insertId: 0n, warningStatus: 0 },
             { affectedRows: 1, insertId: 0n, warningStatus: 0 }
           ]);
-          res = await connBulk.batch({ sql: 'INSERT INTO bufLength VALUES (?)', fullResult: false }, [
-            ['abc'],
-            ['cde'],
-            [1],
-            [new Date('2001-12-31 23:59:58')]
-          ]);
-          assert.deepEqual(res, { affectedRows: 4, insertId: 0n, warningStatus: 0 });
         }
+        res = await connBulk.batch({ sql: 'INSERT INTO bufLength VALUES (?)', fullResult: true }, [
+          ['abc'],
+          ['cde'],
+          [1],
+          [new Date('2001-12-31 23:59:58')]
+        ]);
+        assert.deepEqual(res, [
+          { affectedRows: 1, insertId: 0n, warningStatus: 0 },
+          { affectedRows: 1, insertId: 0n, warningStatus: 0 },
+          { affectedRows: 1, insertId: 0n, warningStatus: 0 },
+          { affectedRows: 1, insertId: 0n, warningStatus: 0 }
+        ]);
+        res = await connBulk.batch({ sql: 'INSERT INTO bufLength VALUES (?)', fullResult: false }, [
+          ['abc'],
+          ['cde'],
+          [1],
+          [new Date('2001-12-31 23:59:58')]
+        ]);
+        assert.deepEqual(res, { affectedRows: 4, insertId: 0n, warningStatus: 0 });
         await connBulk.end();
       });
 

test/integration/connection.test.js

@@ -335,14 +335,14 @@ describe.concurrent('connection', () => {
 
   test('connection.destroy() when executing', async () => {
     const conn = await createConnection();
-    conn.query('SELECT 1');
-    conn.destroy();
+    conn.query('SELECT 1').catch((err) => {});
+    await conn.destroy();
   }, 10000);
 
   test('connection.close alias', async () => {
     const conn = await createConnection({ keepAliveDelay: 100 });
-    conn.query('SELECT 1');
-    conn.close();
+    conn.query('SELECT 1').catch((err) => {});
+    await conn.close();
   }, 10000);
 
   test('connection.destroy() during query execution', async ({ skip }) => {

test/integration/file.test.js

@@ -238,7 +238,8 @@ describe('sql file import', () => {
         });
       }, 30000);
 
-      test('simple file import with direct connection options', async () => {
+      test('simple file import with direct connection options', async ({skip}) => {
+        if (isMaxscale(shareConn)) return skip();
         await new Promise((resolve, reject) => {
           baseCallback.importFile(
             Object.assign({}, Conf.baseConfig, { file: __dirname + '/../tools/data-dump.sql', database: 'fimp' }),

test/integration/redirection.test.js

@@ -66,7 +66,13 @@ describe.concurrent('redirection', () => {
       proxy.close();
       return skip();
     }
-    let conn = await createConnection({ host: 'localhost', port: proxy.port(), permitRedirect: true, debug: true });
+    let conn = await createConnection({
+      host: 'localhost',
+      port: proxy.port(),
+      permitRedirect: true,
+      debug: true,
+      debugLen: 1024
+    });
     try {
       assert.equal(Conf.baseConfig.host, conn.info.host);
       assert.equal(Conf.baseConfig.port, conn.info.port);

test/integration/ssl.test.js

@@ -166,7 +166,7 @@ describe.concurrent('ssl', function () {
       if (
         !isMaxscaleEphemeral &&
         !shareConn.info.isMariaDB() &&
-        (!shareConn.info.hasMinVersion(11, 4, 0) || shareConn.info.hasMinVersion(23, 0, 0))
+        !shareConn.info.hasMinVersion(11, 4, 0)
       ) {
         throw new Error('Must have thrown an exception !');
       }