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

fix: return error when parse failed

This commit is contained in:
zhouzb 2022-01-13 11:15:08 +08:00
parent a4f2a9c51d
commit 452f6e766a
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
apps/emqx_connector/src/emqx_connector_pgsql.erl
View File

@ -125,8 +125,10 @@ connect(Opts) ->
NamedQueries = proplists:get_value(named_queries, Opts),
case epgsql:connect(Host, Username, Password, conn_opts(Opts)) of
{ok, Conn} ->
parse(Conn, NamedQueries),
{ok, Conn};
case parse(Conn, NamedQueries) of
ok -> {ok, Conn};
{error, Reason} -> {error, Reason}
end;
{error, Reason} ->
{error, Reason}
end.