avoid connecting twice

src/renderer/component/Connection/ConnectionStack.tsx

@@ -10,6 +10,7 @@ import {
   DatabaseContextProps,
 } from '../../../contexts/DatabaseContext';
 import type { ConnectionObject } from '../../../sql/types';
+import { getErrorMessage } from '../../utils/error';
 
 interface Props {
   children: ReactNode;
@@ -33,10 +34,15 @@ function ConnectionStack({ children }: Props) {
     };
   }, []);
 
+  // TODO we might need to change that into the proper route as reload will not work
   const handleConnectTo = useCallback(
     async (params: ConnectionObject) => {
-      await window.sql.openConnection(params);
-      // setConnectionNameList((prev) => [...prev, params.name]);
+      try {
+        await window.sql.openConnection(params);
+        setConnectionNameList((prev) => [...prev, params.name]);
+      } catch (error: unknown) {
+        console.error(getErrorMessage(error));
+      }
 
       navigate(`/connections/${params.name}`);
     },

src/renderer/utils/error.tsx

@@ -0,0 +1,11 @@
+export function getErrorMessage(error: unknown, fallback?: string): string {
+  if (typeof error === 'string') {
+    return error;
+  }
+
+  if (error instanceof Error) {
+    return error.message;
+  }
+
+  return fallback ?? 'An unknown error occurred';
+}

src/sql/index.ts

@@ -25,6 +25,13 @@ class ConnectionStack {
   async connect(params: ConnectionObject): Promise<void> {
     const { name, ...rest } = params;
 
+    // don't connect twice to the same connection
+    if (this.connections.has(name)) {
+      throw new Error(`Connection already opened on "${name}"`);
+    }
+
+    console.log(`[SQL] Open connection to "${name}"`);
+
     const connection = await createConnection(rest);
     await connection.connect();
 
@@ -34,7 +41,7 @@ class ConnectionStack {
   async executeQuery(connectionName: string, query: string): QueryResult {
     const connection = this.#getConnection(connectionName);
 
-    console.log(`[SQL] Execute query "${query}"`);
+    console.log(`[SQL] Execute query on "${connectionName}": "${query}"`);
 
     return await connection.query(query);
   }