Lines Matching refs:db
16 # the Python Berkeley DB 3 interface.
57 from bsddb3 import db
60 from bsddb import db
114 _table_names_key = '__TABLE_NAMES__' # list of the tables in this db
163 Open database name in the dbhome Berkeley DB directory.
166 self.db = None
167 myflags = db.DB_THREAD
169 myflags |= db.DB_CREATE
170 flagsforenv = (db.DB_INIT_MPOOL | db.DB_INIT_LOCK | db.DB_INIT_LOG |
171 db.DB_INIT_TXN | dbflags)
174 dbflags |= db.DB_AUTO_COMMIT
178 flagsforenv = flagsforenv | db.DB_RECOVER
179 self.env = db.DBEnv()
181 self.env.set_lk_detect(db.DB_LOCK_DEFAULT)
184 myflags |= db.DB_TRUNCATE
185 self.db = db.DB(self.env)
188 self.db.set_get_returns_none(1)
190 self.db.set_flags(db.DB_DUP)
191 self.db.open(filename, db.DB_BTREE, dbflags | myflags, mode)
217 def __init__(self, db) :
218 self._db = db
255 self.db = db_py3k(self.db)
262 if not getattr(self.db, "has_key")(_table_names_key, txn):
263 getattr(self.db, "put_bytes", self.db.put) \
278 if self.db is not None:
279 self.db.close()
280 self.db = None
289 self.db.sync()
294 cur = self.db.cursor()
305 except db.DBNotFoundError:
312 raises TableDBError if it already exists or for other DB errors.
329 if getattr(self.db, "has_key")(columnlist_key):
334 getattr(self.db, "put_bytes", self.db.put)(columnlist_key,
338 tablelist = pickle.loads(getattr(self.db, "get_bytes",
339 self.db.get) (_table_names_key, txn=txn, flags=db.DB_RMW))
342 self.db.delete(_table_names_key, txn=txn)
343 getattr(self.db, "put_bytes", self.db.put)(_table_names_key,
348 except db.DBError, dberror:
366 if not getattr(self.db, "has_key")(columnlist_key):
368 pickledcolumnlist = getattr(self.db, "get_bytes",
369 self.db.get)(columnlist_key)
377 pickledtablelist = self.db.get_get(_table_names_key)
405 getattr(self.db, "get_bytes",
406 self.db.get)(columnlist_key, txn=txn, flags=db.DB_RMW))
423 self.db.delete(columnlist_key, txn=txn)
424 getattr(self.db, "put_bytes", self.db.put)(columnlist_key,
432 except db.DBError, dberror:
445 tcolpickles = getattr(self.db, "get_bytes",
446 self.db.get)(_columns_key(table))
447 except db.DBNotFoundError:
470 self.db.put(_rowid_key(table, newid), None, txn=txn,
471 flags=db.DB_NOOVERWRITE)
472 db.DBKeyExistError:
487 if not getattr(self.db, "has_key")(_columns_key(table)):
504 self.db.put(_data_key(table, column, rowid), dataitem, txn=txn)
509 except db.DBError, dberror:
517 self.db.delete(_rowid_key(table, rowid))
548 dataitem = self.db.get(
551 self.db.delete(
554 except db.DBNotFoundError:
560 self.db.put(
572 except db.DBError, dberror:
599 self.db.delete(_data_key(table, column, rowid),
601 except db.DBNotFoundError:
606 self.db.delete(_rowid_key(table, rowid), txn=txn)
607 except db.DBNotFoundError:
612 except db.DBError, dberror:
616 except db.DBError, dberror:
639 except db.DBError, dberror:
718 cur = self.db.cursor()
750 except db.DBError, dberror:
751 if dberror.args[0] != db.DB_NOTFOUND:
768 rowdata[column] = self.db.get(
770 except db.DBError, dberror:
772 if dberror[0] != db.DB_NOTFOUND:
775 if dberror.args[0] != db.DB_NOTFOUND:
790 self.db.delete(_columns_key(table), txn=txn)
792 cur = self.db.cursor(txn)
799 except db.DBNotFoundError:
811 except db.DBNotFoundError:
822 getattr(self.db, "get_bytes", self.db.get)(_table_names_key,
823 txn=txn, flags=db.DB_RMW))
830 self.db.delete(_table_names_key, txn=txn)
831 getattr(self.db, "put_bytes", self.db.put)(_table_names_key,
840 except db.DBError, dberror:
