Транзакции базы данных Android Room

Как указано в документации для транзакции, вы можете сделать следующее:

 @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);
     }
 }
 

Как указывает @CommonsWare, @Query являются асинхронными, а @Insert, @Delete, @Update - синхронными.

Если вы хотите выполнить несколько запросов в одной транзакции, Room также предоставляет способ для этого, как указано ниже.

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

Надеюсь, это решит вашу проблему.

Для транзакций комнат в Котлине вы можете использовать:

• Интерфейс с реализованным методом, например:

@Dao 
interface Dao {

    @Insert 
    fun insert(item: Item)

    @Delete 
    fun delete(item: Item)

    @Transaction
    fun replace(oldItem: Item, newItem: Item){
        delete(oldItem)
        insert(newItem)
    }

}

• Или используйте функцию open, например:

@Dao 
abstract class Dao {

    @Insert 
    abstract fun insert(item: Item)

    @Delete 
    abstract fun delete(item: Item)

    @Transaction
    open fun replace(oldItem: Item, newItem: Item){
        delete(oldItem)
        insert(newItem)
    }

}

Вы получите error: Method annotated with @Transaction must not be private, final, or abstract. без модификатора open.

Я считаю, что когда мы используем интерфейсы DAO, мы все же можем выполнять транзакцию, используя методы интерфейса по умолчанию. Нам нужно добавить аннотацию @JvmDefault и @Transaction, и мы можем выполнить любую операцию внутри нее, которая принадлежит одной транзакции.

@Dao
interface TestDao {
    @Insert
    fun insert(dataObj: DataType)

    @Update
    fun update(dataObj: DataType): Completable

    @Delete
    fun delete(dataObj: DataType): Completable

    @Query("DELETE FROM $TABLE_NAME")
    fun deleteAllData()

    @Query("SELECT * FROM $TABLE_NAME ORDER BY id DESC")
    fun getAllData(): Single<List<DataType>>

    @JvmDefault
    @Transaction
    fun singleTransaction(dataList: List<DataType>) {
        deleteAllData()
        dataList.forEach {
            insert(it)
        }
    }
}

вот решение этой проблемы:

@Query("SELECT * FROM friend WHERE id = :id")
Friend getFriendByID(int id);
@Delete
void delete(Friend friend);

Friend friendToBeDeleted = friendDAO.getFriendByID(id);
friendDAO.delete(friendToBeDeleted);

Вам предстоит пройти два шага!