transakcje bazodanowe Android Pokoju

Question

Dzięki nowej bazie danych Pokój w Androidzie, Mam wymóg gdzie istnieją dwie operacje sekwencyjne, które muszą być wykonane:

removeRows(ids); 
insertRows(ids); 

Jeśli uruchomię to widzę (na rozpatrzenie db), że brakuje niektórych wierszy - zakładam, że są one usuwane po wstawieniu. mianowicie. pierwsza operacja działa równolegle do drugiej.

Jeśli używam blok transakcji, takich jak ten, to wszystko jest w porządku - pierwsza operacja wydaje się zakończyć przed wykonaniem drugiego:

roomDb.beginTransaction(); 
removeRows(ids); 
roomDb.endTransaction(); 

insertRows(ids); 

To też dobrze, jeśli daję spać w między zamiast :

removeRows(ids); 
Thread.sleep(500); 

insertRows(ids); 

nie wydaje się być dużo dokumentacji do pokoju, i zastanawiałem się, czy powinienem użyć bloku transakcji jak wyżej, kiedy mam operacji sekwencyjnych do zrobienia, czy jest jakiś lepszy sposób to.

EDIT Po @CommonsWare wskazał, @Query są asynchroniczne, a @Insert i @Delete są synchroniczne. W związku z tym, w jaki sposób uzyskać kwerendę, która usuwa wiersze być asynchroniczny:

@Query("DELETE from table WHERE id IN(:ids)") 
int removeRows(List<Long> ids); 

Według wyjściu kompilacji dostaję Deletion methods must either return void or return int (the number of deleted rows), jeśli staram się zawinąć typ zwracany w Flowable.

Answer 1

Jak zauważyli @CommonsWare, @Query są asynchroniczne, podczas gdy @Insert, @Delete, @Update są synchroniczne.

Jeśli chcesz wykonać wiele zapytań w pojedynczej transakcji, Room udostępnia również metodę, o której mowa poniżej.

roomDB.runInTransaction(new Runnable() { 
     @Override 
     public void run() { 
      removeRows(ids); 
      insertRows(ids); 
     } 
    }); 

Mam nadzieję, że rozwiąże to Twój problem.

Answer 2

jak wskazano na dokumentacji Transaction, można wykonać następujące czynności:

@Dao 
public abstract class ProductDao { 
    @Insert 
    public abstract void insert(Product product); 

    @Delete 
    public abstract void delete(Product product); 

    @Transaction 
    public void insertAndDeleteInTransaction(Product newProduct, Product oldProduct) { 
     // Anything inside this method runs in a single transaction. 
     insert(newProduct); 
     delete(oldProduct); 
    } 
}