Database with Room using Rxjava

Google发布了新的开源库Room，他是属于数据库层的，可以让我们顺畅的数据库，更多相关信息可以移步官方文档。
在这篇文章中，我们将使用更加优雅的方式来访问数据库，使用Rxjava来避免在UI线程中操作数据库，从而都移到后台线程中操作数据。
首先需要在build.gradle文件中引入如下的库：

// for room
compile "android.arch.persistence.room:runtime:1.0.0-beta1"
annotationProcessor "android.arch.persistence.room:compiler:1.0.0-beta1"

// for Rxjava
compile "io.reactivex.rxjava2:rxjava:2.0.6"
compile "io.reactivex.rxjava2:rxandroid:2.0.1"

首先创建实体类User作为示例,最近在学Kotlin，所以把所有的代码都改成了Kotlin，如有不正确之处，欢迎指正：

@Entity(tableName = "users")
class User(@ColumnInfo(name = "first_name")
           var firstName: String?, @ColumnInfo(name = "last_name")
           var lastName: String?) {
    @PrimaryKey(autoGenerate = true)
    var uid: Int = 0
}

接着我们需要一个接口UserDao：

@Dao
interface UserDao {
    @Query("SELECT * FROM users")
    fun getAll(): Maybe<List<User>>

    @Query("SELECT * FROM users WHERE uid IN (:userIds)")
    fun loadAllByIds(userIds: IntArray): Flowable<List<User>>

    @Query("SELECT * FROM users WHERE first_name LIKE :first AND " + "last_name LIKE :last LIMIT 1")
    fun findByName(first: String, last: String): User

    @Query("SELECT * FROM users where uid = :id")
    fun findById(id: Int): Maybe<User>

    @Insert
    fun insertAll(vararg users: User)

    @Delete
    fun delete(user: User)

    @Update
    fun updateUsers(vararg users: User)
}

接着添加AppDatabase

@Database(entities = arrayOf(User::class), version = 1)
abstract class AppDatabase : RoomDatabase() {
    abstract fun userDao(): UserDao
}

在我们的示例中，直接通过调用LocalCacheManager来访问数据库

class LocalCacheManager(private val context: Context) {
    private val db: AppDatabase

    init {
        db = Room.databaseBuilder(context, AppDatabase::class.java, DB_NAME).build()
    }

    val users: Maybe<List<User>>
        get() = db.userDao().getAll()
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())

    fun addUser(firstName: String, lastName: String): Completable {
        return Completable.fromAction {
            val user = User(firstName, lastName)
            db.userDao().insertAll(user)
        }.subscribeOn(Schedulers.io())
          .observeOn(AndroidSchedulers.mainThread())
    }

    fun deleteUser(user: User): Completable {
        return Completable.fromAction { db.userDao().delete(user) }.subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
    }


    fun updateUser(user: User): Completable {
        user.firstName = "first name first name"
        user.lastName = "last name last name"
        return Completable.fromAction { db.userDao().updateUsers(user) }.subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread())
    }

    companion object {
        private val DB_NAME = "database-name"
        private var _instance: LocalCacheManager? = null

        fun getInstance(context: Context): LocalCacheManager {
            if (_instance == null) {
                _instance = LocalCacheManager(context)
            }
            return _instance as LocalCacheManager
        }
    }
}

原示例中使用的是接口回调的方式来通知数据操作完成的，我把这里都做了一些修改。
这样，所有的操作都移到了io线程中。

原文地址：https://medium.com/@alahammad/database-with-room-using-rxjava-764ee6124974