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

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

在 DAO 中：

@Insert
void insert(Product products);

但我有方法

@Update
void update(Product product);

还有一些问题：

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

2. 如果我尝试调用update，但我没有行，是否会插入？

3. 如何更新（如果不是 - 插入）行并返回计数更新或插入的行？

Answer 1

1. 用@Insert 注释的方法可以返回long。这是为插入的行新生成的 ID。使用@Update 注释的方法可以返回int。这是更新的行数。

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

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

Answer 2

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

@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

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

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

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

Answer 3

您应该使用 Rx Android Single 来解决这个问题。示例：

@Query("SELECT * FROM subjectFormTable WHERE study_subject_id ==:subjectFormId")
fun getSubjectForm(subjectFormId: Int): Single<SubjectFormEntity>

我们使用

val compositeDisposable = CompositeDisposable()

和

compositeDisposable.add(
            subjectFormDao.getSubjectForm(studySubjectId)
            .subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe({
                Log.e(TAG, "successful ")
            }, {
                Log.e(TAG, "error "+it.message)
                //Insert or Update data here
            })
    )

Answer 4

您可以查看下面的方法 insertModel()，您可以在其中获取 onComplete() 和 onError() 方法：

    val db: AppDatabase = Room.databaseBuilder(mCtx, AppDatabase::class.java, "db_nam.sqlite").build()

    companion object {
        @SuppressLint("StaticFieldLeak")
        private var mInstance: DatabaseClient? = null

        @Synchronized
        fun getInstance(mCtx: Context): DatabaseClient {
            if (mInstance == null) {
                mInstance = DatabaseClient(mCtx)
            }
            return mInstance as DatabaseClient
        }
    }

    // SEE HERE FOR INSERTING DATA SUCCESSFULLY AND ERROR CODE  
    private fun insertModel(rss_Model: RSS_Model) {
        Completable.fromAction {

            db.database_dao().insertRSS(rss_Model)

        }.observeOn(AndroidSchedulers.mainThread())
                .subscribeOn(Schedulers.io()).subscribe(object : CompletableObserver {
                    override fun onSubscribe(d: Disposable) {}

                    override fun onComplete() {
                        // Log.e("onComplete","GET SUCCESS HERE")
                    }

                    override fun onError(e: Throwable) {
                        // Log.e("onError","onError")
                    }
                })
    }

Answer 5

正如@Danail Alexiev 所说，@Insert 可以返回一个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 6

您还可以检查该条目是否存在于数据库中，您可以相应地制定您的逻辑

科特林

@Query("SELECT * FROM Product WHERE productId == :id")
fun isProductExist(id: Int): Boolean

Java

@Query("SELECT * FROM Product WHERE productId == :id")
public boolean isExist(int id);