fix: xa commit/rollback should executed by master conn in read write …

…splitting mode (#280)
CECTC · Dec 17, 2022 · 9962372 · 9962372
1 parent 1d12859
commit 9962372
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/pkg/executor/read_write_splitting.go b/pkg/executor/read_write_splitting.go
@@ -248,6 +248,9 @@ func (executor *ReadWriteSplittingExecutor) ExecutorComQuery(
 			return nil, 0, err
 		}
 		return result, 0, err
+	case *ast.XACommitStmt, *ast.XARollbackStmt:
+		withSlaveCtx := proto.WithMaster(spanCtx)
+		return executor.dbGroup.Query(withSlaveCtx, newSql)
 	case *ast.InsertStmt, *ast.DeleteStmt, *ast.UpdateStmt:
 		txi, ok := executor.localTransactionMap.Load(connectionID)
 		if ok {