Lines Matching refs:db
34 final RocksDB db = RocksDB.open(opt, in backupDb()
38 prepareDatabase(db); in backupDb()
44 be.createNewBackup(db, false); in backupDb()
45 be.createNewBackup(db, true); in backupDb()
55 final RocksDB db = RocksDB.open(opt, in deleteBackup()
58 prepareDatabase(db); in deleteBackup()
63 be.createNewBackup(db, false); in deleteBackup()
64 be.createNewBackup(db, true); in deleteBackup()
83 final RocksDB db = RocksDB.open(opt, in purgeOldBackups()
86 prepareDatabase(db); in purgeOldBackups()
91 be.createNewBackup(db, false); in purgeOldBackups()
92 be.createNewBackup(db, true); in purgeOldBackups()
93 be.createNewBackup(db, true); in purgeOldBackups()
94 be.createNewBackup(db, true); in purgeOldBackups()
112 RocksDB db = null; in restoreLatestBackup() local
114 db = RocksDB.open(opt, in restoreLatestBackup()
117 prepareDatabase(db); in restoreLatestBackup()
122 be.createNewBackup(db, true); in restoreLatestBackup()
124 db.put("key1".getBytes(), "valueV2".getBytes()); in restoreLatestBackup()
125 db.put("key2".getBytes(), "valueV2".getBytes()); in restoreLatestBackup()
126 be.createNewBackup(db, true); in restoreLatestBackup()
128 db.put("key1".getBytes(), "valueV3".getBytes()); in restoreLatestBackup()
129 db.put("key2".getBytes(), "valueV3".getBytes()); in restoreLatestBackup()
130 assertThat(new String(db.get("key1".getBytes()))).endsWith("V3"); in restoreLatestBackup()
131 assertThat(new String(db.get("key2".getBytes()))).endsWith("V3"); in restoreLatestBackup()
133 db.close(); in restoreLatestBackup()
134 db = null; in restoreLatestBackup()
144 db = RocksDB.open(opt, dbFolder.getRoot().getAbsolutePath()); in restoreLatestBackup()
147 assertThat(new String(db.get("key1".getBytes()))).endsWith("V2"); in restoreLatestBackup()
148 assertThat(new String(db.get("key2".getBytes()))).endsWith("V2"); in restoreLatestBackup()
151 if(db != null) { in restoreLatestBackup()
152 db.close(); in restoreLatestBackup()
162 RocksDB db = null; in restoreFromBackup() local
165 db = RocksDB.open(opt, in restoreFromBackup()
168 prepareDatabase(db); in restoreFromBackup()
172 be.createNewBackup(db, true); in restoreFromBackup()
174 db.put("key1".getBytes(), "valueV2".getBytes()); in restoreFromBackup()
175 db.put("key2".getBytes(), "valueV2".getBytes()); in restoreFromBackup()
176 be.createNewBackup(db, true); in restoreFromBackup()
178 db.put("key1".getBytes(), "valueV3".getBytes()); in restoreFromBackup()
179 db.put("key2".getBytes(), "valueV3".getBytes()); in restoreFromBackup()
180 assertThat(new String(db.get("key1".getBytes()))).endsWith("V3"); in restoreFromBackup()
181 assertThat(new String(db.get("key2".getBytes()))).endsWith("V3"); in restoreFromBackup()
184 db.close(); in restoreFromBackup()
185 db = null; in restoreFromBackup()
195 db = RocksDB.open(opt, in restoreFromBackup()
198 assertThat(new String(db.get("key1".getBytes()))).endsWith("V1"); in restoreFromBackup()
199 assertThat(new String(db.get("key2".getBytes()))).endsWith("V1"); in restoreFromBackup()
202 if(db != null) { in restoreFromBackup()
203 db.close(); in restoreFromBackup()
213 final RocksDB db = RocksDB.open(opt, dbFolder.getRoot().getAbsolutePath())) { in backupDbWithMetadata()
215 prepareDatabase(db); in backupDbWithMetadata()
222 be.createNewBackupWithMetadata(db, metadata, true); in backupDbWithMetadata()
256 private void prepareDatabase(final RocksDB db) in prepareDatabase() argument
258 db.put("key1".getBytes(), "valueV1".getBytes()); in prepareDatabase()
259 db.put("key2".getBytes(), "valueV1".getBytes()); in prepareDatabase()