如何在android room和rxjava 2中插入数据并获取id作为out参数？

Question

插入查询

@Insert(onConflict = OnConflictStrategy.REPLACE)
long insertProduct(Product product);   //product id is auto generated 

查看模型

public Completable insertProduct(final String productName) {
    return new CompletableFromAction(() -> {
        Product newProduct = new Product();
        newProduct.setProductName(productName);
        mProductDataSource.insertOrUpdateProduct(newProduct);
    });
}

在我调用上述函数的活动中，我使用了CompositeDisposable。

CompositeDisposable mDisposable = new CompositeDisposable();

 mDisposable.add(mViewModel.insertProduct(productName))
      .subscribeOn(Schedulers.io())
      .observeOn(AndroidSchedulers.mainThread())
      .subscribe(() ->{} ,throwable -> Log.e(TAG, "Error msg", throwable))); 

我实施的方式不对吗？

Answer 1

根据文件。如果@Insert方法只接收到1个参数，它可以返回long，这是插入项的新rowId。如果参数是数组或集合，则应返回long[]或List。由于只插入一项，因此该方法将只返回一个rowID。

那么，试试这个

Single.fromCallable(new Callable<Long>() {
        @Override
        public Long call() throws Exception {
           return productDao.insertProduct(new Product()));
        }
    })
    .subscribe(id -> {

    } ,throwable -> Log.e(TAG, "Error msg", throwable)))

您可以使用可观察的或可能的。但我认为单条更合适，因为在您的情况下，id是自动生成的，插入应该始终完成。