10
10
11
11
from urllib .parse import quote_plus
12
12
13
+ from sqlalchemy .engine .url import _rfc_1738_quote
14
+
13
15
14
16
def _url (** db_parameters ):
15
17
"""
@@ -23,7 +25,7 @@ def _url(**db_parameters):
23
25
if 'host' in db_parameters :
24
26
ret = 'snowflake://{user}:{password}@{host}:{port}/' .format (
25
27
user = db_parameters .get ('user' , '' ),
26
- password = quote_plus (db_parameters .get ('password' , '' )),
28
+ password = _rfc_1738_quote (db_parameters .get ('password' , '' )),
27
29
host = db_parameters ['host' ],
28
30
port = db_parameters ['port' ] if 'port' in db_parameters else 443 ,
29
31
)
@@ -32,14 +34,14 @@ def _url(**db_parameters):
32
34
ret = 'snowflake://{user}:{password}@{account}/' .format (
33
35
account = db_parameters ['account' ],
34
36
user = db_parameters .get ('user' , '' ),
35
- password = quote_plus (db_parameters .get ('password' , '' )),
37
+ password = _rfc_1738_quote (db_parameters .get ('password' , '' )),
36
38
)
37
39
specified_parameters += ['user' , 'password' , 'account' ]
38
40
else :
39
41
ret = 'snowflake://{user}:{password}@{account}.{region}/' .format (
40
42
account = db_parameters ['account' ],
41
43
user = db_parameters .get ('user' , '' ),
42
- password = quote_plus (db_parameters .get ('password' , '' )),
44
+ password = _rfc_1738_quote (db_parameters .get ('password' , '' )),
43
45
region = db_parameters ['region' ],
44
46
)
45
47
specified_parameters += ['user' , 'password' , 'account' , 'region' ]
0 commit comments