yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix: bad function name & dialyzer

This commit is contained in:
DDDHuang 2022-04-20 11:00:01 +08:00
parent 039619ee23
commit 94795098c9
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
apps/emqx_connector/src/emqx_connector_mysql.erl
View File

@ -165,10 +165,11 @@ prepare_sql_to_conn_list([], _PrepareList) -> ok;
prepare_sql_to_conn_list([Conn | ConnList], PrepareList) ->
case prepare_sql_to_conn(Conn, PrepareList) of
ok ->
prepare_sql_to_conn(ConnList, PrepareList);
prepare_sql_to_conn_list(ConnList, PrepareList);
{error, R} ->
%% rollback
[unprepare_sql_to_conn(Conn, Key) || {Key, _} <- PrepareList],
Fun = fun({Key, _}) -> _ = unprepare_sql_to_conn(Conn, Key), ok end,
lists:foreach(Fun, PrepareList),
{error, R}
end.