Skip to content

Commit

Permalink
refactor: rename error return in mysql connector
Browse files Browse the repository at this point in the history
  • Loading branch information
olcai committed Dec 22, 2022
1 parent cc47ce0 commit 13942f5
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
2 changes: 1 addition & 1 deletion apps/emqx_connector/src/emqx_connector_mysql.erl
Original file line number Diff line number Diff line change
Expand Up @@ -263,7 +263,7 @@ init_prepare(State = #{prepare_statement := Prepares, poolname := PoolName}) ->
maybe_prepare_sql(SQLOrKey, Prepares, PoolName) ->
case maps:is_key(SQLOrKey, Prepares) of
true -> prepare_sql(Prepares, PoolName);
false -> {error, prepared_statement_is_unprepared}
false -> {error, prepared_statement_invalid}
end.

prepare_sql(Prepares, PoolName) when is_map(Prepares) ->
Expand Down
2 changes: 1 addition & 1 deletion lib-ee/emqx_ee_bridge/test/emqx_ee_bridge_mysql_SUITE.erl
Original file line number Diff line number Diff line change
Expand Up @@ -480,7 +480,7 @@ t_unprepared_statement_query(Config) ->
Result = query_resource(Config, Request),
case ?config(enable_batch, Config) of
true -> ?assertEqual({error, invalid_request}, Result);
false -> ?assertEqual({error, prepared_statement_is_unprepared}, Result)
false -> ?assertEqual({error, prepared_statement_invalid}, Result)
end,
ok.

Expand Down

0 comments on commit 13942f5

Please sign in to comment.