feat: implement batch update for view operations (#1825)

* feat: implement batch update for view operations

* fix: adjust database table name handling for SQLite in view service

* fix: schema type

* fix: correct version increment logic in view service

* feat: implement createFields batch update  view operations

* refactor: streamline view update logic and enhance context handling

* refactor: rename initViewColumnMeta function params

* refactor: optimize batch update logic

- change batch update view by temp table to case when
- add batch update view e2e

Author: younocode

apps/nestjs-backend/src/features/field/field-calculate/field-creating.service.ts

@@ -1,5 +1,5 @@
 import { Injectable, Logger } from '@nestjs/common';
-import type { IColumnMeta } from '@teable/core';
+import type { IColumn, IColumnMeta } from '@teable/core';
 import { FieldType } from '@teable/core';
 import { PrismaService } from '@teable/db-main-prisma';
 import { ViewService } from '../../view/view.service';
@@ -19,7 +19,11 @@ export class FieldCreatingService {
     private readonly fieldSupplementService: FieldSupplementService
   ) {}
 
-  async createFieldItem(tableId: string, field: IFieldInstance, columnMeta?: IColumnMeta) {
+  async createFieldItem(
+    tableId: string,
+    field: IFieldInstance,
+    initViewColumnMap?: Record<string, IColumn>
+  ) {
     const fieldId = field.id;
 
     await this.fieldSupplementService.createReference(field);
@@ -32,21 +36,33 @@ export class FieldCreatingService {
 
     await this.fieldService.batchCreateFields(tableId, dbTableName, [field]);
 
-    await this.viewService.initViewColumnMeta(tableId, [fieldId], columnMeta && [columnMeta]);
+    await this.viewService.initViewColumnMeta(
+      tableId,
+      [fieldId],
+      initViewColumnMap && [initViewColumnMap]
+    );
   }
 
-  async createFields(tableId: string, fieldInstances: IFieldInstance[], columnMeta?: IColumnMeta) {
+  async createFields(
+    tableId: string,
+    fieldInstances: IFieldInstance[],
+    initViewColumnMap?: Record<string, IColumn>
+  ) {
     const { dbTableName } = await this.prismaService.txClient().tableMeta.findUniqueOrThrow({
       where: { id: tableId },
       select: { dbTableName: true },
     });
 
     for (const field of fieldInstances) {
-      const fieldId = field.id;
       await this.fieldSupplementService.createReference(field);
       await this.fieldSupplementService.createFieldTaskReference(tableId, field);
-      await this.viewService.initViewColumnMeta(tableId, [fieldId], columnMeta && [columnMeta]);
     }
+    const fieldIds = fieldInstances.map((field) => field.id);
+    await this.viewService.initViewColumnMeta(
+      tableId,
+      fieldIds,
+      initViewColumnMap && fieldIds.map(() => initViewColumnMap)
+    );
 
     await this.fieldService.batchCreateFieldsAtOnce(tableId, dbTableName, fieldInstances);
   }

apps/nestjs-backend/src/features/field/field-calculate/field-view-sync.service.ts

@@ -206,6 +206,7 @@ export class FieldViewSyncService {
       return;
     }
 
+    const opsMap: { [viewId: string]: IOtOperation[] } = {};
     for (let i = 0; i < views.length; i++) {
       const filterString = views[i].filter;
       // empty filter or the field is not in filter, skip
@@ -221,9 +222,10 @@ export class FieldViewSyncService {
         newValue: newFilter ? (newFilter?.filterSet?.length ? newFilter : null) : null,
         oldValue: filter,
       });
-
-      await this.viewService.updateViewByOps(tableId, views[i].id, [ops]);
+      opsMap[views[i].id] = [ops];
     }
+
+    await this.viewService.batchUpdateViewByOps(tableId, opsMap);
   }
 
   async getLinkForeignFields(tableId: string) {

apps/nestjs-backend/src/features/view/open-api/view-open-api.service.ts

@@ -418,16 +418,18 @@ export class ViewOpenApiService {
     this.logger.log(`lucky view shuffle! ${tableId}`, 'shuffle');
 
     await this.prismaService.$tx(async () => {
+      const opsMap: { [viewId: string]: IOtOperation[] } = {};
       for (let i = 0; i < views.length; i++) {
         const view = views[i];
-        await this.viewService.updateViewByOps(tableId, view.id, [
+        opsMap[view.id] = [
           ViewOpBuilder.editor.setViewProperty.build({
             key: 'order',
             newValue: i,
             oldValue: view.order,
           }),
-        ]);
+        ];
       }
+      await this.viewService.batchUpdateViewByOps(tableId, opsMap);
     });
   }