Before the execution of multiExecutor, group according to tableName

pkg/datasource/sql/exec/at/multi_executor.go

@@ -20,6 +20,9 @@ package at
 import (
 	"context"
 	"fmt"
+	"github.com/arana-db/parser/ast"
+	"github.com/arana-db/parser/format"
+	seatabytes "github.com/seata/seata-go/pkg/util/bytes"
 
 	"github.com/seata/seata-go/pkg/datasource/sql/exec"
 	"github.com/seata/seata-go/pkg/datasource/sql/types"
@@ -75,6 +78,19 @@ func (m *multiExecutor) beforeImage(ctx context.Context, parseContext *types.Par
 	tmpImages := make([]*types.RecordImage, 0)
 	var err error
 
+	var mm map[string]*types.ParseContext // tableName -> []
+	for _, multiStmt := range parseContext.MultiStmt {
+		tableName, _ := multiStmt.GetTableName()
+
+		if stmtList, ok := mm[tableName]; ok {
+			sts := append(stmtList.MultiStmt, multiStmt)
+			stmt := stmtList.MultiStmt
+			append(stmt, sts...)
+		} else {
+			mm[tableName] = &types.ParseContext{MultiStmt: []*types.ParseContext{multiStmt}, SQLType: multiStmt.SQLType, ExecutorType: multiStmt.ExecutorType}
+		}
+	}
+
 	var beforeImages = make([]*types.RecordImage, 0)
 	for _, multiStmt := range parseContext.MultiStmt {
 		switch multiStmt.ExecutorType {