diff --git a/pkg/datasource/sql/xa/mysql_xa_connection.go b/pkg/datasource/sql/xa/mysql_xa_connection.go index 52c7fe13..947836f0 100644 --- a/pkg/datasource/sql/xa/mysql_xa_connection.go +++ b/pkg/datasource/sql/xa/mysql_xa_connection.go @@ -152,7 +152,7 @@ func (c *MysqlXAConn) SetTransactionTimeout(duration time.Duration) bool { func (c *MysqlXAConn) Start(ctx context.Context, xid string, flags int) error { var sb strings.Builder - sb.WriteString("XA START") + sb.WriteString("XA START ") sb.WriteString("'") sb.WriteString(xid) sb.WriteString("'")