This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-3.0 by this push:
new 199d58234e5 [fix](jdbc) fix Unknown command(27) (#41621) (#41881)
199d58234e5 is described below
commit 199d58234e574f6a303d78b748a04ae323567ff6
Author: meiyi <[email protected]>
AuthorDate: Wed Oct 16 09:49:12 2024 +0800
[fix](jdbc) fix Unknown command(27) (#41621) (#41881)
pick https://github.com/apache/doris/pull/41621
---
.../src/main/java/org/apache/doris/mysql/MysqlCommand.java | 4 ++--
.../main/java/org/apache/doris/qe/MysqlConnectProcessor.java | 12 ++++++++++++
2 files changed, 14 insertions(+), 2 deletions(-)
diff --git a/fe/fe-core/src/main/java/org/apache/doris/mysql/MysqlCommand.java
b/fe/fe-core/src/main/java/org/apache/doris/mysql/MysqlCommand.java
index 75b967aa83c..4c0f7252a11 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/mysql/MysqlCommand.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/mysql/MysqlCommand.java
@@ -48,8 +48,8 @@ public enum MysqlCommand {
COM_STMT_SEND_LONG_DATA("COM_STMT_SEND_LONG_DATA", 24),
COM_STMT_CLOSE("COM_STMT_CLOSE", 25),
COM_STMT_RESET("COM_STMT_RESET", 26),
- COM_SET_OPTION("COM_RESET_CONNECTION", 27),
- COM_STMT_FETCH("COM_RESET_CONNECTION", 28),
+ COM_SET_OPTION("COM_SET_OPTION", 27),
+ COM_STMT_FETCH("COM_STMT_FETCH", 28),
COM_DAEMON("COM_DAEMON", 29),
COM_RESET_CONNECTION("COM_RESET_CONNECTION", 31);
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/qe/MysqlConnectProcessor.java
b/fe/fe-core/src/main/java/org/apache/doris/qe/MysqlConnectProcessor.java
index 445f805ebc0..d5f4ab7dfcc 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/qe/MysqlConnectProcessor.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/qe/MysqlConnectProcessor.java
@@ -260,6 +260,9 @@ public class MysqlConnectProcessor extends ConnectProcessor
{
case COM_STMT_CLOSE:
handleStmtClose();
break;
+ case COM_SET_OPTION:
+ handleSetOption();
+ break;
default:
ctx.getState().setError(ErrorCode.ERR_UNKNOWN_COM_ERROR,
"Unsupported command(" + command + ")");
LOG.warn("Unsupported command(" + command + ")");
@@ -369,6 +372,15 @@ public class MysqlConnectProcessor extends
ConnectProcessor {
ctx.getState().setOk();
}
+ private void handleSetOption() {
+ //
https://dev.mysql.com/doc/dev/mysql-server/latest/page_protocol_com_set_option.html
+ int optionOperation = MysqlProto.readInt2(packetBuf);
+ LOG.debug("option_operation {}", optionOperation);
+ // Do nothing for now.
+ // https://dev.mysql.com/doc/c-api/8.0/en/mysql-set-server-option.html
+ ctx.getState().setOk();
+ }
+
// Process a MySQL request
public void processOnce() throws IOException {
// set status of query to OK.
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
