[ Room #2 ] Components Room

 

 

  

    
    
    
    
  
import androidx.room.Entity
import androidx.room.PrimaryKey
import com.google.gson.annotations.SerializedName

@Entity
data class Person(
    @PrimaryKey
    @SerializedName("name") val name: String,
    @SerializedName("age") val age: Int,
    @SerializedName("address") val address: String
)

• PrimaryKey 설정 가능.
• @PrimaryKey(autoGenerate = true) : 변수가 Int 형 일 경우 자동 생성 가능.

  

    
    
    
    
  
import androidx.room.*
import com.example.roomrecyclerviewexample.Person
import io.reactivex.Flowable

@Dao
interface PersonDAO {
    @Query("SELECT * FROM person")
    fun getAllPerson(): Flowable<List<Person>>

    @Insert(onConflict = OnConflictStrategy.REPLACE)
    fun insert(vararg person: Person)

    @Update
    fun update(vararg person: Person)

    @Delete
    fun delete(vararg person: Person)
}

• Query 로 직접 쿼리 작성 가능.
• Insert시, PrimaryKey 가 적용 되어 있어 같은 이름이 있을 경우 덮어 쓰기 가능. 
• Rx 연동가능.
• Observing 처리 하여 데이터가 변결 될 때마다 호출이 가능 하게 적용 가능.

  

    
    
    
    
  
import android.content.Context
import androidx.room.Database
import androidx.room.Room
import androidx.room.RoomDatabase
import com.example.roomrecyclerviewexample.Person

@Database(entities = arrayOf(Person::class), version = 1)
abstract class PersonDatabase: RoomDatabase() {
    abstract fun getPersonDao(): PersonDAO

    companion object {
        private var INSTANCE: PersonDatabase? = null
        fun getInstance(context: Context): PersonDatabase? {

            if(INSTANCE == null) {
                synchronized(PersonDatabase::class) {
                    INSTANCE = Room.databaseBuilder(context, PersonDatabase::class.java, "person.db").build()
                }
            }
            return INSTANCE
        }
    }
}

person.db 라는 테이블 명을 만듦.

 

  

    
    
    
    
  
@Database(entities = arrayOf(Person::class), version = 1)
abstract class AppDatabase: RoomDatabase() {
    abstract fun personDao(): PersonDAO
}

entity, version, schema export option등을 정의 ( DB와의 접근 클래스 느낌 ? )

 

 

사용 방법 

  

    
    
    
    
  
PersonDatabase.getInstance(this)
  ?.getPersonDao()
  ?.getAllPerson()
  ?.observeOn(AndroidSchedulers.mainThread())	// UI Thread 에서 사용 ! [중요]
  ?.subscribe({
    Log.d("MyTag", Gson().toJson(it))	// 성공 시 
    },{
    Log.e("MyTag", it.message.toString())	// 실패 시
    })

  

    
    
    
    
  
PersonDatabase.getInstance(this)
  ?.getPersonDao()
  ?.insert(person)	// ?.delete(person)

Sample Example Github