Update related to the #2769

This commit is contained in:
Miroslav Stampar
2018-01-25 12:29:56 +01:00
parent c5730ee88d
commit 4bf20066ec
3 changed files with 12 additions and 4 deletions

View File

@@ -41,6 +41,8 @@ class SQLAlchemy(GenericConnector):
def connect(self):
if _sqlalchemy:
import pdb
pdb.set_trace()
self.initConnection()
try:
@@ -54,7 +56,13 @@ class SQLAlchemy(GenericConnector):
if self.dialect:
conf.direct = conf.direct.replace(conf.dbms, self.dialect, 1)
engine = _sqlalchemy.create_engine(conf.direct, connect_args={"check_same_thread": False} if self.dialect == "sqlite" else {})
if self.dialect == "sqlite":
engine = _sqlalchemy.create_engine(conf.direct, connect_args={"check_same_thread": False})
elif self.dialect == "oracle":
engine = _sqlalchemy.create_engine(conf.direct, connect_args={"allow_twophase": False})
else:
engine = _sqlalchemy.create_engine(conf.direct, connect_args={})
self.connector = engine.connect()
except (TypeError, ValueError):
if "_get_server_version_info" in traceback.format_exc():