diff --git a/packages/cli/src/modules/data-table/data-store-rows.repository.ts b/packages/cli/src/modules/data-table/data-store-rows.repository.ts index c3370bdd58..64eb808e2c 100644 --- a/packages/cli/src/modules/data-table/data-store-rows.repository.ts +++ b/packages/cli/src/modules/data-table/data-store-rows.repository.ts @@ -17,7 +17,6 @@ import { deleteColumnQuery, extractInsertedIds, extractReturningData, - getPlaceholder, normalizeRows, normalizeValue, quoteIdentifier, @@ -226,12 +225,15 @@ export class DataStoreRowsRepository { return true; } - const dbType = this.dataSource.options.type; - const quotedTableName = quoteIdentifier(this.toTableName(dataStoreId), dbType); - const placeholders = ids.map((_, index) => getPlaceholder(index + 1, dbType)).join(', '); - const query = `DELETE FROM ${quotedTableName} WHERE id IN (${placeholders})`; + const table = this.toTableName(dataStoreId); + + await this.dataSource + .createQueryBuilder() + .delete() + .from(table, 'dataStore') + .where({ id: In(ids) }) + .execute(); - await this.dataSource.query(query, ids); return true; } diff --git a/packages/cli/src/modules/data-table/utils/sql-utils.ts b/packages/cli/src/modules/data-table/utils/sql-utils.ts index af96e651c0..a0b769b023 100644 --- a/packages/cli/src/modules/data-table/utils/sql-utils.ts +++ b/packages/cli/src/modules/data-table/utils/sql-utils.ts @@ -261,7 +261,3 @@ export function normalizeValue( return value; } - -export function getPlaceholder(index: number, dbType: DataSourceOptions['type']): string { - return dbType.includes('postgres') ? `$${index}` : '?'; -}