diff --git a/server/src/services/tooljet_db.service.ts b/server/src/services/tooljet_db.service.ts index e5e7bcdf01..aebdb6082e 100644 --- a/server/src/services/tooljet_db.service.ts +++ b/server/src/services/tooljet_db.service.ts @@ -610,13 +610,17 @@ export class TooljetDbService { if (!internalTable) throw new NotFoundException('Internal table not found: ' + tableName); - const query = `ALTER TABLE "${internalTable.id}" DROP COLUMN ${column['column_name']}`; + // const query = `ALTER TABLE "${internalTable.id}" DROP COLUMN "${column['column_name']}"`; + const tjdbQueryRunnner = this.tooljetDbManager.connection.createQueryRunner(); + await tjdbQueryRunnner.connect(); try { - const result = await this.tooljetDbManager.query(query); + const result = await tjdbQueryRunnner.dropColumn(internalTable.id, column['column_name']); await this.tooljetDbManager.query("NOTIFY pgrst, 'reload schema'"); return result; } catch (error) { throw new TooljetDatabaseError(error.message, { origin: 'drop_column', internalTables: [internalTable] }, error); + } finally { + await tjdbQueryRunnner.release(); } }