在android中将房间数据库导出到csv文件

Question

有很多教程可用于将 SQLite 数据库导出到 csv 文件，但从房间数据库导出的内容还不够。

使用 sqlite 导出引用 Exporting SQLite Database to csv file in android 手动解析行的每一列以获得空间。以下是我的代码：

     @Dao
     interface CategoryDao {
         @Query("SELECT * FROM Category")
         fun getAllCategory(): List<Category>
     }

//   Export csv logic

      val categoryList = categoryDao.getAllCategory()
      val csvWrite = CSVWriter(FileWriter(file))

      for (item in categoryList) {
         val arrStr = arrayOf<String>(item.categoryId, item.categoryName)
         csvWrite.writeNext(arrStr)
      }

还有其他导出csv的方法吗？即使在房间里也没有实用地获取表的列名，因此无法为所有表创建动态的通用逻辑。

Answer 1

试试这个
从 Cursor 中获取 Column 数据

@Query("SELECT * FROM Category")
Cursor getAllCategory();

Answer 2

要将房间数据库数据导出到mydb.sqlite 文件并存储到外部存储中，请按照以下步骤操作。

  fun exportDatabase(){
      val sd = Environment.getExternalStorageDirectory()

      // Get the Room database storage path using SupportSQLiteOpenHelper 
      AppDatabase.getDatabase(applicationContext)!!.openHelper.writableDatabase.path

            if (sd.canWrite()) {
                val currentDBPath = AppDatabase.getDatabase(applicationContext)!!.openHelper.writableDatabase.path
                val backupDBPath = "mydb.sqlite"      //you can modify the file type you need to export
                val currentDB = File(currentDBPath)
                val backupDB = File(sd, backupDBPath)
                if (currentDB.exists()) {
                    try {
                        val src = FileInputStream(currentDB).channel
                        val dst = FileOutputStream(backupDB).channel
                        dst.transferFrom(src, 0, src.size())
                        src.close()
                        dst.close()
                    } catch (e: IOException) {
                        e.printStackTrace()
                    }
                }
            }
       }

Answer 3

我尝试通过两种方式迭代大型 Room 数据库：

1- 获取 Cursor 并对其进行迭代：

import android.database.Cursor
...
@Query("SELECT * FROM Category")
fun getAllCategory(): Cursor<Category>
...
val success = cursor.moveToFirst()
if (success) {
     while (!cursor.isAfterLast) {
         // Process items
         cursor.moveToNext()
     }
} else {
    // Empty
}
cursor.close()

2- 使用PagedList 一次获取pageSize 数量的项目并进行处理。然后查询另一个页面并处理：

@Query("SELECT * FROM Category")
fun getAllCategory(): DataSource.Factory<Int, Category>

// Here i will return Flowable. You can return LiveData with 'LivePagedListBuilder'
fun getCategories(pageSize: Int): Flowable<PagedList<Category>> {
        val config = PagedList.Config.Builder()
                .setPageSize(pageSize)
                .setPrefetchDistance(pageSize / 4)
                .setEnablePlaceholders(true)
                .setInitialLoadSizeHint(pageSize)
                .build()
        return RxPagedListBuilder(categoryDao.getAllCategory(), config)
                .buildFlowable(BackpressureStrategy.BUFFER)
}

现在上面的getCategories() 函数将在Flowable 或LiveData 内返回pagedList。由于我们设置了setEnablePlaceholders(true)，pagedList.size 将显示整个大小，即使它不在内存中。因此，如果pageSize 为 50，并且所有数据大小为 1000，pagedList.size 将返回 1000，但其中大部分为空。查询下一页并处理：

// Callback is triggered when next page is loaded
pagedList.addWeakCallback(pagedList.snapshot(), object : PagedList.Callback() {
    override fun onChanged(position: Int, count: Int) {
        for (index in position until (position + count)) {
            if (index == (position + count - 1)) {
                if (index < (pagedList.size - 1)) 
                    pagedList.loadAround(index + 1)
                else{ 
                    // Last item is processed.
                }
            } else
                processCurrentValue(index, pagedList[index]!!)
        }
    }
    override fun onInserted(position: Int, count: Int) {
        // You better not change database while iterating over it 
    }    
    override fun onRemoved(position: Int, count: Int) {
        // You better not change database while iterating over it
    }
})

// Start to iterate and query next page when item is null.
for (index in 0 until pagedList.size) {
     if (pagedList[index] != null) {
            processCurrentValue(index, pagedList[index]!!)
     } else {
            // Query next page
            pagedList.loadAround(index)
            break
     }
}

---

结论：在PagedList 方法中，您可以一次获取数千行并进行处理，而在Cursor 方法中，您可以逐行迭代。当pageSize > 3000时我发现PagedList不稳定。它有时不返回页面。所以我使用了Cursor。在 Android 8 手机上使用这两种方法迭代（和处理）900k 行大约需要 5 分钟。