diff options
| author | LV-426 <lv-426@taproot.org.il> | 2014-10-12 18:07:21 +0200 |
|---|---|---|
| committer | LV-426 <lv-426@taproot.org.il> | 2014-10-12 18:07:21 +0200 |
| commit | 1d8d5646897ca05f97bb33be5ced2b8643ae4a23 (patch) | |
| tree | 664da86a8c05eee333197774f7e7ba777e25cb2f /src-py | |
| parent | f5aaa150c41e07104913fc7e99015ada36e228ac (diff) | |
DB_op - result_set, error_set
Diffstat (limited to 'src-py')
| -rw-r--r-- | src-py/db_controller.py | 16 |
1 files changed, 8 insertions, 8 deletions
diff --git a/src-py/db_controller.py b/src-py/db_controller.py index 936009b5..96de855d 100644 --- a/src-py/db_controller.py +++ b/src-py/db_controller.py @@ -19,8 +19,9 @@ class DB_op(object): """ def __init__(self): - self.s_id = 0 # statement id counter - self.id_to_statement_map = {} # zero based id to statement map + self.statement_set = [] + self.result_set = None + self.error_set = None self.tx_id = None self.tx_commit_url = None # cached from response to tx begin @@ -29,15 +30,14 @@ class DB_op(object): id_str = m.group('id') self.tx_id = int(id_str) - def add_statement(self, cypher_query, params={}): + def add_statement(self, query, query_params={}): """ add a DB query language statement - @return: statement id + @return: statement index (zero based) """ - ret = self.s_id - self.id_to_statement_map[self.s_id] = dbu.statement_to_REST_form(cypher_query, params) - self.s_id = self.s_id + 1 - return ret + s = db_util.statement_to_REST_form(query, query_params) + self.statement_set.append(s) + return len(self.statement_set) def __iter__(self): """ |
