Android Rxjava Room DB

🔥 Rxjava와 함께 Android Room DB 구현하기

🎈 데이터베이스 액세스와 같이 무거운 실행은 MainThread 가 아닌 다른 Thread에서 실행해야 하는데, 이번 예제에서는 Rxjava3 를 적용시켜서 Room DB 를 구현하였다.

📑 순서

1. build.gradle
2. Dao, 사용

✔ build.gradle

plugins {
    ...
    id 'kotlin-kapt'
}

dependencies {
	...
    implementation "androidx.room:room-runtime:2.5.1"
    annotationProcessor "androidx.room:room-compiler:2.5.1"
    implementation "androidx.room:room-rxjava3:2.5.1"

    implementation 'io.reactivex.rxjava3:rxandroid:3.0.2'
    implementation 'io.reactivex.rxjava3:rxjava:3.1.5'
}

✔ Dao

@Dao
public interface TestDao {
    @Query("SELECT * FROM testInfo")
    Single<List<TestInfo>> getAll();

    @Insert
    Completable addTest(TestInfo testInfo);

    @Update
    Completable updateTest(TestInfo testInfo);
}

• Room DB 는 Rxjava를 적용하기 쉽게 구현되어 있다.
• Dao에서 Single, Completable, Flowable 등을 선택하여 작성하면, 간단하게 연동할 수 있다.
• 위 예제에서 addTest() 와 updateText() 는 데이터를 발행할 필요 없이 수행만 진행하고 종료시키기 위하여 Completable을 사용하였다.

✔ 사용

// 사용
TestDataBase.getInstance(context)
        .testDao()
        .addTest(testInfo)
        .subscribeOn(Schedulers.io())
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe();
        
TestDataBase.getInstance(context)
        .testDao()
        .getAll()
        .subscribeOn(Schedulers.io())
        .observeOn(AndroidSchedulers.mainThread())
        .doOnSuccess(list -> {
            // 성공
        }).subscribe();        

• Rxjava 는 subscribe 와 observe 를 사용하여 특정 이벤트를 관찰하고 구독한다는 개념을 사용한다.
• 이렇게 구독을 하고, 이벤트가 발생하였을 때, 구독한 사용자에게 데이터가 발행된다고 말한다.