我正在尝试通过编程方式备份一个Room数据库。
为此，我只需复制包含整个数据库的.sqlite文件
但是，在复制之前，由于Room启用了写日志记录，我们必须关闭数据库，以便-shm文件和-wal文件合并为单个.sqlite文件。 如此处所指出的那样
我在RoomDatabase对象上运行.close()：
备份一切正常，但是后来，当我尝试执行一个INSERT查询时，我会得到这个错误：
android.database.sqlite.SQLiteException: no such table: room_table_modification_log (code 1)
如何在关闭 Room 数据库后正确地重新打开它？
PS：RoomDatabase 对象上的 .isOpen() 方法会在 INSERT 之前返回 true。
Room 版本：1.1.1-rc1
wal_checkpoint pragma强制进行检查点。pragma（它会触发一个UNKNOWN query type错误）。将此查询放在您的DAO内部：@RawQuery
int checkpoint(SupportSQLiteQuery supportSQLiteQuery);
然后当你调用检查点方法时，使用以下查询：
myDAO.checkpoint(new SimpleSQLiteQuery("pragma wal_checkpoint(full)"));
这个链接可能对wal_checkpoint的作用有所启示。
myDAO.checkpoint(new SimpleSQLiteQuery("pragma wal_checkpoint(full)"));？ - Zakaria Darwish更具体地回答您的问题，这是我在我的一个应用程序中备份房间数据库的方法：
RoomDatabase。在我的情况下，AppDatabase 是一个包含构建房间数据库的逻辑的单例。 AppDatabase.getInstance(this).getDatabase() 获取单例的当前实例及其当前数据库类，该类扩展了 RoomDatabase。这本质上调用了 RoomDatabase.close().FileUtils 指的是 commons-io。if(id == R.id.action_save_db) {
int permission = ActivityCompat.checkSelfPermission(this, Manifest.permission.WRITE_EXTERNAL_STORAGE);
if(permission == PackageManager.PERMISSION_GRANTED) {
AppDatabase.getInstance(this).getDatabase().close();
File db = getDatabasePath("my-db");
File dbShm = new File(db.getParent(), "my-db-shm");
File dbWal = new File(db.getParent(), "my-db-wal");
File db2 = new File("/sdcard/", "my-db");
File dbShm2 = new File(db2.getParent(), "my-db-shm");
File dbWal2 = new File(db2.getParent(), "my-db-wal");
try {
FileUtils.copyFile(db, db2);
FileUtils.copyFile(dbShm, dbShm2);
FileUtils.copyFile(dbWal, dbWal2);
} catch (Exception e) {
Log.e("SAVEDB", e.toString());
}
} else {
Snackbar.make(mDrawer, "Please allow access to your storage", Snackbar.LENGTH_LONG)
.setAction("Allow", view -> ActivityCompat.requestPermissions(this, new String[] {
Manifest.permission.WRITE_EXTERNAL_STORAGE
}, 0)).show();
}
} else if(id == R.id.action_load_db) {
int permission = ActivityCompat.checkSelfPermission(this, Manifest.permission.READ_EXTERNAL_STORAGE);
if(permission == PackageManager.PERMISSION_GRANTED) {
AppDatabase.getInstance(this).getDatabase().close();
File db = new File("/sdcard/", "my-db");
File dbShm = new File(db.getParent(), "my-db-shm");
File dbWal = new File(db.getParent(), "my-db-wal");
File db2 = getDatabasePath("my-db");
File dbShm2 = new File(db2.getParent(), "my-db-shm");
File dbWal2 = new File(db2.getParent(), "my-db-wal");
try {
FileUtils.copyFile(db, db2);
FileUtils.copyFile(dbShm, dbShm2);
FileUtils.copyFile(dbWal, dbWal2);
} catch (Exception e) {
Loge("RESTOREDB", e.toString());
}
} else {
Snackbar.make(mDrawer, "Please allow access to your storage", Snackbar.LENGTH_LONG)
.setAction("Allow", view -> ActivityCompat.requestPermissions(this, new String[] {
Manifest.permission.READ_EXTERNAL_STORAGE
}, 0)).show();
}
}
Room.databaseBuilder(context, db.class, dbName)
.setJournalMode(JournalMode.TRUNCATE)
.build();
private fun createBackup() {
val db = AppDatabase.getInstance(this@MainActivity)
db.close()
val dbFile: File = getDatabasePath(DATABASE_NAME)
val sDir = File(Environment.getExternalStorageDirectory(), "Backup")
val fileName = "Backup (${getDateTimeFromMillis(System.currentTimeMillis(), "dd-MM-yyyy-hh:mm")})"
val sfPath = sDir.path + File.separator + fileName
if (!sDir.exists()) {
sDir.mkdirs()
}
val saveFile = File(sfPath)
if (saveFile.exists()) {
Log.d("LOGGER ", "File exists. Deleting it and then creating new file.")
saveFile.delete()
}
try {
if (saveFile.createNewFile()) {
val bufferSize = 8 * 1024
val buffer = ByteArray(bufferSize)
var bytesRead: Int
val saveDb: OutputStream = FileOutputStream(sfPath)
val indDb: InputStream = FileInputStream(dbFile)
do {
bytesRead = indDb.read(buffer, 0, bufferSize)
if (bytesRead < 0)
break
saveDb.write(buffer, 0, bytesRead)
} while (true)
saveDb.flush()
indDb.close()
saveDb.close()
}
} catch (e: Exception) {
e.printStackTrace()
}
}
你必须在其中包含保存文件
try {
//backup process
}
} catch (e: Exception) {
e.printStackTrace()
}
fun getDateTimeFromMillis(millis: Long, pattern: String): String {
val simpleDateFormat = SimpleDateFormat(pattern, Locale.getDefault()).format(Date())
return simpleDateFormat.format(millis)
}
恢复数据库的代码 将文件对象传递给 Uri.fromFile
try {
val fileUri: Uri = Uri.fromFile(file)
val inputStream = contentResolver.openInputStream(fileUri)
println("restoring ")
restoreDatabase(inputStream);
inputStream?.close()
} catch (e: IOException) {
println( e.message)
e.printStackTrace()
}
**或者返回带有启动活动的结果**
protected void onActivityResult(int requestCode, int resultCode, Intent data) {
super.onActivityResult(requestCode, resultCode, data);
if (requestCode == 12 && resultCode == RESULT_OK && data != null) {
Uri fileUri = data.getData();
try {
assert fileUri != null;
InputStream inputStream = getContentResolver().openInputStream(fileUri);
restoreDatabase(inputStream);
inputStream.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
restoreDatabase函数
private fun restoreDatabase(inputStreamNewDB: InputStream?) {
val db = AppDatabase.getInstance(this@MainActivity)
db.close()
val oldDB = getDatabasePath(DATABASE_NAME)
if (inputStreamNewDB != null) {
try {
copyFile(inputStreamNewDB as FileInputStream?, FileOutputStream(oldDB))
println("restore success")
} catch (e: IOException) {
Log.d("BindingContextFactory ", "ex for is of restore: $e")
e.printStackTrace()
}
} else {
Log.d("BindingContextFactory ", "Restore - file does not exists")
}
}
现在你需要将备份文件复制到真实的数据库文件中 使用copyFile函数
@Throws(IOException::class)
fun copyFile(fromFile: FileInputStream?, toFile: FileOutputStream) {
var fromChannel: FileChannel? = null
var toChannel: FileChannel? = null
try {
fromChannel = fromFile?.channel
toChannel = toFile.channel
fromChannel?.transferTo(0, fromChannel.size(), toChannel)
} finally {
try {
fromChannel?.close()
} finally {
toChannel?.close()
}
}
}
首先需要做的事情是创建具有适当日志模式的数据库。
Room.databaseBuilder(context, AppDatabase::class.java, name)
.setJournalMode(RoomDatabase.JournalMode.TRUNCATE)
.build()
接下来需要执行以下检查点查询以确保所有挂起的事务都得到应用。
为此，需要向数据库 Dao 接口添加以下方法。
interface UserDao {
@RawQuery
fun checkpoint(supportSQLiteQuery: SupportSQLiteQuery?): Single<Int>
}
然后需要使用以下SQL查询调用该方法
userDao.checkpoint((SimpleSQLiteQuery("pragma wal_checkpoint(full)")))
一旦检查点方法成功，数据库备份文件最终可以被保存。
以下代码可用于检索数据库备份文件。
File(database.openHelper.writableDatabase.path)
然后需要将文件复制到备份文件位置。
恢复文件的唯一操作就是用备份文件覆盖数据库文件（可以使用上面的代码片段检索数据库文件）。
您可以在我的博客上阅读更详细的内容。
https://androidexplained.github.io/android/room/2020/10/03/room-backup-restore.html
wal_checkpoint语句。根据SQLite文档：“如果禁用了写日志模式，则此编译指示符是无害的无操作”。 - Reza Mohammadi首先，必须关闭数据库以应用来自"dbName.db-wal"文件的更改。
然后，您可以复制具有所有表和最新数据更改的数据库。
AppDatabase appDatabase = AppDatabase.getAppDatabase(getApplicationContext());
appDatabase.close();
以上已经有答案了。无需关闭/重新打开数据库。
我在我的Android应用程序中使用MVVM模式备份db文件以将其上传到Google Drive。只想总结一下对我起作用的解决方案：
在DAO文件中提到以下代码：
@RawQuery
int checkpoint(SupportSQLiteQuery supportSQLiteQuery);
/* Android database has three files under /data/data/com.package.app/databases/
** test.db, test.db-shm, test.db-wal - those extra files have recent commits.
** To merge data from other shm and wal files to db, run following method - useful before taking backup.
*/
void checkPoint() {
ItemRoomDatabase.databaseWriteExecutor.execute(() -> {
itemDao.checkpoint(new SimpleSQLiteQuery("pragma wal_checkpoint(full)"));
});
}
请在您的ViewModel中提到以下内容：
public void checkPoint() {
itemRepository.checkPoint();
}
ItemViewModel itemViewModel = new ViewModelProvider(this).get(ItemViewModel.class);
itemViewModel.checkPoint();