equal
deleted
inserted
replaced
273 |
273 |
274 def commit(self): |
274 def commit(self): |
275 self.session.commit() |
275 self.session.commit() |
276 self.session.set_cnxset() |
276 self.session.set_cnxset() |
277 |
277 |
|
278 def qexecute(self, rql, args=None, build_descr=True): |
|
279 with self.session.new_cnx() as cnx: |
|
280 with cnx.ensure_cnx_set: |
|
281 try: |
|
282 return self.o.execute(cnx, rql, args, build_descr) |
|
283 finally: |
|
284 if rql.startswith(('INSERT', 'DELETE', 'SET')): |
|
285 cnx.commit() |
|
286 |
278 |
287 |
279 class BasePlannerTC(BaseQuerierTC): |
288 class BasePlannerTC(BaseQuerierTC): |
280 |
289 |
281 def setup(self): |
290 def setup(self): |
282 # XXX source_defs |
291 # XXX source_defs |