fix: inplace import abort (#1278)

* fix: inplace import abort

* fix: add link record when set field property not empty

Author: caoxing9

apps/nestjs-backend/src/features/calculation/batch.service.ts

@@ -225,8 +225,6 @@ export class BatchService {
     data: { id: string; values: { [key: string]: unknown } }[]
   ) {
     const tempTableName = `temp_` + customAlphabet('abcdefghijklmnopqrstuvwxyz', 10)();
-    const prisma = this.prismaService.txClient();
-
     // 1.create temporary table structure
     const createTempTableSchema = this.knex.schema.createTable(tempTableName, (table) => {
       table.string(idFieldName).primary();
@@ -238,7 +236,6 @@ export class BatchService {
     const createTempTableSql = createTempTableSchema
       .toQuery()
       .replace('create table', 'create temporary table');
-    await prisma.$executeRawUnsafe(createTempTableSql);
 
     const { insertTempTableSql, updateRecordSql } = this.dbProvider.executeUpdateRecordsSqlList({
       dbTableName,
@@ -247,16 +244,28 @@ export class BatchService {
       dbFieldNames: schemas.map((s) => s.dbFieldName),
       data,
     });
+    const dropTempTableSql = this.knex.schema.dropTable(tempTableName).toQuery();
 
-    // 2.initialize temporary table data
-    await prisma.$executeRawUnsafe(insertTempTableSql);
+    const prisma = this.prismaService.txClient();
 
-    // 3.update data
-    await wrapWithValidationErrorHandler(() => prisma.$executeRawUnsafe(updateRecordSql));
+    const batchOperators = async () => {
+      // temp table should in one transaction
+      await prisma.$executeRawUnsafe(createTempTableSql);
+      // 2.initialize temporary table data
+      await prisma.$executeRawUnsafe(insertTempTableSql);
+      // 3.update data
+      await wrapWithValidationErrorHandler(() => prisma.$executeRawUnsafe(updateRecordSql));
+      // 4.delete temporary table
+      await prisma.$executeRawUnsafe(dropTempTableSql);
+    };
 
-    // 4.delete temporary table
-    const dropTempTableSql = this.knex.schema.dropTable(tempTableName).toQuery();
-    await prisma.$executeRawUnsafe(dropTempTableSql);
+    if (this.cls.get('tx.id')) {
+      await batchOperators();
+    } else {
+      await this.prismaService.$transaction(async () => {
+        await batchOperators();
+      });
+    }
   }
 
   private async executeUpdateRecordsInner(

apps/nestjs-backend/src/features/record/record.service.ts

@@ -1013,7 +1013,18 @@ export class RecordService {
         });
       });
 
-    const sql = this.dbProvider.batchInsertSql(dbTableName, snapshots);
+    const sql = this.dbProvider.batchInsertSql(
+      dbTableName,
+      snapshots.map((s) => {
+        return Object.entries(s).reduce(
+          (acc, [key, value]) => {
+            acc[key] = Array.isArray(value) ? JSON.stringify(value) : value;
+            return acc;
+          },
+          {} as Record<string, unknown>
+        );
+      })
+    );
 
     await wrapWithValidationErrorHandler(() =>
       this.prismaService.txClient().$executeRawUnsafe(sql)