diff options
| author | LV-426 <lv-426@taproot.org.il> | 2015-03-30 19:20:05 +0300 |
|---|---|---|
| committer | LV-426 <lv-426@taproot.org.il> | 2015-04-01 22:25:53 +0300 |
| commit | 8ee0f82019e68362ab28edd17a052e0a927341b6 (patch) | |
| tree | d2c5baf55b250c27b66bf8ebf0561b058749404f /src | |
| parent | b27aa64f6c6130910ed2131bc980e1b93c6d6620 (diff) | |
misc rename: q_set -> statement_param_pair_set
Diffstat (limited to 'src')
| -rw-r--r-- | src/server/db_driver.py | 12 |
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)) |
