Lines Matching +defs:db +defs:close
25 import com.sleepycat.db.Cursor;
26 import com.sleepycat.db.CursorConfig;
27 import com.sleepycat.db.Database;
28 import com.sleepycat.db.DatabaseConfig;
29 import com.sleepycat.db.DatabaseEntry;
30 import com.sleepycat.db.DatabaseException;
31 import com.sleepycat.db.Environment;
32 import com.sleepycat.db.ForeignKeyDeleteAction;
33 import com.sleepycat.db.OperationStatus;
34 import com.sleepycat.db.SecondaryConfig;
35 import com.sleepycat.db.SecondaryDatabase;
36 import com.sleepycat.db.Sequence;
37 import com.sleepycat.db.SequenceConfig;
38 import com.sleepycat.db.Transaction;
344 Database db;
346 db = DbCompat.openDatabase
352 priOpenState.addDatabase(db);
356 (db, primaryKeyClass, keyBinding, entityClass,
362 deferredWriteDatabases.put(db, null);
404 * opening the primary and secondaries aborts. Also used to close all
422 void addDatabase(Database db) {
423 databases.put(db, null);
441 for (Database db : databases.keySet()) {
443 db.close();
459 for (Database db : databases.keySet()) {
460 deferredWriteDatabases.remove(db);
677 SecondaryDatabase db;
683 db = DbCompat.openSecondaryDatabase
698 (db, null, primaryIndex, keyClass, keyBinding);
703 deferredWriteDatabases.put(db, null);
706 priOpenState.addDatabase(db);
789 Database db = secIndex.getDatabase();
790 firstException = closeDb(db, firstException);
794 deferredWriteDatabases.remove(db);
798 Database db = priIndex.getDatabase();
799 firstException = closeDb(db, firstException);
801 deferredWriteDatabases.remove(db);
810 public synchronized void close()
817 boolean allClosed = catalog.close();
824 if (catalog.close()) {
1166 private DatabaseException closeDb(Database db,
1168 if (db != null) {
1170 db.close();
1232 Database db = index.getDatabase();
1248 cursor = db.openCursor(txn, cursorConfig);
1265 cursor.close();
1270 cursor = db.openCursor(txn, cursorConfig);
1283 cursor.close();
1327 void onSync(Database db, boolean flushLog);