Jetpack

Android Room 基础

2020-05-23  本文已影响0人  leilifengxingmw

本文学习Room的基本使用,参考 Android Room with a View - Kotlin 这篇文章。目前在工作中也没有用到,就是为了混个脸熟,所以只学习一些基础的用法,更高级的用法在真正工作中用到的时候再去研究。

Room简介:Room持久性库在SQLite的基础上提供了一个抽象层,让用户能够在充分利用SQLite的强大功能的同时,获享更强健的数据库访问机制。

前提条件:要在项目中配置好Kotlin,要了解一点Kotlin协程的知识,了解一点LiveData。

添加依赖

dependencies {
  
  def room_version = "2.2.5"

  implementation "androidx.room:room-runtime:$room_version"
  kapt "androidx.room:room-compiler:$room_version" 

  // Room的Kotlin扩展和对协程的支持
  implementation "androidx.room:room-ktx:$room_version"
  
}

配置编译器选项

Room 具有以下注释处理器选项:

在app的build.gradle文件中,配置schemaLocation选项为app/schemas,方便我们查看数据库架构信息。

 defaultConfig {
        ...
        javaCompileOptions {
            annotationProcessorOptions {
                arguments = ["room.schemaLocation":
                                     "$projectDir/schemas".toString()]
            }
        }

    }

等我们创建好表和数据库等信息的时候,编译一下,会在app/schemas目录下生成这样的Json文件。

schema_path.png

创建一个实体类,对应数据库中的一张表

@Entity(tableName = "word_table")
data class Word(
        @PrimaryKey @ColumnInfo(name = "word") val word: String,
        val name: String? = null
)

创建DAO(data access object)

DAO必须是接口或者抽象类,Room使用注解帮我们生成访问数据库的代码,感觉和Retrofit有类似之处。接下来我们创建一个DAO类,具有简单的增删改查的功能。

//注释1处
@Dao
interface WordDao {

    @Insert()
    suspend fun insert(word: Word)
    
    @Delete
    suspend fun delete(word: Word):Int

    @Update
    suspend fun update(word: Word):Int

    //注释2处,查询整张表,升序排序
    @Query("SELECT * FROM word_table ORDER BY word ASC")
    fun getAlphabetizedWords(): LiveData<List<Word>>
    
    //...
}

注释1处,使用@Dao注解WordDao类,增删改方法我们都用suspend关键字修饰了,所以你需要在协程中或者另一个挂起函数中调用。

注释2处,当方法返回类型是LiveData的时候,真正的查询默认是在工作线程的,Room内部为我们做了一些线程切换的工作,暂时不去管。

添加Room数据库

//注释1处
@Database(entities = [Word::class], version = 1, exportSchema = true)
abstract class WordRoomDatabase : RoomDatabase() {

    //注释2处
    abstract fun wordDao(): WordDao

    //获取单例
    companion object {

        @JvmStatic
        @Volatile
        private var INSTANCE: WordRoomDatabase? = null

        @JvmStatic
        fun getDatabase(context: Context): WordRoomDatabase {
            val tempInstance = INSTANCE
            if (tempInstance != null) {
                return tempInstance
            }
            synchronized(this) {
                //注释3处
                val instance = Room.databaseBuilder(context.applicationContext, WordRoomDatabase::class.java,
                        "word_database")
                        .build()
                INSTANCE = instance
                return instance
            }
        }
    }
}

Room数据库必须是一个继承自RoomDatabase的抽象类。通常情况下应用内应该只有一个Room数据库实例。

注释1处使用@Database注解WordRoomDatabase类,并指定数据库中的表,版本号和是否在指定的schemaLocation目录下输出数据库架构信息。

注释2处,提供获取DAO类的抽象方法。

注释3处,获取WordRoomDatabase类的实例。

插入数据

//在协程中调用
launch {
     val word = Word("Hi", "dmw")
     wordDAO.insert(word)
}

如果要插入多条数据,我们可以如下声明

//插入两条数据
@Insert
suspend fun insert(word1: Word, word2: Word)

//可变参数
@Insert
fun insert(vararg words: Word)

//插入列表
@Insert
suspend fun insert(wordList: List<Word>)

插入数据时候的冲突策略

如果我们插入的数据在数据库表中已经存在了,那么我们就会遇到冲突。遇到冲突时候的时候处理冲突的策略如下:


public @interface OnConflictStrategy {
    /**
     * 替换,数据会发生变化
     */
    int REPLACE = 1;
   
    /**
     * 默认行为,终止操作,抛出异常
     */
    int ABORT = 3;
    
    /**
     * 忽略冲突,数据不会发生变化
     */
    int IGNORE = 5;

}

