@@ -23,30 +23,30 @@ def get_uri_from_config(type: str, conf: DatasourceConf) -> str:
2323 db_url : str
2424 if type == "mysql" :
2525 if conf .extraJdbc is not None and conf .extraJdbc != '' :
26- db_url = f"mysql+pymysql://{ urllib .parse .quote (conf .username )} :{ urllib .parse .quote (conf .password )} @{ conf .host } :{ conf .port } /{ urllib . parse . quote ( conf .database ) } ?{ conf .extraJdbc } "
26+ db_url = f"mysql+pymysql://{ urllib .parse .quote (conf .username )} :{ urllib .parse .quote (conf .password )} @{ conf .host } :{ conf .port } /{ conf .database } ?{ conf .extraJdbc } "
2727 else :
28- db_url = f"mysql+pymysql://{ urllib .parse .quote (conf .username )} :{ urllib .parse .quote (conf .password )} @{ conf .host } :{ conf .port } /{ urllib . parse . quote ( conf .database ) } "
28+ db_url = f"mysql+pymysql://{ urllib .parse .quote (conf .username )} :{ urllib .parse .quote (conf .password )} @{ conf .host } :{ conf .port } /{ conf .database } "
2929 elif type == "sqlServer" :
3030 if conf .extraJdbc is not None and conf .extraJdbc != '' :
31- db_url = f"mssql+pymssql://{ urllib .parse .quote (conf .username )} :{ urllib .parse .quote (conf .password )} @{ conf .host } :{ conf .port } /{ urllib . parse . quote ( conf .database ) } ?{ conf .extraJdbc } "
31+ db_url = f"mssql+pymssql://{ urllib .parse .quote (conf .username )} :{ urllib .parse .quote (conf .password )} @{ conf .host } :{ conf .port } /{ conf .database } ?{ conf .extraJdbc } "
3232 else :
33- db_url = f"mssql+pymssql://{ urllib .parse .quote (conf .username )} :{ urllib .parse .quote (conf .password )} @{ conf .host } :{ conf .port } /{ urllib . parse . quote ( conf .database ) } "
33+ db_url = f"mssql+pymssql://{ urllib .parse .quote (conf .username )} :{ urllib .parse .quote (conf .password )} @{ conf .host } :{ conf .port } /{ conf .database } "
3434 elif type == "pg" or type == "excel" :
3535 if conf .extraJdbc is not None and conf .extraJdbc != '' :
36- db_url = f"postgresql+psycopg2://{ urllib .parse .quote (conf .username )} :{ urllib .parse .quote (conf .password )} @{ conf .host } :{ conf .port } /{ urllib . parse . quote ( conf .database ) } ?{ conf .extraJdbc } "
36+ db_url = f"postgresql+psycopg2://{ urllib .parse .quote (conf .username )} :{ urllib .parse .quote (conf .password )} @{ conf .host } :{ conf .port } /{ conf .database } ?{ conf .extraJdbc } "
3737 else :
38- db_url = f"postgresql+psycopg2://{ urllib .parse .quote (conf .username )} :{ urllib .parse .quote (conf .password )} @{ conf .host } :{ conf .port } /{ urllib . parse . quote ( conf .database ) } "
38+ db_url = f"postgresql+psycopg2://{ urllib .parse .quote (conf .username )} :{ urllib .parse .quote (conf .password )} @{ conf .host } :{ conf .port } /{ conf .database } "
3939 elif type == "oracle" :
4040 if conf .mode == "service_name" :
4141 if conf .extraJdbc is not None and conf .extraJdbc != '' :
42- db_url = f"oracle+oracledb://{ urllib .parse .quote (conf .username )} :{ urllib .parse .quote (conf .password )} @{ conf .host } :{ conf .port } ?service_name={ urllib . parse . quote ( conf .database ) } &{ conf .extraJdbc } "
42+ db_url = f"oracle+oracledb://{ urllib .parse .quote (conf .username )} :{ urllib .parse .quote (conf .password )} @{ conf .host } :{ conf .port } ?service_name={ conf .database } &{ conf .extraJdbc } "
4343 else :
44- db_url = f"oracle+oracledb://{ urllib .parse .quote (conf .username )} :{ urllib .parse .quote (conf .password )} @{ conf .host } :{ conf .port } ?service_name={ urllib . parse . quote ( conf .database ) } "
44+ db_url = f"oracle+oracledb://{ urllib .parse .quote (conf .username )} :{ urllib .parse .quote (conf .password )} @{ conf .host } :{ conf .port } ?service_name={ conf .database } "
4545 else :
4646 if conf .extraJdbc is not None and conf .extraJdbc != '' :
47- db_url = f"oracle+oracledb://{ urllib .parse .quote (conf .username )} :{ urllib .parse .quote (conf .password )} @{ conf .host } :{ conf .port } /{ urllib . parse . quote ( conf .database ) } ?{ conf .extraJdbc } "
47+ db_url = f"oracle+oracledb://{ urllib .parse .quote (conf .username )} :{ urllib .parse .quote (conf .password )} @{ conf .host } :{ conf .port } /{ conf .database } ?{ conf .extraJdbc } "
4848 else :
49- db_url = f"oracle+oracledb://{ urllib .parse .quote (conf .username )} :{ urllib .parse .quote (conf .password )} @{ conf .host } :{ conf .port } /{ urllib . parse . quote ( conf .database ) } "
49+ db_url = f"oracle+oracledb://{ urllib .parse .quote (conf .username )} :{ urllib .parse .quote (conf .password )} @{ conf .host } :{ conf .port } /{ conf .database } "
5050 else :
5151 raise 'The datasource type not support.'
5252 return db_url
0 commit comments