refactor: improve database interaction by using PostgresAdapter and SQLKITException

- Updated test setup to utilize PostgresAdapter for executing SQL commands.
- Introduced SQLKITException for better error handling in SQL execution.
- Refactored query builders to ensure executor is provided and handle errors appropriately.
- Cleaned up imports and removed redundant code in query builders.

Author: kingRayhan

src/.idea/modules.xml

@@ -1,20 +1,19 @@
-import { QueryResult, SqlExecutor } from "../types/common";
+import { Pool } from "pg";
+import { QueryResult, SqlExecutor } from "../types";
+import { SQLKITException } from "../exceptions";
 
 export class PostgresAdapter implements SqlExecutor {
-  constructor(private client: any) {}
+  constructor(private pgPool: Pool) {}
 
   async executeSQL<T>(sql: string, values: any[]): Promise<QueryResult> {
-    try {
-      const result = await this.client.query(sql, values);
-      this.client.release();
-      return { rows: result.rows as T[] };
-    } catch (error) {
-      throw new Error(`PostgreSQL error: ${(error as Error).message}`);
-    } finally {
-      // Ensure the client is released back to the pool
-      if (this.client.release) {
-        this.client.release();
-      }
-    }
+    return new Promise((resolve, reject) => {
+      this.pgPool.query<T>(sql, values, (err, result) => {
+        if (err) {
+          reject(new SQLKITException(err.message));
+        } else {
+          resolve(result);
+        }
+      });
+    });
   }
 }

src/.idea/src.iml

@@ -0,0 +1,6 @@
+export class SQLKITException extends Error {
+  constructor(message: string) {
+    super(message);
+    this.name = "SQLKITException";
+  }
+}

src/.idea/vcs.xml

@@ -0,0 +1 @@
+export * from "./SQLKIT_Exception";

src/.idea/workspace.xml

@@ -1,15 +1,24 @@
 import { QueryResult, SqlExecutor } from "../types";
+import { SQLKITException } from "../exceptions";
 
 export abstract class BaseQueryBuilder<T> {
   protected constructor(
     protected readonly tableName: string,
-    protected readonly executor: SqlExecutor,
+    protected readonly executor?: SqlExecutor<T>,
   ) {}
 
   protected abstract build(): { sql: string; values: any[] };
 
   async commit(): Promise<QueryResult> {
     const { sql, values } = this.build();
+
+    if (!this.executor) {
+      throw new SQLKITException(`
+        To commit a query, you must provide an executor.
+        Please provide an executor when creating the query builder.
+      `);
+    }
+
     return this.executor.executeSQL(sql, values);
   }
 }

src/dialects/postgres.ts

@@ -1,4 +1,3 @@
-import { SqlExecutor } from "../types";
 import { WhereCondition } from "../types";
 import { buildWhereClause } from "../utils";
 import { BaseQueryBuilder } from "./base";
@@ -7,10 +6,6 @@ export class DeleteQueryBuilder<T> extends BaseQueryBuilder<T> {
   private whereCondition?: WhereCondition<T>;
   private returningColumns: Array<keyof T | "*"> = ["*"] as any;
 
-  constructor(tableName: string, executor: SqlExecutor) {
-    super(tableName, executor);
-  }
-
   where(condition: WhereCondition<T>): this {
     this.whereCondition = condition;
     return this;

src/exceptions/SQLKIT_Exception.ts

@@ -1,15 +1,10 @@
-import { SqlExecutor } from "../types";
 import { toSnakeCase } from "../utils";
 import { BaseQueryBuilder } from "./base";
 
 export class InsertQueryBuilder<T> extends BaseQueryBuilder<T> {
   private data: Partial<T> | Partial<T>[] = {};
   private returningColumns: Array<keyof T> = ["*"] as any;
 
-  constructor(tableName: string, executor: SqlExecutor) {
-    super(tableName, executor);
-  }
-
   values(data: Partial<T> | Partial<T>[]): this {
     this.data = data;
     return this;