add mariadb connect

backend-api/package.json

@@ -48,12 +48,14 @@
     "js-joda": "^1.11.0",
     "knex": "^2.3.0",
     "knex-bigquery": "^2.0.3",
+    "knex-db2": "^1.0.0",
     "knex-schema-inspector": "^2.0.4",
     "knex-snowflake-dialect": "^1.0.1",
     "mustache": "^4.2.0",
     "mysql": "^2.18.1",
     "mysql2": "^2.3.3",
     "nest-winston": "^1.7.0",
+    "odbc": "^2.4.6",
     "oracledb": "^5.5.0",
     "pg": "^8.8.0",
     "reflect-metadata": "^0.1.13",

backend-api/src/connection/connection.service.ts

@@ -69,7 +69,7 @@ export class ConnectionService {
     let _knex: Knex;
     let returnObj = {};
     try {
-      console.log(connectionConfig);
+
       _knex = knex(connectionConfig as Knex.Config);
     } catch (e) {
       console.log('knex not connected');
@@ -101,13 +101,16 @@ export class ConnectionService {
     const fields = [];
     const resultObj = { status: ResponseStatus.SUCCESS, message: 'success', datas: [], fields: [] };
 
+
+
     try {
       const queryRes = await knex.raw(queryExecuteDto.query);
 
       switch (knex.client.config.client) {
-        case 'mysql':
         case 'mysql2':
+
           if (queryRes && queryRes[0].length > 0) {
+
             datas = queryRes[0];
             const tempFields = queryRes[1];
             tempFields.map(field => {
@@ -117,6 +120,7 @@ export class ConnectionService {
                 columnType: FieldTypeUtil.mysqlFieldType(field.type),
               };
               fields.push(fieldInfo);
+
             });
             break;
           }
@@ -136,8 +140,27 @@ export class ConnectionService {
             break;
           }
 
+        case 'mysql':
+          if (queryRes && queryRes[0].length > 0) {
+
+            datas = queryRes[0];
+            const tempFields = queryRes[1];
+            tempFields.map(field => {
+              const fieldInfo = {
+                columnName: field.name,
+                columnLength: field.length,
+                columnType: FieldTypeUtil.mysqlFieldType(field.type),
+              };
+              fields.push(fieldInfo);
+            });
+            break;
+          }
+
+
+
         case 'mssql':
           if (queryRes && queryRes.length > 0) {
+
             datas = queryRes;
             for (let i = 0; i < Object.keys(queryRes[0]).length; i++) {
               console.log(Object.keys[i]);