equal
deleted
inserted
replaced
257 s = Session(u, self.repo) |
257 s = Session(u, self.repo) |
258 return s |
258 return s |
259 |
259 |
260 def qexecute(self, rql, args=None, build_descr=True): |
260 def qexecute(self, rql, args=None, build_descr=True): |
261 with self.session.new_cnx() as cnx: |
261 with self.session.new_cnx() as cnx: |
262 with cnx.ensure_cnx_set: |
262 try: |
263 try: |
263 return self.o.execute(cnx, rql, args, build_descr) |
264 return self.o.execute(cnx, rql, args, build_descr) |
264 finally: |
265 finally: |
265 if rql.startswith(('INSERT', 'DELETE', 'SET')): |
266 if rql.startswith(('INSERT', 'DELETE', 'SET')): |
266 cnx.commit() |
267 cnx.commit() |
|
268 |
267 |
269 |
268 |
270 class BasePlannerTC(BaseQuerierTC): |
269 class BasePlannerTC(BaseQuerierTC): |
271 |
270 |
272 def setup(self): |
271 def setup(self): |