kotlin--Flow結(jié)合Room運(yùn)用

kotlin結(jié)合Room在實(shí)際項(xiàng)目中的運(yùn)用

架構(gòu)還是MVVM,DataBinding+ViewModel+LiveData的組合

效果:

1.首先添加Room依賴(lài)

添加kapt插件:

plugins {
    id 'com.android.application'
    id 'kotlin-android'
    id 'kotlin-kapt'
}
    def room_version = "2.3.0"
    implementation "androidx.room:room-runtime:$room_version"
    implementation "androidx.room:room-ktx:$room_version"
    kapt "androidx.room:room-compiler:$room_version"
2.創(chuàng)建數(shù)據(jù)庫(kù)相關(guān)類(lèi)

entity:

package com.aruba.flowapplyapplication.database.entity

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

/**
 * Created by aruba on 2021/9/20.
 */
@Entity
data class UserInfo(
    @PrimaryKey val id: Int,
    var userName: String,
    var age: Int
)

Dao炫乓,之前我們需要使用異步任務(wù)操作Dao刚夺,kotlin則可以使用掛起函數(shù),標(biāo)識(shí)使用協(xié)程操作:

package com.aruba.flowapplyapplication.database.dao

import androidx.room.Dao
import androidx.room.Insert
import androidx.room.OnConflictStrategy
import androidx.room.Query
import com.aruba.flowapplyapplication.database.entity.UserInfo
import kotlinx.coroutines.flow.Flow

/**
 * Created by aruba on 2021/9/20.
 */
@Dao
interface UserInfoDao {
    //id重復(fù)的替換
    @Insert(onConflict = OnConflictStrategy.REPLACE)
    suspend fun insert(userInfo: UserInfo)

    //返回Flow末捣,由于Flow需要使用collect侠姑,該函數(shù)為掛起函數(shù),所以不需要加suspend了
    @Query("SELECT * FROM userinfo")
    fun getUserInfoList(): Flow<List<UserInfo>>
}

Database:

package com.aruba.flowapplyapplication.database

import android.content.Context
import androidx.room.Database
import androidx.room.Room
import androidx.room.RoomDatabase
import com.aruba.flowapplyapplication.database.dao.UserInfoDao
import com.aruba.flowapplyapplication.database.entity.UserInfo

private const val DB_NAME: String = "my.db"

/**
 * Created by aruba on 2021/9/20.
 */
@Database(entities = [UserInfo::class], version = 1, exportSchema = true)
abstract class MyDatabase : RoomDatabase() {

    abstract fun getUserDao(): UserInfoDao

    companion object {
        private var instance: MyDatabase? = null

        fun getInstance(): MyDatabase {
            checkNotNull(instance) { "init has not been called" }
            return instance as MyDatabase
        }

        fun init(context: Context) {
            synchronized(this) {
                instance ?: Room.databaseBuilder(
                    context,
                    MyDatabase::class.java, DB_NAME
                ).build().let { instance = it }
            }
        }
    }
}
3.定義ViewModel

使用LiveData對(duì)三個(gè)EditText進(jìn)行雙向綁定

package com.aruba.flowapplyapplication.viewmodel

import android.view.View
import androidx.lifecycle.MutableLiveData
import androidx.lifecycle.ViewModel
import androidx.lifecycle.viewModelScope
import com.aruba.flowapplyapplication.database.MyDatabase
import com.aruba.flowapplyapplication.database.dao.UserInfoDao
import com.aruba.flowapplyapplication.database.entity.UserInfo
import kotlinx.coroutines.Dispatchers
import kotlinx.coroutines.flow.Flow
import kotlinx.coroutines.flow.collect
import kotlinx.coroutines.flow.flowOn
import kotlinx.coroutines.launch
import androidx.databinding.ObservableField


/**
 * Created by aruba on 2021/9/20.
 */
class UserInfoViewModel : ViewModel() {
    val id = MutableLiveData<String>()
    val name = MutableLiveData<String>()
    val age = MutableLiveData<String>()

    private val userInfoDao: UserInfoDao by lazy {
        MyDatabase.getInstance().getUserDao()
    }

    fun insert(v: View) {
        if (id.value == null || name.value == null || age.value == null) {
            return
        }

        val userInfo = UserInfo(id.value!!.toInt(), name.value!!, age.value!!.toInt())
        viewModelScope.launch(Dispatchers.IO) {
            userInfoDao.insert(userInfo)
        }
    }

    fun getUserInfo(): Flow<List<UserInfo>> {
        return userInfoDao
            .getUserInfoList()
            .flowOn(Dispatchers.IO)
    }

}
4.定義RecyclerViewAdapter
package com.aruba.flowapplyapplication.adapter

import android.view.LayoutInflater
import android.view.ViewGroup
import androidx.databinding.DataBindingUtil
import androidx.recyclerview.widget.RecyclerView
import com.aruba.flowapplyapplication.R
import com.aruba.flowapplyapplication.database.entity.UserInfo
import com.aruba.flowapplyapplication.databinding.ItemUserinfoBinding

