1164 def rqlexec(self, rql, kwargs=None, cachekey=None, ask_confirm=True): |
1164 def rqlexec(self, rql, kwargs=None, cachekey=None, ask_confirm=True): |
1165 """rql action""" |
1165 """rql action""" |
1166 if not isinstance(rql, (tuple, list)): |
1166 if not isinstance(rql, (tuple, list)): |
1167 rql = ( (rql, kwargs), ) |
1167 rql = ( (rql, kwargs), ) |
1168 res = None |
1168 res = None |
|
1169 try: |
|
1170 execute = self._cw.unsafe_execute |
|
1171 except AttributeError: |
|
1172 execute = self._cw.execute |
1169 for rql, kwargs in rql: |
1173 for rql, kwargs in rql: |
1170 if kwargs: |
1174 if kwargs: |
1171 msg = '%s (%s)' % (rql, kwargs) |
1175 msg = '%s (%s)' % (rql, kwargs) |
1172 else: |
1176 else: |
1173 msg = rql |
1177 msg = rql |
1174 if not ask_confirm or self.confirm('execute rql: %s ?' % msg): |
1178 if not ask_confirm or self.confirm('execute rql: %s ?' % msg): |
1175 try: |
1179 try: |
1176 res = self._cw.execute(rql, kwargs, cachekey) |
1180 res = execute(rql, kwargs, cachekey) |
1177 except Exception, ex: |
1181 except Exception, ex: |
1178 if self.confirm('error: %s\nabort?' % ex): |
1182 if self.confirm('error: %s\nabort?' % ex): |
1179 raise |
1183 raise |
1180 return res |
1184 return res |
1181 |
1185 |