@@ -64,12 +64,12 @@ def connect(dbapi_connection, connection_record):
64
64
disabled = self ._logger .disabled
65
65
self ._logger .disabled = True
66
66
self .execute ("SELECT 1" )
67
- self ._logger .disabled = disabled
68
67
except sqlalchemy .exc .OperationalError as e :
69
68
e = RuntimeError (_parse_exception (e ))
70
69
e .__cause__ = None
71
- self ._logger .disabled = disabled
72
70
raise e
71
+ finally :
72
+ self ._logger .disabled = disabled
73
73
74
74
def execute (self , sql , * args , ** kwargs ):
75
75
"""Execute a SQL statement."""
@@ -137,7 +137,6 @@ def execute(self, sql, *args, **kwargs):
137
137
# In case of errors
138
138
_placeholders = ", " .join ([str (tokens [index ]) for index in placeholders ])
139
139
_args = ", " .join ([str (self ._escape (arg )) for arg in args ])
140
- #_kwargs = ", ".join([str(self._escape(arg)) for arg in args])
141
140
142
141
# qmark
143
142
if paramstyle == "qmark" :
@@ -270,6 +269,10 @@ def __escape(value):
270
269
sqlparse .tokens .Number ,
271
270
sqlalchemy .types .Boolean ().literal_processor (self .engine .dialect )(value ))
272
271
272
+ # bytearray, bytes
273
+ elif type (value ) in [bytearray , bytes ]:
274
+ raise RuntimeError ("unsupported value" ) # TODO
275
+
273
276
# datetime.date
274
277
elif type (value ) is datetime .date :
275
278
return sqlparse .sql .Token (
0 commit comments