summaryrefslogtreecommitdiff
path: root/src/server
diff options
context:
space:
mode:
authorLV-426 <lv-426@taproot.org.il>2015-01-20 03:08:38 +0200
committerLV-426 <lv-426@taproot.org.il>2015-01-20 04:00:42 +0200
commitfe38771c39b2ca17070f02a471cc26c32cf9f156 (patch)
tree6462442b117be08a1cdddd68f7790008eb20ba5d /src/server
parent7867097cd47dc59b806fdec8ad526831ce3ff57f (diff)
DB_op: update param names, doc
Diffstat (limited to 'src/server')
-rw-r--r--src/server/db_op.py20
1 files changed, 13 insertions, 7 deletions
diff --git a/src/server/db_op.py b/src/server/db_op.py
index 135088b4..d9dc28f8 100644
--- a/src/server/db_op.py
+++ b/src/server/db_op.py
@@ -46,19 +46,25 @@ class DB_op(object):
def __iter__(self):
"""
- iterate over (statement_index, statement, result, error)
+ iterate over (DB_Query index, DB_Query, result | error)
where result & error are mutually exclusive
- note: statement_index is zero based
+ note: index is zero based
TODO: handle partial iteration due to error_set being non-empty
"""
r_set_len = len(self.result_set)
- for i, s in enumerate(self.statement_set):
- r_set = None # row-set
+
+ #
+ # i: statement index
+ # dbq: db query
+ # row-set: query result
+ #
+ for i, dbq in enumerate(self.statement_set):
+ r_set = None
if i < r_set_len: # support partial result recovery
r_set = DB_result_set(self.result_set[i])
- yield (i, s, r_set)
+ yield (i, dbq, r_set)
def parse_multi_statement_response_data(self, data):
pass
@@ -73,8 +79,8 @@ class DB_op(object):
assists in parsing response data from a single query.
"""
ret = []
- for _, _, r_set in self:
- for row in r_set:
+ for _, _, row_set in self:
+ for row in row_set:
for col in row:
ret.append(col)
return ret