#13 fix: added error handler for insert record

Sanketika-Obsrv · Mar 2, 2023 · bbe3875 · bbe3875
1 parent 801f8d5
commit bbe3875
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/connectors/DbConnector.ts b/src/connectors/DbConnector.ts
@@ -34,7 +34,8 @@ export class DbConnector implements IConnector {
     }
 
     private async insertRecord(table: string, fields: any) {
-        await this.pool(table).insert(fields)
+        let fetchedRecords = await this.pool(table).select().where('id', '=', fields.id)
+        return fetchedRecords.length > 0 ? (() => { throw new Error('Record already exists') })() : await this.pool(table).insert(fields)
     }
 
     private async updateRecord(table: string, fields: any) {