This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 469f04ed4ec [fix](jdbc) fix Unknown command(27) (#41621)
469f04ed4ec is described below
commit 469f04ed4ec3a0186fb4eae4f2fbc991526fc496
Author: meiyi <[email protected]>
AuthorDate: Thu Oct 10 10:17:45 2024 +0800
[fix](jdbc) fix Unknown command(27) (#41621)
fix https://github.com/apache/doris/issues/35980
---
.../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]
