summaryrefslogtreecommitdiff
path: root/src/server/db_driver.py
diff options
context:
space:
mode:
authorLV-426 <lv-426@taproot.org.il>2015-03-30 19:20:05 +0300
committerLV-426 <lv-426@taproot.org.il>2015-04-01 22:25:53 +0300
commit8ee0f82019e68362ab28edd17a052e0a927341b6 (patch)
treed2c5baf55b250c27b66bf8ebf0561b058749404f /src/server/db_driver.py
parentb27aa64f6c6130910ed2131bc980e1b93c6d6620 (diff)
misc rename: q_set -> statement_param_pair_set
Diffstat (limited to 'src/server/db_driver.py')
-rw-r--r--src/server/db_driver.py12
1 files changed, 7 insertions, 5 deletions
diff --git a/src/server/db_driver.py b/src/server/db_driver.py
index 8cdd35f7..26801874 100644
--- a/src/server/db_driver.py
+++ b/src/server/db_driver.py
@@ -17,6 +17,7 @@ class DB_Driver_Base():
log.debug(msg)
class DB_Driver_Embedded(DB_Driver_Base):
+
def __init__(self, db_base_url):
self.tx_base_url = db_base_url + '/db/data/transaction'
@@ -34,6 +35,7 @@ class DB_Driver_Embedded(DB_Driver_Base):
pass
class DB_Driver_REST(DB_Driver_Base):
+
def __init__(self, db_base_url):
self.tx_base_url = db_base_url + '/db/data/transaction'
@@ -56,24 +58,24 @@ class DB_Driver_REST(DB_Driver_Base):
def exec_query_set(self, op):
tx_url = "{0}/{1}".format(self.tx_base_url, op.tx_id)
- q_set = db_util.db_query_set_to_REST_form(op.query_set)
+ statement_param_pair_set = db_util.db_query_set_to_REST_form(op.query_set)
try:
- post_ret = db_util.post_neo4j(tx_url, q_set)
+ post_ret = db_util.post_neo4j(tx_url, statement_param_pair_set)
op.result_set = post_ret['results']
op.error_set = post_ret['errors']
if 0 != len(op.error_set):
raise Neo4JException(op.error_set)
- self.log_committed_queries(q_set)
+ self.log_committed_queries(statement_param_pair_set)
except Neo4JException as e:
# NOTE: python 2.7 loses the stack when reraising the exception.
# python 3 does the right thing, but gevent doesn't support it yet.
- log.error('REST statement: %r' % statement_set)
+ log.error('REST statement: %r' % statement_param_pair_set)
log.exception(e)
raise e
except Exception as e:
- log.error('REST statement: %r' % statement_set)
+ log.error('REST statement: %r' % statement_param_pair_set)
log.exception(e)
raise Exception('failed exec op statements: err: {0}, url: {1}'.format(e.message, tx_url))