fix mysql connection string

dashpresshq · Feb 22, 2024 · e374caf · e374caf
1 parent dbf800a
commit e374caf
Show file tree

Hide file tree

Showing 2 changed files with 19 additions and 3 deletions.
diff --git a/package.json b/package.json
@@ -1,12 +1,14 @@
 {
   "name": "@dashpress/bacteria",
-  "version": "0.0.11",
+  "version": "0.0.12",
   "license": "MIT",
   "main": "dist/index.js",
   "typings": "dist/index.d.ts",
   "author": "Ayobami Akingbade",
   "module": "dist/bacteria.esm.js",
-  "files": ["dist"],
+  "files": [
+    "dist"
+  ],
   "scripts": {
     "test": "jest --detectOpenHandles --runInBand",
     "start": "tsdx watch",

diff --git a/src/utils/connect.ts b/src/utils/connect.ts
@@ -14,14 +14,28 @@ const SupportedDataSourceToKnexClientMap: Record<
 const handleStringCredentials = (credentials: string) => {
   if (credentials.startsWith("sqlite")) {
     return knex({
-      client: "better-sqlite3",
+      client: SupportedDataSourceToKnexClientMap[RDMSSources.Sqlite],
       connection: {
         filename: credentials.split(":")[1],
       },
       useNullAsDefault: true,
     });
   }
 
+  if (credentials.startsWith("mysql:")) {
+    return knex({
+      client: SupportedDataSourceToKnexClientMap[RDMSSources.MySql],
+      connection: credentials,
+    });
+  }
+
+  if (credentials.startsWith("mssql:")) {
+    return knex({
+      client: SupportedDataSourceToKnexClientMap[RDMSSources.MsSql],
+      connection: credentials,
+    });
+  }
+
   return knex(credentials);
 };