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));
}
/**