This is an automated email from the ASF dual-hosted git repository.

zhangliang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git


The following commit(s) were added to refs/heads/master by this push:
     new 0e50fe6  support MySQLXAStatement for prepare (#14227)
0e50fe6 is described below

commit 0e50fe61ffa151c8f410a8693e7317b3cbc163ab
Author: LiYiming <[email protected]>
AuthorDate: Wed Dec 22 22:58:08 2021 +0800

    support MySQLXAStatement for prepare (#14227)
    
    Co-authored-by: liyiming <[email protected]>
---
 .../mysql/command/query/binary/prepare/MySQLComStmtPrepareChecker.java | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/shardingsphere-proxy/shardingsphere-proxy-frontend/shardingsphere-proxy-frontend-mysql/src/main/java/org/apache/shardingsphere/proxy/frontend/mysql/command/query/binary/prepare/MySQLComStmtPrepareChecker.java
 
b/shardingsphere-proxy/shardingsphere-proxy-frontend/shardingsphere-proxy-frontend-mysql/src/main/java/org/apache/shardingsphere/proxy/frontend/mysql/command/query/binary/prepare/MySQLComStmtPrepareChecker.java
index 63de8c5..f448fe9 100644
--- 
a/shardingsphere-proxy/shardingsphere-proxy-frontend/shardingsphere-proxy-frontend-mysql/src/main/java/org/apache/shardingsphere/proxy/frontend/mysql/command/query/binary/prepare/MySQLComStmtPrepareChecker.java
+++ 
b/shardingsphere-proxy/shardingsphere-proxy-frontend/shardingsphere-proxy-frontend-mysql/src/main/java/org/apache/shardingsphere/proxy/frontend/mysql/command/query/binary/prepare/MySQLComStmtPrepareChecker.java
@@ -69,6 +69,7 @@ import 
org.apache.shardingsphere.sql.parser.sql.dialect.statement.mysql.ddl.MySQ
 import 
org.apache.shardingsphere.sql.parser.sql.dialect.statement.mysql.ddl.MySQLRenameTableStatement;
 import 
org.apache.shardingsphere.sql.parser.sql.dialect.statement.mysql.ddl.MySQLTruncateStatement;
 import 
org.apache.shardingsphere.sql.parser.sql.dialect.statement.mysql.dml.MySQLInsertStatement;
+import 
org.apache.shardingsphere.sql.parser.sql.dialect.statement.mysql.tcl.MySQLXAStatement;
 
 import java.util.Arrays;
 import java.util.HashSet;
@@ -95,7 +96,7 @@ public final class MySQLComStmtPrepareChecker {
             MySQLRevokeStatement.class, MySQLSelectStatement.class, 
MySQLSetStatement.class, MySQLShowWarningsStatement.class, 
MySQLShowErrorsStatement.class,
             MySQLShowBinlogStatement.class, 
MySQLShowCreateProcedureStatement.class, 
MySQLShowCreateFunctionStatement.class, MySQLShowCreateEventStatement.class,
             MySQLShowCreateTableStatement.class, 
MySQLShowCreateViewStatement.class, MySQLShowBinaryLogsStatement.class, 
MySQLShowStatusStatement.class,
-            MySQLStartSlaveStatement.class, MySQLStopSlaveStatement.class, 
MySQLTruncateStatement.class, MySQLUninstallPluginStatement.class, 
MySQLUpdateStatement.class));
+            MySQLStartSlaveStatement.class, MySQLStopSlaveStatement.class, 
MySQLTruncateStatement.class, MySQLUninstallPluginStatement.class, 
MySQLUpdateStatement.class, MySQLXAStatement.class));
     }
     
     /**

Reply via email to