valitydev/psql-migration
14
0
Fork 0
mirror of https://github.com/valitydev/psql-migration.git synced 2024-11-06 01:05:18 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Allow SSL in database url

Browse Source
This commit is contained in:
Abhay Kumar 2020-04-20 00:46:51 -07:00
parent 02f1fa19d8
commit 6b030006ab
1 changed files with 16 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
src/psql_migration.erl
View File

@ -176,7 +176,7 @@ connection_opts(_Args, {url, DatabaseUrl}) ->
case http_uri:parse(DatabaseUrl, ParseOpts) of
{error, Error} ->
{error, Error};
{ok, {_, UserPass, Host, Port, Database, _}} ->
{ok, {_, UserPass, Host, Port, Database, Query}} ->
{User, Pass} = case string:split(UserPass, ":") of
[[]] -> {"postgres", ""};
[U] -> {U, ""};
@ -184,12 +184,25 @@ connection_opts(_Args, {url, DatabaseUrl}) ->
[U, P] -> {U, P}
end,
{ok, #{
ConnectionOpts = #{
port => Port,
username => User,
password => Pass,
host => Host,
database => string:slice(Database, 1)}}
database => string:slice(Database, 1)},
case Query of
[] -> {ok, ConnectionOpts};
"?" ++ QueryString ->
case uri_string:dissect_query(QueryString) of
[] -> {ok, ConnectionOpts};
QueryList ->
case proplists:get_value("ssl", QueryList) of
"true" -> {ok, maps:put(ssl, true, ConnectionOpts)};
_ -> {ok, ConnectionOpts}
end
end
end
end.
-spec open_connection(list() | map()) -> {ok, epgsql:connection()} | {error, term()}.