diff options
| author | LV-426 <lv-426@taproot.org.il> | 2014-10-12 14:40:12 +0200 |
|---|---|---|
| committer | LV-426 <lv-426@taproot.org.il> | 2014-10-12 14:40:12 +0200 |
| commit | 6a5c1acbeca40a374736d657d48beb33f0d32b27 (patch) | |
| tree | 6de860667251e4dbde1f3bba5c028dbbdea2b6b3 /src-py/db_controller.py | |
| parent | f917586c635d099891708ae6e1ca4796b28a53e8 (diff) | |
support result_set iteration post DB_op execution
Diffstat (limited to 'src-py/db_controller.py')
| -rw-r--r-- | src-py/db_controller.py | 17 |
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): """ |
