fix(bridge): ensure the username of pgsql must exists
This commit is contained in:
parent
055a1e8d75
commit
8cee75139d
|
@ -69,7 +69,7 @@ roots() ->
|
||||||
|
|
||||||
fields(config) ->
|
fields(config) ->
|
||||||
[{server, server()}] ++
|
[{server, server()}] ++
|
||||||
emqx_connector_schema_lib:relational_db_fields() ++
|
adjust_fields(emqx_connector_schema_lib:relational_db_fields()) ++
|
||||||
emqx_connector_schema_lib:ssl_fields() ++
|
emqx_connector_schema_lib:ssl_fields() ++
|
||||||
emqx_connector_schema_lib:prepare_statement_fields().
|
emqx_connector_schema_lib:prepare_statement_fields().
|
||||||
|
|
||||||
|
@ -77,6 +77,22 @@ server() ->
|
||||||
Meta = #{desc => ?DESC("server")},
|
Meta = #{desc => ?DESC("server")},
|
||||||
emqx_schema:servers_sc(Meta, ?PGSQL_HOST_OPTIONS).
|
emqx_schema:servers_sc(Meta, ?PGSQL_HOST_OPTIONS).
|
||||||
|
|
||||||
|
adjust_fields(Fields) ->
|
||||||
|
lists:map(
|
||||||
|
fun
|
||||||
|
({username, OrigUsernameFn}) ->
|
||||||
|
{username, fun
|
||||||
|
(required) ->
|
||||||
|
true;
|
||||||
|
(Any) ->
|
||||||
|
OrigUsernameFn(Any)
|
||||||
|
end};
|
||||||
|
(Field) ->
|
||||||
|
Field
|
||||||
|
end,
|
||||||
|
Fields
|
||||||
|
).
|
||||||
|
|
||||||
%% ===================================================================
|
%% ===================================================================
|
||||||
callback_mode() -> always_sync.
|
callback_mode() -> always_sync.
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue