[TIL] 🌼24/05/09🌼#Room asynchronous query

[TIL] 🌼24/05/09🌼#Room asynchronous query

Room asynchronous query

📌참고자료

• Write asynchronous DAO queries | Android Developers
• Flow<List> instead of using Flow? | stack overflow

• Room asynchronous query
  • asynchronous one-shot write query
  • observable query

asynchronous one-shot 쿼리

• suspend 키워드 사용, Room Entity 클래스 인스턴스 반환
• one-shot 쿼리인 이유?
  함수를 호출했을 때 수행됨, 함수 수행될 때의 데이터베이스 상태 스냅샷 반환

@Dao
interface UserDao {
    @Insert(onConflict = OnConflictStrategy.REPLACE)
    suspend fun insertUsers(vararg users: User)

    @Update
    suspend fun updateUsers(vararg users: User)

    @Delete
    suspend fun deleteUsers(vararg users: User)

    @Query("SELECT * FROM user WHERE id = :id")
    suspend fun loadUserById(id: Int): User

    @Query("SELECT * from user WHERE region IN (:regions)")
    suspend fun loadUsersByRegion(regions: List<String>): List<User>
}

observable 쿼리

• suspend 키워드 사용 X, Flow 반환
  • Room Entity 클래스 인스턴스 목록을 반환받을 때, Flow<*>가 아닌 Flow<List<*>> 타입으로 반환 받음!
• observable한 이유?
  • 쿼리가 참조하는 데이터베이스에 변화가 생기면, 쿼리를 자동적으로 수행하여 결과 emit
  • whenever any row in the table is updated
    → 쿼리 결과로 반환되는 row에는 변화가 없을 수도 있음
    → 변화가 있을 때만 UI에게 notify되도록 distinctUtilChanged 연산자 적용해주기

@Dao
interface UserDao {
    @Query("SELECT * FROM user WHERE id = :id")
    fun loadUserById(id: Int): Flow<User>

    @Query("SELECT * from user WHERE region IN (:regions)")
    fun loadUsersByRegion(regions: List<String>): Flow<List<User>>
}