summaryrefslogtreecommitdiff
path: root/src-py/db_controller.py
diff options
context:
space:
mode:
authorLV-426 <lv-426@taproot.org.il>2014-10-12 14:40:12 +0200
committerLV-426 <lv-426@taproot.org.il>2014-10-12 14:40:12 +0200
commit6a5c1acbeca40a374736d657d48beb33f0d32b27 (patch)
tree6de860667251e4dbde1f3bba5c028dbbdea2b6b3 /src-py/db_controller.py
parentf917586c635d099891708ae6e1ca4796b28a53e8 (diff)
support result_set iteration post DB_op execution
Diffstat (limited to 'src-py/db_controller.py')
-rw-r--r--src-py/db_controller.py17
1 files changed, 12 insertions, 5 deletions
diff --git a/src-py/db_controller.py b/src-py/db_controller.py
index 180a6b37..3969a2bb 100644
--- a/src-py/db_controller.py
+++ b/src-py/db_controller.py
@@ -40,15 +40,22 @@ class DB_op(object):
def __iter__(self):
"""
- iterate over (statement_index, statement, statement_result)
+ iterate over (statement_index, statement, result, error)
+ where result & error are mutually exclusive
+
note: statement_index is zero based
- TODO: support statement_result
+ TODO: handle partial iteration due to error_set being non-empty
"""
i = 0
- for s in self.statement_set:
- yield (i, s, None)
- i = i + 1
+ if self.result_set:
+ for s in self.statement_set:
+ yield (i, s, self.result_set[i])
+ i = i + 1
+ else:
+ for s in self.statement_set:
+ yield (i, s, None)
+ i = i + 1
def extract_single_query_response_data(self, q, data):
"""