Merge pull request #738 from rocket-admin/backend_postgres_fix

refactor: Add error handling for cachedKnex in KnexManager
rocket-admin · Jul 17, 2024 · 0b3ca56 · 0b3ca56
2 parents d56a1a1 + 8d3297f
commit 0b3ca56
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/shared-code/src/knex-manager/knex-manager.ts b/shared-code/src/knex-manager/knex-manager.ts
@@ -16,7 +16,12 @@ export class KnexManager {
     knexMap.set('postgres', async (connection: ConnectionParams): Promise<Knex<any, any[]>> => {
       const cachedKnex = knexCache.get(JSON.stringify(connection));
       if (cachedKnex) {
-        return cachedKnex;
+        try {
+          await cachedKnex.raw('SELECT 1');
+          return cachedKnex;
+        } catch (error) {
+          knexCache.delete(JSON.stringify(connection));
+        }
       }
       if (connection.ssh) {
         const newKnex = await KnexManager.createTunneledKnex(connection);