equal
deleted
inserted
replaced
319 req = req or self.request(rql=rql) |
319 req = req or self.request(rql=rql) |
320 return self.cnx.cursor(req).execute(unicode(rql), args, eidkey) |
320 return self.cnx.cursor(req).execute(unicode(rql), args, eidkey) |
321 |
321 |
322 @nocoverage |
322 @nocoverage |
323 def commit(self): |
323 def commit(self): |
324 self.cnx.commit() |
324 try: |
|
325 return self.cnx.commit() |
|
326 finally: |
|
327 self.session.set_pool() # ensure pool still set after commit |
325 |
328 |
326 @nocoverage |
329 @nocoverage |
327 def rollback(self): |
330 def rollback(self): |
328 try: |
331 try: |
329 self.cnx.rollback() |
332 self.cnx.rollback() |
330 except ProgrammingError: |
333 except ProgrammingError: |
331 pass |
334 pass |
|
335 finally: |
|
336 self.session.set_pool() # ensure pool still set after commit |
332 |
337 |
333 # # server side db api ####################################################### |
338 # # server side db api ####################################################### |
334 |
339 |
335 def sexecute(self, rql, args=None, eid_key=None): |
340 def sexecute(self, rql, args=None, eid_key=None): |
336 self.session.set_pool() |
341 self.session.set_pool() |