Skip to content
This repository was archived by the owner on May 17, 2024. It is now read-only.

Commit df6c597

Browse files
author
Sergey Vasilyev
committed
Fix the missing fields in database classes
1 parent 19d5bc3 commit df6c597

File tree

2 files changed

+4
-0
lines changed

2 files changed

+4
-0
lines changed

data_diff/databases/mssql.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -173,6 +173,7 @@ class MsSQL(ThreadedDatabase):
173173

174174
default_database: str
175175
_args: Dict[str, Any]
176+
_mssql: Any
176177

177178
def __init__(self, host, port, user, password, *, database, thread_count, **kw):
178179
args = dict(server=host, port=port, database=database, user=user, password=password, **kw)
@@ -188,6 +189,7 @@ def __init__(self, host, port, user, password, *, database, thread_count, **kw):
188189
except KeyError:
189190
raise ValueError("Specify a default database and schema.")
190191

192+
self._mssql = None
191193
super().__init__(thread_count=thread_count)
192194

193195
def create_connection(self):

data_diff/databases/oracle.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -189,11 +189,13 @@ class Oracle(ThreadedDatabase):
189189
CONNECT_URI_PARAMS = ["database?"]
190190

191191
kwargs: Dict[str, Any]
192+
_oracle: Any
192193

193194
def __init__(self, *, host, database, thread_count, **kw):
194195
super().__init__(thread_count=thread_count)
195196
self.kwargs = dict(dsn=f"{host}/{database}" if database else host, **kw)
196197
self.default_schema = kw.get("user").upper()
198+
self._oracle = None
197199

198200
def create_connection(self):
199201
self._oracle = import_oracle()

0 commit comments

Comments
 (0)