summaryrefslogtreecommitdiff
path: root/src/server/db_controller.py
diff options
context:
space:
mode:
authorLV-426 <lv-426@taproot.org.il>2015-01-20 14:58:40 +0200
committerLV-426 <lv-426@taproot.org.il>2015-01-20 14:58:40 +0200
commit5e05b37aed97612e2c8c59f99265b740b44e87f4 (patch)
tree23fd129659b545e8817f632f578d86f4980e2849 /src/server/db_controller.py
parenteac4125bf02c7c19953d6173e3e0191244a18a82 (diff)
DB_Controller#exec_op() logging, comments
Diffstat (limited to 'src/server/db_controller.py')
-rw-r--r--src/server/db_controller.py20
1 files changed, 11 insertions, 9 deletions
diff --git a/src/server/db_controller.py b/src/server/db_controller.py
index 1dbdc27b..0f056398 100644
--- a/src/server/db_controller.py
+++ b/src/server/db_controller.py
@@ -27,21 +27,23 @@ class DB_Controller:
"""
execute operation within a DB transaction
"""
- if isinstance(op, DB_composed_op):
- # construct a list comprehension composed of all sup_op statements
- for s_op in op:
- self.exec_op(s_op)
- return op.process_result_set()
+ if isinstance(op, DB_composed_op): # composed DB op
+ log.debug('exec_composed-op:' + op.name)
+ for sub_op in op:
+ sub_op_ret = self.exec_op(sub_op) # recursive call
- try:
+ op_ret = op.process_result_set()
+ return op_ret
+
+ try: # non-composed DB op
self.db_driver.begin_tx(op)
self.db_driver.exec_statement_set(op)
self.db_driver.commit_tx(op)
- ret = op.process_result_set()
+ op_ret = op.process_result_set()
+ log.debug('exec_op:' + op.name + ': return value: ' + str(op_ret))
+ return op_ret
- log.debug('exec_op:' + op.name + ': return value: ' + str(ret))
- return ret
except Neo4JException as e:
log.exception(e) # Neo4JException may be composed of several sub errors, defer to class __str__
raise e