房间更新（或插入，如果不存在）行，并返回计数已更改的行

Question

我需要更新，如果不存在插入行到ROOM DB。

我这样做：productRepository。updateProducts（productsResponse.getProductItems（））

和：

@Override
public void updateProducts(final List<ProductItem> products) {
    new Thread(() -> {
        for (ProductItem item : products) {
            Product product = createProduct(item);
            productDao.insert(product);
        }
    }).start();
}

在道中：

@Insert
void insert(Product products);

但我有办法

@Update
void update(Product product);

我有一些问题：

>

这两种方法都是无效的。如何在插入后返回保存的产品或布尔标志或插入计数？

如何更新（如果没有-插入）行并返回count updatet或插入的行？




Answer 1

您可以检查您的数据库是否已经有特定字段的项目，例如：

@Query("SELECT id FROM items WHERE id = :id LIMIT 1")
fun getItemId(id: String): String?

@Insert
fun insert(item: Item): Long

@Update(onConflict = OnConflictStrategy.REPLACE)
fun update(item: Item): Int

项是您的对象，在您的代码中：

 fun insertOrUpdate(item: Item) {
            database.runInTransaction {
                val id = getItemDao().getItemId(item.id)

                if(id == null)
                    getItemDao().insert(item)
                else
                    getItemDao().update(item)
            }
        }

Answer 2

正如@Danail Alexiev所说的@Inert可以返回long。@Update可以返回int。

但你使用更新的目的是什么？如果您只想用新对象替换整个对象，那么只需指定OnConflictStrategy

@Insert(onConflict = OnConflictStrategy.REPLACE)
void insert(Product products);

结果将是：不存在的项目将被添加，已经存在的项目将被新项目替换。

如果你只需要更新一个参数（比如数量），你可以这样做

  @Insert(onConflict = OnConflictStrategy.REPLACE)
  void insert(Product products);

  @Query("SELECT * from item WHERE id= :id")
  List<Product> getItemById(int id);

  @Query("UPDATE item SET quantity = quantity + 1 WHERE id = :id")
  void updateQuantity(int id)

  void insertOrUpdate(Product item) {
                List<Product> itemsFromDB = getItemById(item.getId())
                if (itemsFromDB.isEmpty())
                    insert(item)
                else
                    updateQuantity(item.getId())   
            }
        }

结果将是：尝试在数据库中查找该项，如果找到，则更新属性，如果不只是插入新项。因此，您只需要从DAO调用一个方法insertOrUpdate。

Answer 3

>

update将尝试使用where子句中主键的值更新所有字段。如果您的实体尚未在数据库中持久化，则更新查询将无法找到行，并且不会更新任何内容。

您可以使用@Insert（onConflict=OnConflictStrategy.REPLACE）。这将尝试插入实体，如果存在具有相同ID值的现有行，它将删除该行，并将其替换为您尝试插入的实体。请注意，如果使用的是自动生成的ID，这意味着生成的行的ID将与替换的原始行的ID不同。如果你想保留这个ID，那么你必须想出一个定制的方法。