Zapisz asynchroniczne zapytania DAO

Aby zapobiec blokowaniu interfejsu przez zapytania, sala nie zezwala na dostęp do bazy danych w wątku głównym. To ograniczenie oznacza, że musisz skonfigurować DAO asynchroniczne. Pokój udostępnia integrację z kilkoma różnymi platformami, asynchroniczne wykonywanie zapytań.

Zapytania dotyczące DAO dzielą się na 3 kategorie:

• Zapytania zapisu jednorazowego, które wstawiają, aktualizują lub usuwają dane w bazie danych.
• zapytania jednorazowe odczytu, które odczytują dane z bazy danych tylko raz i zwracają je ze zrzutem bazy danych w danym momencie.
• Dostrzegalne zapytania odczytu, które odczytują dane z bazy danych za każdym razem, gdy bazowe tabele bazy danych zmieniają się i generują nowe wartości, aby je odzwierciedlić zmian.

Opcje języka i platformy

Sala umożliwia integrację w zakresie interoperacyjności w określonym języku funkcje i biblioteki. W tabeli poniżej znajdziesz odpowiednie typy zwrotów na podstawie o typie i strukturze zapytania:

Ten przewodnik pokazuje 3 sposoby wykorzystania tych integracji aby wdrożyć asynchroniczne zapytania w DAO.

Kotlin z przepływu i courutyny

Kotlin udostępnia funkcje językowe, które umożliwiają pisanie zapytań asynchronicznych bez korzystania z platform zewnętrznych:

• W pokoju 2.2 lub nowszym możesz korzystać z funkcji Flow do pisania obserwowalnych zapytań.
• W pokoju 2.1 i nowszych możesz użyć słowa kluczowego suspend, aby skonfigurować DAO asynchronicznych zapytań za pomocą współrzędnych Kotlin.

Java z RxJava

Jeśli Twoja aplikacja korzysta z języka programowania Java, możesz użyć specjalnego zwrotu ze platformy RxJava do pisania asynchronicznych metod DAO. Wyposażenie pokoju obsługa następujących typów zwracanych RxJava 2:

• W przypadku zapytań jednorazowych pokój 2.1 lub nowszy obsługuje Completable Single<T>, i Maybe<T> zwracanych typów.
• W przypadku zapytań dostrzegalnych funkcja Sala obsługuje Publisher<T> Flowable<T>, i Observable<T> zwracanych typów.

Dodatkowo Room 2.3 i nowsze wersje obsługują RxJava 3.

Java z LiveData i Guavą

Jeśli Twoja aplikacja korzysta z języka Java i nie chcesz używać modułu środowiska RxJava, możesz użyć następujących alternatywnych rozwiązań do zapisu asynchronicznego zapytania:

• Możesz użyć opakowania LiveData z Jetpack do pisania asynchronicznych zapytań dostrzegalnych.
• Za pomocą ListenableFuture<T> opracowaną przez firmę Guava do pisania asynchronicznych zapytań jednorazowych.

Twórz asynchroniczne zapytania jednorazowe

Zapytania jednorazowe to operacje na bazie danych, które są uruchamiane tylko raz i umożliwiają pobranie zrzutu danych w momencie uruchomienia. Oto kilka przykładów użycia asynchronicznego zapytania jednorazowe:

@Dao
interface UserDao {
    @Insert(onConflict = OnConflictStrategy.REPLACE)
    suspend fun insertUsers(vararg users: User)

    @Update
    suspend fun updateUsers(vararg users: User)

    @Delete
    suspend fun deleteUsers(vararg users: User)

    @Query("SELECT * FROM user WHERE id = :id")
    suspend fun loadUserById(id: Int): User

    @Query("SELECT * from user WHERE region IN (:regions)")
    suspend fun loadUsersByRegion(regions: List<String>): List<User>
}

@Dao
public interface UserDao {
    @Insert(onConflict = OnConflictStrategy.REPLACE)
    public Completable insertUsers(List<User> users);

    @Update
    public Completable updateUsers(List<User> users);

    @Delete
    public Completable deleteUsers(List<User> users);

    @Query("SELECT * FROM user WHERE id = :id")
    public Single<User> loadUserById(int id);

    @Query("SELECT * from user WHERE region IN (:regions)")
    public Single<List<User>> loadUsersByRegion(List<String> regions);
}

@Dao
public interface UserDao {
    // Returns the number of users inserted.
    @Insert(onConflict = OnConflictStrategy.REPLACE)
    public ListenableFuture<Integer> insertUsers(List<User> users);

    // Returns the number of users updated.
    @Update
    public ListenableFuture<Integer> updateUsers(List<User> users);

    // Returns the number of users deleted.
    @Delete
    public ListenableFuture<Integer> deleteUsers(List<User> users);

    @Query("SELECT * FROM user WHERE id = :id")
    public ListenableFuture<User> loadUserById(int id);

    @Query("SELECT * from user WHERE region IN (:regions)")
    public ListenableFuture<List<User>> loadUsersByRegion(List<String> regions);
}

Napisz obserwowalne zapytania

Obserwowalne zapytania to operacje odczytu, które generują nowe wartości, gdy zmiany w tabelach, do których odwołuje się zapytanie. Jednym ze sposobów Pomaga to aktualizować wyświetlaną listę elementów, w bazowej bazie danych zostały wstawione, zaktualizowane lub usunięte. Oto kilka przykłady dostrzegalnych zapytań:

@Dao
interface UserDao {
    @Query("SELECT * FROM user WHERE id = :id")
    fun loadUserById(id: Int): Flow<User>

    @Query("SELECT * from user WHERE region IN (:regions)")
    fun loadUsersByRegion(regions: List<String>): Flow<List<User>>
}

@Dao
public interface UserDao {
    @Query("SELECT * FROM user WHERE id = :id")
    public Flowable<User> loadUserById(int id);

    @Query("SELECT * from user WHERE region IN (:regions)")
    public Flowable<List<User>> loadUsersByRegion(List<String> regions);
}

@Dao
public interface UserDao {
    @Query("SELECT * FROM user WHERE id = :id")
    public LiveData<User> loadUserById(int id);

    @Query("SELECT * from user WHERE region IN (:regions)")
    public LiveData<List<User>> loadUsersByRegion(List<String> regions);
}

Dodatkowe materiały

Więcej informacji o asynchronicznych zapytaniach DAO znajdziesz w tych dodatkowych zasoby:

Próbki

• Sala Przykład RxJava (Java) (Kotlin)

Blogi

• Pokoje Proces