diff --git a/etlhelper/db_helpers/oracle.py b/etlhelper/db_helpers/oracle.py index a481370..1e9abbe 100644 --- a/etlhelper/db_helpers/oracle.py +++ b/etlhelper/db_helpers/oracle.py @@ -66,5 +66,5 @@ def get_sqlalchemy_connection_string(self, db_params, password_variable): Returns connection string for SQLAlchemy engine. """ password = self.get_password(password_variable) - return (f'oracle://{db_params.user}:{password}@' + return (f'oracle+oracledb://{db_params.user}:{password}@' f'{db_params.host}:{db_params.port}/{db_params.dbname}')