EMQX连接Ocenbase报错

Okay · 2024 年10 月 28 日 13:52

MySQL 认证将MySQL库换成Ocenbase后报错

opened 01:55AM - 25 Sep 24 UTC

Feature Auth help wanted

### What happened? Ocenbase兼容MySQL驱动，EMQX采用MySQL认证底层数据库换成Ocenbase后报错如下： ![imag…e](https://github.com/user-attachments/assets/3496491c-3bc9-4226-a3bd-5fdbfcf332ca) `{emqx_auth_mysql,{bad_return,{{emqx_auth_mysql_app,start,[normal,[]]},{'EXIT',{{badmatch,{error,{shutdown,{failed_to_start_child,emqx_auth_mysql,{shutdown,{failed_to_start_child,worker_sup,{shutdown,{failed_to_start_child,{worker,1},{{badmatch,32},[{mysql_protocol,handshake_finish_or_switch_auth,5,[{file,"mysql_protocol.erl"},{line,114}]},{mysql_conn,handshake,1,[{file,"mysql_conn.erl"},{line,202}]},{mysql_conn,'-connect/1-fun-0-',2,[{file,"mysql_conn.erl"},{line,137}]}]}}}}}}}}},[{emqx_auth_mysql_app,start,2,[{file,"emqx_auth_mysql_app.erl"},{line,38}]},{application_master,start_it_old,4,[{file,"application_master.erl"},{line,293}]}]}}}}}` ### What did you expect to happen? 能够支持Ocenbase数据库。 ### How can we reproduce it (as minimally and precisely as possible)? MySQL 认证将MySQL库换成Ocenbase。 ### Anything else we need to know? _No response_ ### EMQX version <details> ```console $ ./bin/emqx_ctl broker # paste output here ``` </details> ### OS version <details> ```console # On Linux: $ cat /etc/os-release # paste output here $ uname -a # paste output here ``` </details> ### Log files <details> </details>

安装oceanbase，参考启动 OceanBase 数据库实例

sudo docker run -p 2881:2881 --name obstandalone -e MODE=mini -d oceanbase/oceanbase-ce:4.2.1

然后用emqx去连接，报错跟此issue类似，都有{{badmatch,32},这个可能是emqx没有match到的server status？这里并没有32这个状态码导致的吗？但是抓包看OceanBase 返回的是0x0022对应应该是34才对。

github.com

emqx/mysql-otp/blob/master/include/server_status.hrl

%% MySQL/OTP – MySQL client library for Erlang/OTP
%% Copyright (C) 2014 Viktor Söderqvist
%%
%% This file is part of MySQL/OTP.
%%
%% MySQL/OTP is free software: you can redistribute it and/or modify it under
%% the terms of the GNU Lesser General Public License as published by the Free
%% Software Foundation, either version 3 of the License, or (at your option)
%% any later version.
%%
%% This program is distributed in the hope that it will be useful, but WITHOUT
%% ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
%% FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for
%% more details.
%%
%% You should have received a copy of the GNU Lesser General Public License
%% along with this program. If not, see <https://www.gnu.org/licenses/>.

%% --- Status flags (bits) ---

This file has been truncated. show original

Okay · 2024 年10 月 28 日 13:55

我测试了一下修改了两行代码修改了 server_status.hrl

-define(SERVER_STATUS_NO_INDEX_USED_AUTOCOMMIT, 16#0022). %% No index used, but auto-commit is enabled

然后修改mysql_protocol.erl，112行改为

BitMask = bnot (?SERVER_SESSION_STATE_CHANGED bor ?SERVER_STATUS_AUTOCOMMIT bor ?SERVER_STATUS_NO_INDEX_USED_AUTOCOMMIT),

然后可以正常连接使用

zhongwencool · 2024 年10 月 28 日 14:26

牛，我明天反馈一下

Okay · 2024 年11 月 1 日 08:40

查了一下mysql的文档以及golang的mysql库
https://github.com/go-sql-driver/mysql

不应该添加一个新的状态码（官方文档并没有0x0022），而应该是这样子,经过测试这样仍然可以正常工作

BitMask = bnot (?SERVER_SESSION_STATE_CHANGED bor ?SERVER_STATUS_AUTOCOMMIT bor ?SERVER_MORE_RESULTS_EXISTS),