KotlinのRoomでコルーチン対応！suspend関数とFlowの使い方をやさしく解説

先生と生徒の会話形式で理解しよう

生徒

「KotlinのRoomでデータベースを使うとき、非同期処理って必要ですか？」

先生

「うん、Roomではデータベース操作に時間がかかることがあるから、アプリが固まらないようにコルーチンで非同期処理をするのが基本なんです。」

生徒

「コルーチンって何ですか？難しそう…」

先生

「大丈夫！コルーチンは、簡単にいうと“待っている間に他の作業をする”ような仕組みだよ。Roomでは、suspend関数やFlowと一緒に使うから、実際の使い方を順番に見ていこう！」

1. Roomでコルーチンを使う理由とは？

Roomのデータベース操作は時間がかかることがあります。たとえば、何千件ものデータを読み込むときなど、アプリが一瞬止まったように感じることもあります。

そこでKotlinのコルーチンを使うと、画面表示とは別の流れで処理を行えるので、スムーズな操作を保てます。

2. suspend（サスペンド）とは？

suspend（サスペンド）関数とは、「一時停止できる関数」のことです。重い処理を一時中断して、あとで続きを再開できるのが特徴です。

Roomでは、データの追加・更新・削除などに使うのが一般的です。

3. Flow（フロー）とは？

Flowは、データの流れを非同期で受け取る仕組みです。LiveDataと似ていますが、Kotlinの標準ライブラリとして使え、より柔軟な操作ができます。

Roomでは、「データをリアルタイムで監視したい」ときに使います。

4. KotlinでRoomのDAOにsuspend関数とFlowを使う方法

では、KotlinのRoomで、suspendとFlowを使う具体例を見てみましょう。

① エンティティ（データの形）を定義


import androidx.room.Entity
import androidx.room.PrimaryKey

@Entity(tableName = "tasks")
data class Task(
    @PrimaryKey(autoGenerate = true) val id: Int = 0,
    val title: String,
    val isDone: Boolean
)

② DAOにsuspendとFlowを使った関数を定義


import androidx.room.*
import kotlinx.coroutines.flow.Flow

@Dao
interface TaskDao {

    @Insert
    suspend fun insertTask(task: Task)

    @Update
    suspend fun updateTask(task: Task)

    @Delete
    suspend fun deleteTask(task: Task)

    @Query("SELECT * FROM tasks ORDER BY id DESC")
    fun getAllTasks(): Flow<List<Task>>
}

ポイント：データを追加・更新・削除するときはsuspend、データを受け取るときはFlowを使います。

5. ViewModelやUIでの使い方

Flowを受け取るには、collect関数を使って監視します。例として、ViewModelでデータを取得するコードは以下のようになります。


class TaskViewModel(private val dao: TaskDao) : ViewModel() {

    val taskList: Flow<List<Task>> = dao.getAllTasks()

    fun addTask(title: String) {
        viewModelScope.launch {
            dao.insertTask(Task(title = title, isDone = false))
        }
    }
}