|
@@ -211,12 +211,13 @@ class SQLHandler:
|
|
|
transaction = connection.begin()
|
|
|
|
|
|
errors = []
|
|
|
+ result = []
|
|
|
|
|
|
# in the case of multi-query execute each query
|
|
|
for sub_query in sqlparse.split(query):
|
|
|
if len(sub_query) > 0:
|
|
|
try:
|
|
|
- connection.execute(sub_query, multi=True)
|
|
|
+ result.append(connection.execute(sub_query, multi=True))
|
|
|
except Exception as e:
|
|
|
errors.append(str(e))
|
|
|
|
|
@@ -227,9 +228,10 @@ class SQLHandler:
|
|
|
|
|
|
self._log.error(err)
|
|
|
raise Exception(err)
|
|
|
-
|
|
|
+
|
|
|
transaction.commit()
|
|
|
connection.close()
|
|
|
+ return result
|
|
|
|
|
|
def execute_query_from_file(self, filename: str):
|
|
|
'''
|