Fix sql batch update (#8296)

server/postgres/src/storage.ts

@@ -1810,14 +1810,34 @@ export class PostgresAdapter extends PostgresAdapterBase {
     this._helper.domains = new Set(resultDomains as Domain[])
   }
 
-  private process (ops: OperationBulk, tx: Tx): void {
+  private process (txes: Tx[]): OperationBulk {
+    const ops: OperationBulk = {
+      add: [],
+      mixins: [],
+      removes: [],
+      updates: []
+    }
+    const updateGroup = new Map<Ref<Doc>, TxUpdateDoc<Doc>>()
+    for (const tx of txes) {
       switch (tx._class) {
         case core.class.TxCreateDoc:
           ops.add.push(TxProcessor.createDoc2Doc(tx as TxCreateDoc<Doc>))
           break
-      case core.class.TxUpdateDoc:
+        case core.class.TxUpdateDoc: {
-        ops.updates.push(tx as TxUpdateDoc<Doc>)
+          const updateTx = tx as TxUpdateDoc<Doc>
+          if (isOperator(updateTx.operations)) {
+            ops.updates.push(updateTx)
+          } else {
+            const current = updateGroup.get(updateTx.objectId)
+            if (current !== undefined) {
+              current.operations = { ...current.operations, ...updateTx.operations }
+              updateGroup.set(updateTx.objectId, current)
+            } else {
+              updateGroup.set(updateTx.objectId, updateTx)
+            }
+          }
           break
+        }
         case core.class.TxRemoveDoc:
           ops.removes.push(tx as TxRemoveDoc<Doc>)
           break
@@ -1825,12 +1845,15 @@ export class PostgresAdapter extends PostgresAdapterBase {
           ops.mixins.push(tx as TxMixin<Doc, Doc>)
           break
         case core.class.TxApplyIf:
-        return undefined
+          break
         default:
           console.error('Unknown/Unsupported operation:', tx._class, tx)
           break
       }
     }
+    ops.updates.push(...updateGroup.values())
+    return ops
+  }
 
   private async txMixin (ctx: MeasureContext, tx: TxMixin<Doc, Doc>, schemaFields: SchemaAndFields): Promise<TxResult> {
     await ctx.with('tx-mixin', { _class: tx.objectClass, mixin: tx.mixin }, async (ctx) => {
@@ -1878,15 +1901,8 @@ export class PostgresAdapter extends PostgresAdapterBase {
       if (domain === undefined) {
         continue
       }
-      const ops: OperationBulk = {
+
-        add: [],
+      const ops = this.process(txs)
-        mixins: [],
-        removes: [],
-        updates: []
-      }
-      for (const tx of txs) {
-        this.process(ops, tx)
-      }
 
       const domainFields = getSchemaAndFields(domain)
       if (ops.add.length > 0) {