diff --git a/packages/cli/src/modules/data-store/__tests__/data-store.service.test.ts b/packages/cli/src/modules/data-store/__tests__/data-store.service.test.ts index c8ff611ba53..2fd4a94a02e 100644 --- a/packages/cli/src/modules/data-store/__tests__/data-store.service.test.ts +++ b/packages/cli/src/modules/data-store/__tests__/data-store.service.test.ts @@ -973,7 +973,7 @@ describe('dataStore', () => { const result = await dataStoreService.insertRows(dataStoreId, project1.id, rows); // ASSERT - expect(result).toBe(true); + expect(tresult).toBe(true); const { count, data } = await dataStoreService.getManyRowsAndCount( dataStoreId, diff --git a/packages/cli/src/modules/data-store/data-store-rows.repository.ts b/packages/cli/src/modules/data-store/data-store-rows.repository.ts index 23b39ce8fca..a7ace504cb7 100644 --- a/packages/cli/src/modules/data-store/data-store-rows.repository.ts +++ b/packages/cli/src/modules/data-store/data-store-rows.repository.ts @@ -58,11 +58,10 @@ export class DataStoreRowsRepository { columns: DataStoreColumn[], ) { const dbType = this.dataSource.options.type; - await this.dataSource.query.apply( + return (await this.dataSource.query.apply( this.dataSource, buildInsertQuery(tableName, rows, columns, dbType), - ); - return true; + )) as number; } async upsertRows( diff --git a/packages/cli/src/modules/data-store/data-store.controller.ts b/packages/cli/src/modules/data-store/data-store.controller.ts index 6a9592080b8..eae82220834 100644 --- a/packages/cli/src/modules/data-store/data-store.controller.ts +++ b/packages/cli/src/modules/data-store/data-store.controller.ts @@ -233,6 +233,9 @@ export class DataStoreController { } } + /** + * @returns the IDs of the inserted rows + */ @Post('/:dataStoreId/insert') @ProjectScope('dataStore:writeRow') async appendDataStoreRows(