/**
 * Created by aruba on 2021/9/20.
 */
class UserInfoAdapter() : RecyclerView.Adapter<UserInfoAdapter.MyViewHolder>() {
    private var data = ArrayList<UserInfo>()

    class MyViewHolder(val binding: ItemUserinfoBinding) : RecyclerView.ViewHolder(binding.root)

    fun setData(data: List<UserInfo>) {
        this.data.clear()
        this.data.addAll(data)
        notifyDataSetChanged()
    }

    override fun onCreateViewHolder(parent: ViewGroup, viewType: Int): MyViewHolder {
        val binding: ItemUserinfoBinding = DataBindingUtil.inflate(
            LayoutInflater.from(parent.context),
            R.layout.item_userinfo,
            parent, false
        )

        return MyViewHolder(binding)
    }

    override fun onBindViewHolder(holder: MyViewHolder, position: Int) {
        holder.binding.userInfo = data[position]
    }

    override fun getItemCount(): Int {
        return data.size
    }
}
5.Fragment中實(shí)例化ViewModel箩做,以及進(jìn)行數(shù)據(jù)綁定等操作
package com.aruba.flowapplyapplication

import android.os.Bundle
import androidx.fragment.app.Fragment
import android.view.LayoutInflater
import android.view.View
import android.view.ViewGroup
import androidx.databinding.DataBindingUtil
import androidx.lifecycle.ViewModelProvider
import androidx.lifecycle.lifecycleScope
import androidx.recyclerview.widget.LinearLayoutManager
import com.aruba.flowapplyapplication.adapter.UserInfoAdapter
import com.aruba.flowapplyapplication.database.MyDatabase
import com.aruba.flowapplyapplication.databinding.FragmentRoomBinding
import com.aruba.flowapplyapplication.viewmodel.UserInfoViewModel
import kotlinx.coroutines.flow.collect

class RoomFragment : Fragment() {

