add mysql connection

outerbase · Oct 8, 2024 · 11f2dc0 · 11f2dc0
1 parent 6ce6fdf
commit 11f2dc0
Show file tree

Hide file tree

Showing 6 changed files with 372 additions and 9 deletions.
diff --git a/package-lock.json b/package-lock.json
diff --git a/package.json b/package.json
@@ -47,6 +47,7 @@
         "husky": "^9.0.11",
         "jest": "^29.7.0",
         "lint-staged": "^15.2.4",
+        "mysql2": "^3.11.3",
         "prettier": "^3.2.5",
         "ts-jest": "^29.1.3",
         "ts-node": "^10.9.2",

diff --git a/src/connections/index.ts b/src/connections/index.ts
@@ -9,6 +9,12 @@ export type OperationResponse = {
     error: Error | null
 }
 
+export interface QueryResult<T = Record<string, unknown>> {
+    data: T[]
+    error: Error | null
+    query: string
+}
+
 export interface Connection {
     queryType: QueryType
     dialect: AbstractDialect
@@ -18,9 +24,9 @@ export interface Connection {
     disconnect: () => Promise<any>
 
     // Raw query execution method that can be used to execute any query.
-    query: (
+    query: <T = Record<string, unknown>>(
         query: Query
-    ) => Promise<{ data: any; error: Error | null; query: string }>
+    ) => Promise<QueryResult<T>>
 
     // Retrieve metadata about the database, useful for introspection.
     fetchDatabaseSchema?: () => Promise<Database>