diff options
Diffstat (limited to 'src-py/db_driver.py')
| -rw-r--r-- | src-py/db_driver.py | 18 |
1 files changed, 9 insertions, 9 deletions
diff --git a/src-py/db_driver.py b/src-py/db_driver.py index 11eace2c..0532e512 100644 --- a/src-py/db_driver.py +++ b/src-py/db_driver.py @@ -7,7 +7,15 @@ import neo4j_util as db_util log = logging.getLogger('rhizi') class DB_Driver_Base(): - pass + + def log_committed_queries(self, statement_set): + for sp_dict in statement_set['statements']: + if None != sp_dict['parameters']: + msg = '\tq: {0}\n\tp: {1}'.format(sp_dict['statement'], + sp_dict['parameters']) + else: + msg = '\tq: {0}'.format(sp_dict['statement']) + log.debug(msg) class DB_Driver_Embedded(DB_Driver_Base): def __init__(self, db_base_url): @@ -27,10 +35,6 @@ class DB_Driver_Embedded(DB_Driver_Base): def commit_tx(self, op): pass - def log_committed_queries(self, statement_set): - for sp_dict in statement_set['statements']: - log.debug('\tq: {0}'.format(sp_dict['statement'])) - class DB_Driver_REST(DB_Driver_Base): def __init__(self, db_base_url): self.tx_base_url = db_base_url + '/db/data/transaction' @@ -85,7 +89,3 @@ class DB_Driver_REST(DB_Driver_Base): except Exception as e: raise Exception('failed to commit transaction:' + e.message) - def log_committed_queries(self, statement_set): - for sp_dict in statement_set['statements']: - log.debug('\tq: {0}'.format(sp_dict['statement'])) - |