    override fun onCreateView(
        inflater: LayoutInflater, container: ViewGroup?,
        savedInstanceState: Bundle?
    ): View? {
        //初始化數(shù)據(jù)庫(kù)
        MyDatabase.init(requireContext())
        
        val inflate = DataBindingUtil.inflate<FragmentRoomBinding>(
            layoutInflater,
            R.layout.fragment_room,
            container,
            false
        )

        //實(shí)例化ViewModel
        val userInfoViewModel = ViewModelProvider(
            this,
            ViewModelProvider.AndroidViewModelFactory(requireActivity().application)
        ).get(UserInfoViewModel::class.java)
        inflate.userInfoViewModel = userInfoViewModel
        inflate.recyclerview.adapter = UserInfoAdapter()
        inflate.recyclerview.layoutManager = LinearLayoutManager(context)
        inflate.lifecycleOwner = viewLifecycleOwner

        //開(kāi)啟協(xié)程對(duì)數(shù)據(jù)庫(kù)的表進(jìn)行監(jiān)聽(tīng)
        lifecycleScope.launchWhenCreated {
            //每當(dāng)UserInfo表發(fā)生變化莽红,F(xiàn)low都會(huì)把UserInfo列表發(fā)射出去,那么我們
            //在collect中就可以獲取到
            userInfoViewModel.getUserInfo().collect {
                (inflate.recyclerview.adapter as UserInfoAdapter).setData(it)
            }
        }
        return inflate.root
    }

}
項(xiàng)目地址:https://gitee.com/aruba/flow-apply-application.git
最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
  • 序言:七十年代末邦邦,一起剝皮案震驚了整個(gè)濱河市安吁,隨后出現(xiàn)的幾起案子,更是在濱河造成了極大的恐慌燃辖,老刑警劉巖鬼店,帶你破解...
    沈念sama閱讀 219,270評(píng)論 6 508
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件,死亡現(xiàn)場(chǎng)離奇詭異黔龟,居然都是意外死亡妇智,警方通過(guò)查閱死者的電腦和手機(jī),發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 93,489評(píng)論 3 395
  • 文/潘曉璐 我一進(jìn)店門(mén)氏身,熙熙樓的掌柜王于貴愁眉苦臉地迎上來(lái)巍棱,“玉大人,你說(shuō)我怎么就攤上這事蛋欣『结悖” “怎么了?”我有些...
    開(kāi)封第一講書(shū)人閱讀 165,630評(píng)論 0 356
  • 文/不壞的土叔 我叫張陵陷虎,是天一觀的道長(zhǎng)捉偏。 經(jīng)常有香客問(wèn)我倒得,道長(zhǎng),這世上最難降的妖魔是什么夭禽? 我笑而不...
    開(kāi)封第一講書(shū)人閱讀 58,906評(píng)論 1 295
  • 正文 為了忘掉前任,我火速辦了婚禮谊路,結(jié)果婚禮上讹躯,老公的妹妹穿的比我還像新娘。我一直安慰自己缠劝,他們只是感情好潮梯,可當(dāng)我...
    茶點(diǎn)故事閱讀 67,928評(píng)論 6 392
  • 文/花漫 我一把揭開(kāi)白布。 她就那樣靜靜地躺著惨恭,像睡著了一般秉馏。 火紅的嫁衣襯著肌膚如雪。 梳的紋絲不亂的頭發(fā)上脱羡,一...
    開(kāi)封第一講書(shū)人閱讀 51,718評(píng)論 1 305
  • 那天萝究,我揣著相機(jī)與錄音,去河邊找鬼锉罐。 笑死帆竹,一個(gè)胖子當(dāng)著我的面吹牛,可吹牛的內(nèi)容都是我干的脓规。 我是一名探鬼主播栽连,決...
    沈念sama閱讀 40,442評(píng)論 3 420
  • 文/蒼蘭香墨 我猛地睜開(kāi)眼,長(zhǎng)吁一口氣:“原來(lái)是場(chǎng)噩夢(mèng)啊……” “哼侨舆!你這毒婦竟也來(lái)了秒紧?” 一聲冷哼從身側(cè)響起,我...
    開(kāi)封第一講書(shū)人閱讀 39,345評(píng)論 0 276
  • 序言:老撾萬(wàn)榮一對(duì)情侶失蹤挨下,失蹤者是張志新(化名)和其女友劉穎熔恢,沒(méi)想到半個(gè)月后,有當(dāng)?shù)厝嗽跇?shù)林里發(fā)現(xiàn)了一具尸體复颈,經(jīng)...
    沈念sama閱讀 45,802評(píng)論 1 317
  • 正文 獨(dú)居荒郊野嶺守林人離奇死亡绩聘,尸身上長(zhǎng)有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 37,984評(píng)論 3 337
  • 正文 我和宋清朗相戀三年,在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了耗啦。 大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片凿菩。...
    茶點(diǎn)故事閱讀 40,117評(píng)論 1 351
  • 序言:一個(gè)原本活蹦亂跳的男人離奇死亡,死狀恐怖帜讲,靈堂內(nèi)的尸體忽然破棺而出衅谷,到底是詐尸還是另有隱情,我是刑警寧澤似将,帶...
    沈念sama閱讀 35,810評(píng)論 5 346
  • 正文 年R本政府宣布获黔,位于F島的核電站蚀苛,受9級(jí)特大地震影響,放射性物質(zhì)發(fā)生泄漏玷氏。R本人自食惡果不足惜堵未,卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 41,462評(píng)論 3 331
  • 文/蒙蒙 一、第九天 我趴在偏房一處隱蔽的房頂上張望盏触。 院中可真熱鬧渗蟹,春花似錦、人聲如沸赞辩。這莊子的主人今日做“春日...
    開(kāi)封第一講書(shū)人閱讀 32,011評(píng)論 0 22
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽(yáng)辨嗽。三九已至世落,卻和暖如春,著一層夾襖步出監(jiān)牢的瞬間糟需,已是汗流浹背屉佳。 一陣腳步聲響...
    開(kāi)封第一講書(shū)人閱讀 33,139評(píng)論 1 272
  • 我被黑心中介騙來(lái)泰國(guó)打工, 沒(méi)想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留篮灼,地道東北人忘古。 一個(gè)月前我還...
    沈念sama閱讀 48,377評(píng)論 3 373
  • 正文 我出身青樓,卻偏偏與公主長(zhǎng)得像诅诱,于是被迫代替她去往敵國(guó)和親髓堪。 傳聞我的和親對(duì)象是個(gè)殘疾皇子,可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 45,060評(píng)論 2 355

推薦閱讀更多精彩內(nèi)容

  • 學(xué)習(xí)了kotlin后娘荡,我們將它運(yùn)用到實(shí)際開(kāi)發(fā)中干旁,結(jié)合Flow實(shí)現(xiàn)文件下載 最終效果: 項(xiàng)目使用了Navigatio...
    aruba閱讀 3,724評(píng)論 6 19
  • JetPack提供了Room數(shù)據(jù)庫(kù),和GreenDAO等開(kāi)源庫(kù)一樣炮沐,在SQLite做了封裝 Room主要使用三個(gè)注...
    aruba閱讀 1,051評(píng)論 0 6
  • Paging是一個(gè)用于分頁(yè)加載的組件争群,對(duì)于一些列表數(shù)據(jù),以前大家都使用過(guò)的一種方式是定義一個(gè)page大年,當(dāng)達(dá)到加載更...
    aruba閱讀 1,251評(píng)論 2 4
  • 1.簡(jiǎn)介 本項(xiàng)目是一個(gè)Android Kotlin框架項(xiàng)目换薄,目的是為Android原生開(kāi)發(fā)者提供一個(gè)快速開(kāi)發(fā)的框架...
    風(fēng)起于山巔閱讀 9,324評(píng)論 0 34
  • 引言 做這個(gè)起初的目的是為了學(xué)習(xí)Kotlin協(xié)程,以及JetPack中的相關(guān)組件,并且老項(xiàng)目準(zhǔn)備重構(gòu),于是打算徹徹...
    tomato_wl閱讀 4,597評(píng)論 13 12