summaryrefslogtreecommitdiff
path: root/src-py
diff options
context:
space:
mode:
authorLV-426 <lv-426@taproot.org.il>2014-10-12 18:07:21 +0200
committerLV-426 <lv-426@taproot.org.il>2014-10-12 18:07:21 +0200
commit1d8d5646897ca05f97bb33be5ced2b8643ae4a23 (patch)
tree664da86a8c05eee333197774f7e7ba777e25cb2f /src-py
parentf5aaa150c41e07104913fc7e99015ada36e228ac (diff)
DB_op - result_set, error_set
Diffstat (limited to 'src-py')
-rw-r--r--src-py/db_controller.py16
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):
"""