Jetpack 总结系列- Google-Room数据库使用

怼烎@ 2023-01-16 14:26 149阅读 0赞

官方文档 : [Room][]  谷歌实验室：[官方教程][Link 1] SQL语法：[SQLite教程][SQLite]

与greendao的区别：同样基于ORM模式封装的数据库。而Room和其他ORM对比，具有编译时验证查询语句正常性，支持LiveData数据返回等优势。

# 第一步 添加依赖 #

apply plugin: 'kotlin-kapt'
    dependencies {
        // Room
        implementation "androidx.room:room-runtime:2.2.5"
        kapt "androidx.room:room-compiler:2.2.5"
        androidTestImplementation "androidx.room:room-testing:$rootProject.roomVersion"}
    //注意：对于基于 Kotlin 的应用，请确保使用 kapt，而不是 annotationProcessor。您还应添加 kotlin-kapt 插件。

//注意：**对于基于 Kotlin 的应用，请确保使用 kapt**，而不是 annotationProcessor。您还应添加 kotlin-kapt 插件。

配置编译器选项

defaultConfig {
        //指定room.schemaLocation生成的文件路径  处理Room 警告 Schema export Error
        javaCompileOptions {
            annotationProcessorOptions {
                arguments = [
                        //配置并启用将数据库架构导出到给定目录中的 JSON 文件的功能。如需了解详情，请参阅 Room 迁移。
                        "room.schemaLocation"  : "$projectDir/schemas".toString(),
                        "room.incremental"     : "true",//启用 Gradle 增量注释处理器
                        "room.expandProjection": "true"]//配置 Room 以重写查询
            }
        }
    }

# 第二步 创建表（实体） #

<table> 
 <tbody> 
 <tr> 
 <td> 注解 </td> 
 <td> 说明 </td> 
 </tr> 
 <tr> 
 <td> @Entity </td> 
 <td> 声明这是一个表（实体），主要参数：tableName-表名、foreignKeys-外键、indices-索引。 </td> 
 </tr> 
 <tr> 
 <td> @ColumnInfo </td> 
 <td> 主要用来修改在数据库中的字段名。&nbsp;@ColumnInfo(name = "shoe_id") </td> 
 </tr> 
 <tr> 
 <td> @PrimaryKey </td> 
 <td> 声明该字段主键并可以声明是否自动创建。&nbsp;&nbsp;&nbsp;@PrimaryKey(autoGenerate = true) </td> 
 </tr> 
 <tr> 
 <td> @Ignore </td> 
 <td> 声明某个字段只是临时用，不存储在数据库中。 </td> 
 </tr> 
 <tr> 
 <td> @Embedded </td> 
 <td> 用于嵌套，里面的字段同样会存储在数据库中。 </td> 
 </tr> 
 <tr> 
 <td> @ForeignKey&nbsp; &nbsp; </td> 
 <td> 外键约束 </td> 
 </tr> 
 </tbody> 
</table>

**@Entity(tableName = "xxx")**

@Entity(tableName = "xxx")
        data class User(
            @PrimaryKey val uid: Int,
            @ColumnInfo(name = "first_name") val firstName: String?,
            @ColumnInfo(name = "last_name") val lastName: String?
        )

/** 示例
    * 鞋表
    */@Entity(tableName = "shoe")data class Shoe(
        @ColumnInfo(name = "shoe_name") val name: String // 鞋名
        , @ColumnInfo(name = "shoe_description") val description: String// 描述
        , @ColumnInfo(name = "shoe_price") val price: Float // 价格
        , @ColumnInfo(name = "shoe_brand") val brand: String // 品牌
        , @ColumnInfo(name = "shoe_imgUrl") val imageUrl: String // 图片地址) {
        @PrimaryKey(autoGenerate = true)
        @ColumnInfo(name = "id")
        var id: Long = 0}

# 第三步 创建Dao #

