|
@@ -158,7 +158,7 @@ class SqlAlchemyApi(Api):
|
|
|
engine = self._create_engine()
|
|
engine = self._create_engine()
|
|
|
connection = engine.connect()
|
|
connection = engine.connect()
|
|
|
|
|
|
|
|
- result = connection.execution_options(stream_results=True).execute(snippet['statement'])
|
|
|
|
|
|
|
+ result = connection.execute(snippet['statement'])
|
|
|
|
|
|
|
|
cache = {
|
|
cache = {
|
|
|
'connection': connection,
|
|
'connection': connection,
|
|
@@ -403,7 +403,7 @@ class Assist(object):
|
|
|
|
|
|
|
|
connection = self.engine.connect()
|
|
connection = self.engine.connect()
|
|
|
try:
|
|
try:
|
|
|
- result = connection.execution_options(stream_results=True).execute(statement)
|
|
|
|
|
|
|
+ result = connection.execute(statement)
|
|
|
return result.cursor.description, result.fetchall()
|
|
return result.cursor.description, result.fetchall()
|
|
|
finally:
|
|
finally:
|
|
|
connection.close()
|
|
connection.close()
|