equal
deleted
inserted
replaced
167 self.rqlst = rqlst |
167 self.rqlst = rqlst |
168 self.args = args or {} |
168 self.args = args or {} |
169 # session executing the query |
169 # session executing the query |
170 self.session = session |
170 self.session = session |
171 # quick reference to the system source |
171 # quick reference to the system source |
172 self.syssource = session.pool.source('system') |
172 self.syssource = session.cnxset.source('system') |
173 # execution steps |
173 # execution steps |
174 self.steps = [] |
174 self.steps = [] |
175 # index of temporary tables created during execution |
175 # index of temporary tables created during execution |
176 self.temp_tables = {} |
176 self.temp_tables = {} |
177 # various resource accesors |
177 # various resource accesors |
732 except (Unauthorized, ValidationError): |
732 except (Unauthorized, ValidationError): |
733 # getting an Unauthorized/ValidationError exception means the |
733 # getting an Unauthorized/ValidationError exception means the |
734 # transaction must been rollbacked |
734 # transaction must been rollbacked |
735 # |
735 # |
736 # notes: |
736 # notes: |
737 # * we should not reset the pool here, since we don't want the |
737 # * we should not reset the connections set here, since we don't want the |
738 # session to loose its pool during processing |
738 # session to loose it during processing |
739 # * don't rollback if we're in the commit process, will be handled |
739 # * don't rollback if we're in the commit process, will be handled |
740 # by the session |
740 # by the session |
741 if session.commit_state is None: |
741 if session.commit_state is None: |
742 session.commit_state = 'uncommitable' |
742 session.commit_state = 'uncommitable' |
743 raise |
743 raise |