删除数据

注意在删除数据的时候,是根据primary key来查找要删除的记录。如果记录不存在,则不会改变数据。

private fun deleteWord() {
    launch {
        val word = Word("Hi", "dmw")
        //返回删除的行数
        val row = wordDAO.delete(word)
        Log.d(TAG, "deleteWord: row = $row")

    }
}

删除多条数据可如下声明

@Delete
suspend fun delete(word1: Word, word2: Word): Int

//可变参数
@Delete
fun delete(vararg words: Word)

//插入列表
@Delete
suspend fun delete(wordList: List<Word>)

更新数据

注意在更新数据的时候,是根据primary key来查找要更新的记录。如果记录不存在,则不会改变数据。

private fun updateWord() {
    launch {
        val word1 = Word("Hi0", "dmw${System.currentTimeMillis()}")
        //更新的行数
        val row = wordDAO.update(word1)
        Log.d(TAG, "updateWord: row = $row")
    }
}

更新多条记录可如下声明

@Update
suspend fun update(word1: Word, word2: Word): Int

@Update
suspend fun update(vararg words: Word): Int

@Update
suspend fun update(wordList: List<Word>): Int

查询数据

/**
 * 真正的查询默认是在工作线程的,Room内部为我们做了一些线程切换的工作,暂时不去管
 */
@Query("SELECT * FROM word_table ORDER BY word ASC")
fun getAlphabetizedWords(): LiveData<List<Word>>

默认情况下,为了避免阻塞主线程,Room不允许在主线程查询数据。当Room的返回类型是LiveData的时候,查询操作会自动在一个后台线程异步进行。

private fun queryWord() {
    val allWords = wordDAO.getAlphabetizedWords()
    allWords.observe(this, Observer { list ->
        list.forEach {
            Log.d(TAG, "queryWord: ${it.word},${it.name}")
        }
    })
}

增删改番外篇

以插入数据举例。

定义Playlist类,对应数据库中的一张表

@Entity
class Playlist(
    @PrimaryKey(autoGenerate = true)
    val playlistId: Long,
    val name: String,
    val description: String,
    @ColumnInfo(defaultValue = "normal")
    val category: String,
    @ColumnInfo(defaultValue = "CURRENT_TIMESTAMP")
    val createdTime: String,
    @ColumnInfo(defaultValue = "CURRENT_TIMESTAMP")
    val lastModifiedTime: String
)

定义一个NameAndDescription类,注意,该类是Playlist类的子集,即NameAndDescription中有的成员变量,Playlist类中都有。

class NameAndDescription(
    val name: String,
    val description: String
)

创建PlaylistDao类

@Dao
interface PlaylistDao {

    @Insert(entity = Playlist::class)
    suspend fun insert(nameDescription: NameAndDescription)
}

我们在插入数据的时候,@Insert指定了我们要插入的类是Playlist,但是我们方法中传入的参数类型是Playlist的子集。 那么在插入的时候相当于我们向Playlist表中只插入了部分列,其他列都是默认值。

例如我们插入如下一条数据

private fun insertPlaylist() {
    launch {
        val nameAndDescription = NameAndDescription("dmw", "帅")
        playlistDao.insertPartial(nameAndDescription)
    }
}

使用stetho查看数据库中的内容


partial_insert_1.png

数据插入成功,name和description列都是正常的,其他列都是默认值。createdTime和lastModifiedTime 这两列注意一下竟然给我们自动转成了日期,要注意一下时间的问题避免踩坑。

到这里我有个疑问,如果NameAndDescription类中存在Playlist不存在的字段会怎么样。猜想是:不存在的字段会被忽略。接下来我们验证一下。

修改NameAndDescription类,添加一个age字段

class NameAndDescription(
    val name: String,
    val description: String,
    val age:Int
)

插入数据

private fun insertPlaylist() {
    launch {
        val nameAndDescription = NameAndDescription("dmw", "小伙子可以", 28)
        playlistDao.insertPartial(nameAndDescription)
    }
}

结果打脸,直接编译不过。

错误: Cannot find a column in the entity Playlist that matches with this partial entity field. 
If you don't wish to use the field then you can annotate it with @Ignore.
private final int age = 0;

告诉我们Playlist表中没有一列和age字段匹配。我们可以使用 @Ignore注解来忽略age字段。

class NameAndDescription(
    val name: String,
    val description: String,
    @Ignore
    val age:Int
)

现在就可以了。


partial_insert_2.png

更新和删除也有类似的功能,但是更新和删除的时候需要主键,这里就不去探索了,有兴趣的可以研究一下。

参考链接:

上一篇下一篇

猜你喜欢

热点阅读