@Dao
 interface UserDao {
 @Query("SELECT * FROM user")
 fun getAll(): List<User>
 
 @Query("SELECT * FROM user WHERE uid IN (:userIds)")
 fun loadAllByIds(userIds: IntArray): List<User>
 
 @Query("SELECT * FROM user WHERE first_name LIKE :first AND " +
 "last_name LIKE :last LIMIT 1")
 fun findByName(first: String, last: String): User
 
 @Insert
 fun insertAll(vararg users: User)
 
 
 @Delete
 fun delete(user: User)
 }

示例:

<table> 
 <tbody> 
 <tr> 
 <td> 增 @Insert注解声明当前的方法为新增的方法，并且可以设置当新增冲突的时候处理的方法。 @Insert(onConflict = OnConflictStrategy.REPLACE)主键相同的话，旧数据会替换新数据。 @Daointerface ShoeDao { &nbsp;&nbsp;&nbsp;&nbsp;// 省略... &nbsp;&nbsp;&nbsp;&nbsp;// 增加一双鞋子 &nbsp;&nbsp;&nbsp;&nbsp;@Insert(onConflict = OnConflictStrategy.REPLACE) &nbsp;&nbsp;&nbsp;&nbsp;fun insertShoe(shoe: Shoe) &nbsp;&nbsp;&nbsp;&nbsp;// 增加多双鞋子 &nbsp;&nbsp;&nbsp;&nbsp;// 除了List之外，也可以使用数组 &nbsp;&nbsp;&nbsp;&nbsp;@Insert(onConflict = OnConflictStrategy.REPLACE) &nbsp;&nbsp;&nbsp;&nbsp;fun insertShoes(shoes: List&lt;Shoe&gt;)} </td> 
 <td> 查&nbsp; Room的查很接近原生的SQL语句。@Query注解不仅可以声明这是一个查询语句，也可以用来删除和修改，不可以用来新增。 &nbsp; 简单查询&nbsp; 查询多个的时候，可以返回List和数组，还可以配合LiveData和RxJava 2。 @Daointerface ShoeDao { &nbsp;&nbsp;&nbsp;&nbsp;// 查询一个 &nbsp;&nbsp;&nbsp;&nbsp;@Query("SELECT * FROM shoe WHERE id=:id") &nbsp;&nbsp;&nbsp;&nbsp;fun findShoeById(id: Long): Shoe? &nbsp;&nbsp;&nbsp;&nbsp;// 查询多个 通过品牌查询多款鞋 &nbsp;&nbsp;&nbsp;&nbsp;@Query("SELECT * FROM shoe WHERE shoe_brand=:brand") &nbsp;&nbsp;&nbsp;&nbsp;fun findShoesByBrand(brand: String): List&lt;Shoe&gt; &nbsp;&nbsp;&nbsp;&nbsp;// 模糊查询 排序 同名鞋名查询鞋 &nbsp;&nbsp;&nbsp;&nbsp;@Query("SELECT * FROM shoe WHERE shoe_name LIKE :name ORDER BY shoe_brand ASC") &nbsp;&nbsp;&nbsp;&nbsp;fun findShoesByName(name:String):List&lt;Shoe&gt; &nbsp;&nbsp;&nbsp;&nbsp;// 配合LiveData 返回所有的鞋子 &nbsp;&nbsp;&nbsp;&nbsp;@Query("SELECT * FROM shoe") &nbsp;&nbsp;&nbsp;&nbsp;fun getAllShoesLD(): LiveData&lt;List&lt;Shoe&gt;&gt; &nbsp;&nbsp;&nbsp;&nbsp;// 配合LiveData 通过Id查询单款鞋子 &nbsp;&nbsp;&nbsp;&nbsp;@Query("SELECT * FROM shoe WHERE id=:id") &nbsp;&nbsp;&nbsp;&nbsp;fun findShoeByIdLD(id: Long): LiveData&lt;Shoe&gt; &nbsp;&nbsp;&nbsp;&nbsp;// 配合RxJava 通过Id查询单款鞋子 &nbsp;&nbsp;&nbsp;&nbsp;@Query("SELECT * FROM shoe WHERE id=:id") &nbsp;&nbsp;&nbsp;&nbsp;fun findShoeByIdRx(id: Long): Flowable&lt;Shoe&gt; &nbsp;&nbsp;&nbsp;&nbsp;// 省略...} &nbsp; 复合查询 @Daointerface ShoeDao { &nbsp;&nbsp;&nbsp;&nbsp;// 省略... &nbsp;&nbsp;&nbsp;&nbsp;// 根据收藏结合 查询用户喜欢的鞋的集合 内联查询 &nbsp;&nbsp;&nbsp;&nbsp;@Query( &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;"SELECT shoe.id,shoe.shoe_name,shoe.shoe_description,shoe.shoe_price,shoe.shoe_brand,shoe.shoe_imgUrl " + &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;"FROM shoe " + &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;"INNER JOIN fav_shoe ON fav_shoe.shoe_id = shoe.id " + &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;"WHERE fav_shoe.user_id = :userId" &nbsp;&nbsp;&nbsp;&nbsp;) &nbsp;&nbsp;&nbsp;&nbsp;fun findShoesByUserId(userId: Long): LiveData&lt;List&lt;Shoe&gt;&gt;} &nbsp; </td> 
 </tr> 
 <tr> 
 <td> 删&nbsp; @Delete注解声明当前的方法是一个删除方法。 @Daointerface ShoeDao { &nbsp;&nbsp;&nbsp;&nbsp;// 省略... &nbsp;&nbsp;&nbsp;&nbsp;// 删除一双鞋子 &nbsp;&nbsp;&nbsp;&nbsp;@Delete &nbsp;&nbsp;&nbsp;&nbsp;fun deleteShoe(shoe: Shoe) &nbsp;&nbsp;&nbsp;&nbsp;// 删除多个鞋子 &nbsp;&nbsp;&nbsp;&nbsp;// 参数也可以使用数组 &nbsp;&nbsp;&nbsp;&nbsp;@Delete &nbsp;&nbsp;&nbsp;&nbsp;fun deleteShoes(shoes:List&lt;Shoe&gt;)} </td> 
 </tr> 
 <tr> 
 <td> 改&nbsp; @Update注解声明当前方法是一个更新方法 @Daointerface ShoeDao { &nbsp;&nbsp;&nbsp;&nbsp;// 省略... &nbsp;&nbsp;&nbsp;&nbsp;// 更新一双鞋 &nbsp;&nbsp;&nbsp;&nbsp;@Update &nbsp;&nbsp;&nbsp;&nbsp;fun updateShoe(shoe:Shoe) &nbsp;&nbsp;&nbsp;&nbsp;// 更新多双鞋 &nbsp;&nbsp;&nbsp;&nbsp;// 参数也可以是集合 &nbsp;&nbsp;&nbsp;&nbsp;@Update &nbsp;&nbsp;&nbsp;&nbsp;fun updateShoes(shoes:Array&lt;Shoe&gt;)} &nbsp; 更新部分字段: @Query("UPDATE people SET is_alive= :alive WHERE name = :name") public abstract int setIsAliveByName(String name, int alive); </td> 
 </tr> 
 </tbody> 
</table>

# 第四步 创建数据库 #

/**
 * 数据库文件
 */@Database(entities = [User::class,Shoe::class,FavouriteShoe::class],version = 1,exportSchema = false)abstract class AppDataBase:RoomDatabase() {
 // 得到UserDao
 abstract fun userDao():UserDao
 // 得到ShoeDao
 abstract fun shoeDao():ShoeDao
 // 得到FavouriteShoeDao
 abstract fun favouriteShoeDao():FavouriteShoeDao
 companion object{
 @Volatile
 private var instance:AppDataBase? = null
 
 
 fun getInstance(context:Context):AppDataBase{
 return instance?: synchronized(this){
 instance?:buildDataBase(context)
 .also {
 instance = it
 }
 }
 }
 private fun buildDataBase(context: Context):AppDataBase{
 return Room
 .databaseBuilder(context,AppDataBase::class.java,"jetPackDemo-database")
 .addCallback(object :RoomDatabase.Callback(){
 override fun onCreate(db: SupportSQLiteDatabase) {
 super.onCreate(db)
 
 
 // 读取鞋的集合
 val request = OneTimeWorkRequestBuilder<ShoeWorker>().build()
 WorkManager.getInstance(context).enqueue(request)
 }
 })
 .build()
 }
 }}
 @Database注解声明当前是一个数据库文件，注解中entities变量声明数据库中的表（实体），以及其他的例如版本等变量。同时，获取的Dao也必须在数据库类中。完成之后，点击build目录下的make project，系统就会自动帮我创建AppDataBase和xxxDao的实现类。

# 第五步 简要封装 #

在不使用LiveData和RxJava的前提下，Room的操作是不可以放在主线程中的。
 /**
 * 用户处理仓库
 */class UserRepository private constructor(private val userDao: UserDao) {
 //...
 /**
 * 登录用户 本地数据库的查询
 */
 fun login(account: String, pwd: String):LiveData<User?>
 = userDao.login(account,pwd)
 /**
 * 注册一个用户 本地数据库的新增
 */
 suspend fun register(email: String, account: String, pwd: String):Long {
 return withContext(IO) {
 userDao.insertUser(User(account, pwd, email))
 }
 }
 companion object {
 @Volatile
 private var instance: UserRepository? = null
 fun getInstance(userDao: UserDao): UserRepository =
 // ...
 }}
 register()方法是一个普通方法，所以它需要在子线程使用，如代码所见，通过协程实现。login()是配合LiveData使用的，不需要额外创建子线程，但是他的核心数据库操作还是在子线程中实现的。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTEyMDA2MDQ_size_16_color_FFFFFF_t_70][]

--------------------

参考:

[Google文档][Google]    ;   [Room库版本][Room 1]   ;  [SQLite教程0-菜鸟][SQLite]

[Android从零开始搭建MVVM架构（4）————Room（从入门到进阶）][Android_MVVM_4_Room]

[即学即用Android Jetpack - Room][Android Jetpack - Room]

[Jetpack架构组件 — Room入坑详解][Jetpack_ _ Room]

[快速掌握Room数据库框架][Room 2]

[一篇好文之Android数据库 GreenDao的完全解析][Android_ GreenDao]

[Room数据库迁移][Room 3]     ;    [Room数据库升级][Room 4](知乎)     ;    [Room数据库版本升级，][Room 5][数据迁移详解][Room 5]     ;   [Room数据库的版本升级姿势][Room 6]

[Room]: https://developer.android.com/topic/libraries/architecture/room
[Link 1]: https://developer.android.com/codelabs/android-room-with-a-view-kotlin#0
[SQLite]: https://www.runoob.com/sqlite/sqlite-tutorial.html
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTEyMDA2MDQ_size_16_color_FFFFFF_t_70]: /images/20221022/f92ba1d961fc4eea8d4d73208c9cb8fb.png
[Google]: https://developer.android.google.cn/training/data-storage/room?hl=zh_cn#java
[Room 1]: https://developer.android.google.cn/jetpack/androidx/releases/room?hl=zh_cn#declaring_dependencies
[Android_MVVM_4_Room]: https://juejin.im/post/5d9fdacaf265da5bb86ac12c
[Android Jetpack - Room]: https://www.jianshu.com/p/815c7db24b6d
[Jetpack_ _ Room]: https://juejin.im/post/5dde5f305188257a0d22ae25#heading-0
[Room 2]: https://www.jianshu.com/p/72c8efc3ad87
[Android_ GreenDao]: https://www.jianshu.com/p/53083f782ea2
[Room 3]: https://www.jianshu.com/p/3d2874f3a082
[Room 4]: https://zhuanlan.zhihu.com/p/77408877
[Room 5]: https://blog.csdn.net/yonghuming_jesse/article/details/98037118
[Room 6]: https://www.jianshu.com/p/fae0245cf384