refactor: streamline error handling and improve code readability in database connectors

- Consolidated error message formatting for DSN parsing across all database connectors.
- Simplified schema clause definitions in MySQL, MariaDB, and SQLite connectors for better readability.
- Enhanced consistency in code structure by reducing line breaks in relevant sections.

Author: theboringhumane

src/connectors/mariadb/index.ts

@@ -42,9 +42,7 @@ class MariadbDSNParser implements DSNParser {
 
       return config;
     } catch (error) {
-      throw new Error(
-        `Failed to parse MariaDB DSN: ${error instanceof Error ? error.message : String(error)}`
-      );
+      throw new Error(`Failed to parse MariaDB DSN: ${error instanceof Error ? error.message : String(error)}`);
     }
   }
 
@@ -295,9 +293,7 @@ export class MariaDBConnector implements Connector {
 
     try {
       // In MariaDB, if no schema is provided, use the current database context
-      const schemaClause = schema
-        ? 'WHERE ROUTINE_SCHEMA = ?'
-        : 'WHERE ROUTINE_SCHEMA = DATABASE()';
+      const schemaClause = schema ? 'WHERE ROUTINE_SCHEMA = ?' : 'WHERE ROUTINE_SCHEMA = DATABASE()';
 
       const queryParams = schema ? [schema] : [];
 
@@ -326,9 +322,7 @@ export class MariaDBConnector implements Connector {
 
     try {
       // In MariaDB, if no schema is provided, use the current database context
-      const schemaClause = schema
-        ? 'WHERE r.ROUTINE_SCHEMA = ?'
-        : 'WHERE r.ROUTINE_SCHEMA = DATABASE()';
+      const schemaClause = schema ? 'WHERE r.ROUTINE_SCHEMA = ?' : 'WHERE r.ROUTINE_SCHEMA = DATABASE()';
 
       const queryParams = schema ? [schema, procedureName] : [procedureName];
 

src/connectors/mysql/index.ts

@@ -42,9 +42,7 @@ class MySQLDSNParser implements DSNParser {
 
       return config;
     } catch (error) {
-      throw new Error(
-        `Failed to parse MySQL DSN: ${error instanceof Error ? error.message : String(error)}`
-      );
+      throw new Error(`Failed to parse MySQL DSN: ${error instanceof Error ? error.message : String(error)}`);
     }
   }
 
@@ -293,9 +291,7 @@ export class MySQLConnector implements Connector {
 
     try {
       // In MySQL, if no schema is provided, use the current database context
-      const schemaClause = schema
-        ? 'WHERE ROUTINE_SCHEMA = ?'
-        : 'WHERE ROUTINE_SCHEMA = DATABASE()';
+      const schemaClause = schema ? 'WHERE ROUTINE_SCHEMA = ?' : 'WHERE ROUTINE_SCHEMA = DATABASE()';
 
       const queryParams = schema ? [schema] : [];
 
@@ -324,9 +320,7 @@ export class MySQLConnector implements Connector {
 
     try {
       // In MySQL, if no schema is provided, use the current database context
-      const schemaClause = schema
-        ? 'WHERE r.ROUTINE_SCHEMA = ?'
-        : 'WHERE r.ROUTINE_SCHEMA = DATABASE()';
+      const schemaClause = schema ? 'WHERE r.ROUTINE_SCHEMA = ?' : 'WHERE r.ROUTINE_SCHEMA = DATABASE()';
 
       const queryParams = schema ? [schema, procedureName] : [procedureName];
 

src/connectors/postgres/index.ts

@@ -45,9 +45,7 @@ class PostgresDSNParser implements DSNParser {
 
       return config;
     } catch (error) {
-      throw new Error(
-        `Failed to parse PostgreSQL DSN: ${error instanceof Error ? error.message : String(error)}`
-      );
+      throw new Error(`Failed to parse PostgreSQL DSN: ${error instanceof Error ? error.message : String(error)}`);
     }
   }
 

src/connectors/sqlite/index.ts

@@ -55,9 +55,7 @@ class SQLiteDSNParser implements DSNParser {
 
       return { dbPath };
     } catch (error) {
-      throw new Error(
-        `Failed to parse SQLite DSN: ${error instanceof Error ? error.message : String(error)}`
-      );
+      throw new Error(`Failed to parse SQLite DSN: ${error instanceof Error ? error.message : String(error)}`);
     }
   }
 
@@ -212,9 +210,7 @@ export class SQLiteConnector implements Connector {
         .all(tableName) as { index_name: string; is_unique: number }[];
 
       // Get the primary key info
-      const tableInfo = this.db
-        .prepare(`PRAGMA table_info(${tableName})`)
-        .all() as SQLiteTableInfo[];
+      const tableInfo = this.db.prepare(`PRAGMA table_info(${tableName})`).all() as SQLiteTableInfo[];
 
       // Find primary key columns
       const pkColumns = tableInfo.filter((col) => col.pk > 0).map((col) => col.name);
@@ -224,9 +220,9 @@ export class SQLiteConnector implements Connector {
       // Add regular indexes
       for (const indexInfo of indexInfoRows) {
         // Get the columns for this index
-        const indexDetailRows = this.db
-          .prepare(`PRAGMA index_info(${indexInfo.index_name})`)
-          .all() as { name: string }[];
+        const indexDetailRows = this.db.prepare(`PRAGMA index_info(${indexInfo.index_name})`).all() as {
+          name: string;
+        }[];
         const columnNames = indexDetailRows.map((row) => row.name);
 
         results.push({

src/connectors/sqlserver/index.ts

@@ -19,9 +19,7 @@ export class SQLServerDSNParser implements DSNParser {
   async parse(dsn: string): Promise<sql.config> {
     // Remove the protocol prefix
     if (!this.isValidDSN(dsn)) {
-      throw new Error(
-        'Invalid SQL Server DSN format. Expected: sqlserver://username:password@host:port/database'
-      );
+      throw new Error('Invalid SQL Server DSN format. Expected: sqlserver://username:password@host:port/database');
     }
 
     // Parse the DSN
@@ -402,14 +400,8 @@ export class SQLServerConnector implements Connector {
       if (parameterResult.recordset.length > 0) {
         parameterList = parameterResult.recordset
           .map(
-            (param: {
-              CHARACTER_MAXIMUM_LENGTH: number;
-              PARAMETER_NAME: any;
-              PARAMETER_MODE: any;
-              DATA_TYPE: any;
-            }) => {
-              const lengthStr =
-                param.CHARACTER_MAXIMUM_LENGTH > 0 ? `(${param.CHARACTER_MAXIMUM_LENGTH})` : '';
+            (param: { CHARACTER_MAXIMUM_LENGTH: number; PARAMETER_NAME: any; PARAMETER_MODE: any; DATA_TYPE: any }) => {
+              const lengthStr = param.CHARACTER_MAXIMUM_LENGTH > 0 ? `(${param.CHARACTER_MAXIMUM_LENGTH})` : '';
               return `${param.PARAMETER_NAME} ${param.PARAMETER_MODE} ${param.DATA_TYPE}${lengthStr}`;
             }
           )