throw error if query fails

ajayyy · ajayyy · commit cbf352173ad4 · 2022-08-25T21:14:25.000-04:00
diff --git a/src/databases/Postgres.ts b/src/databases/Postgres.ts
@@ -141,6 +141,8 @@ export class Postgres implements IDatabase {
             }
         } while (this.isReadQuery(type) && tries < (lastPool === this.pool
             ? this.config.postgres.maxTries : this.config.postgresReadOnly.maxTries));
+
+        throw new Error(`prepare (postgres): ${type} ${query} failed after ${tries} tries`);
     }
 
     private getPool(type: string, options: QueryOption): Pool {

Original file line number	Diff line number	Diff line change
`@@ -141,6 +141,8 @@ export class Postgres implements IDatabase {`
`141`	`141`	`}`
`142`	`142`	`} while (this.isReadQuery(type) && tries < (lastPool === this.pool`
`143`	`143`	`? this.config.postgres.maxTries : this.config.postgresReadOnly.maxTries));`
	`144`	`+`
	`145`	+ throw new Error(`prepare (postgres): ${type} ${query} failed after ${tries} tries`);
`144`	`146`	`}`
`145`	`147`
`146`	`148`	`private getPool(type: string, options: QueryOption): Pool {`