Lines Matching refs:txn
220 def cursor(self, txn=None) : argument
221 return cursor_py3k(self._db.cursor(txn=txn))
223 def has_key(self, key, txn=None) : argument
225 txn=txn)
227 def put(self, key, value, flags=0, txn=None) : argument
231 return self._db.put(key, value, flags=flags, txn=txn)
233 def put_bytes(self, key, value, txn=None) : argument
235 return self._db.put(key, value, txn=txn)
237 def get(self, key, txn=None, flags=0) : argument
239 v = self._db.get(key, txn=txn, flags=flags)
244 def get_bytes(self, key, txn=None, flags=0) : argument
246 return self._db.get(key, txn=txn, flags=flags)
248 def delete(self, key, txn=None) : argument
250 return self._db.delete(key, txn=txn)
260 txn = self.env.txn_begin()
262 if not getattr(self.db, "has_key")(_table_names_key, txn):
264 (_table_names_key, pickle.dumps([], 1), txn=txn)
267 txn.abort()
270 txn.commit()
316 txn = None
332 txn = self.env.txn_begin()
335 pickle.dumps(columns, 1), txn=txn)
339 self.db.get) (_table_names_key, txn=txn, flags=db.DB_RMW))
342 self.db.delete(_table_names_key, txn=txn)
344 pickle.dumps(tablelist, 1), txn=txn)
346 txn.commit()
347 txn = None
349 if txn:
350 txn.abort()
398 txn = None
401 txn = self.env.txn_begin()
406 self.db.get)(columnlist_key, txn=txn, flags=db.DB_RMW))
423 self.db.delete(columnlist_key, txn=txn)
426 txn=txn)
428 txn.commit()
429 txn = None
433 if txn:
434 txn.abort()
453 def __new_rowid(self, table, txn) : argument
470 self.db.put(_rowid_key(table, newid), None, txn=txn,
485 txn = None
498 txn = self.env.txn_begin()
499 rowid = self.__new_rowid(table, txn=txn)
504 self.db.put(_data_key(table, column, rowid), dataitem, txn=txn)
506 txn.commit()
507 txn = None
515 if txn:
516 txn.abort()
542 txn = None
545 txn = self.env.txn_begin()
550 txn=txn)
553 txn=txn)
562 dataitem, txn=txn)
563 txn.commit()
564 txn = None
568 if txn:
569 txn.abort()
593 txn = None
595 txn = self.env.txn_begin()
600 txn=txn)
606 self.db.delete(_rowid_key(table, rowid), txn=txn)
610 txn.commit()
611 txn = None
613 if txn:
614 txn.abort()
785 txn = None
787 txn = self.env.txn_begin()
790 self.db.delete(_columns_key(table), txn=txn)
792 cur = self.db.cursor(txn)
823 txn=txn, flags=db.DB_RMW))
830 self.db.delete(_table_names_key, txn=txn)
832 pickle.dumps(tablelist, 1), txn=txn)
834 txn.commit()
835 txn = None
841 if txn:
842 txn.abort()