检查数据库中是否已插入ROOM和RXJava项

Question

我是一个拥有ROOM,RXJava和Android的新手。

在Android应用程序测试中，REST服务检索用户列表。如果用户已经存在，则必须修改此列表。如果该用户不存在，则将该用户插入到数据库中。如果用户已经存在，则不插入该用户。

在活动中的验证如下：

UserRepository repo = new UserRepository(LoadingActivity.this);

    for (int i = 0; i < list.size(); i++){
                            
         if (!repo.existsUser(list.get(i))){
               repo.insert(list.get(i));
          }
    }

Iserdao consiste en lo Siguiente：

@Query("select count(*) from users where name = :userName and email = :userEmail")
Single<Long> existsUser(int userName , String userEmail);

El UserRepository contiene lo siguiente：

private AppDatabase db;

public UserRepository(Context context){
    this.db  = AppDatabase.getDatabase(context);
}

public boolean existsUser(User item){

    final boolean[] existe = {false};

    db.userDao().existsUser(item.getName(), item.getEmail())
            .subscribeOn(Schedulers.io())
            .subscribe(query -> existe[0] = query > 0);

    return existe[0];
}

public void insert(User user){
    db.userDao().insert(user)
            .subscribeOn(Schedulers.computation())
            .subscribe(new CompletableObserver() {
                @Override
                public void onSubscribe(Disposable d) {

                }

                @Override
                public void onComplete() {

                }

                @Override
                public void onError(Throwable e) {

                }
            });
}

Answer 1

您的代码有很多不同类型的问题。

首先，您应该理解使用活动的上下文来创建数据库--这是一个非常糟糕的主意。您应该改用应用程序上下文。

此外，您还尝试在此处使用命令式编程风格和反应式编程：

if (!repo.existsUser(list.get(i))){
    repo.insert(list.get(i));
}

我认为在你问一些关于它的问题之前，你需要对反应编程和room框架进行更深入的研究。

至于你的问题--你应该避免没有主键的db实体。在这里您应该做的唯一一件事来解决您的问题--使用@insert(onConflict=onconflictStrategy.Ignore)和您的insert fun的签名应该是类似于Kotlin中的fun insertIfNotExists（User：User）：completable或completable insertIfNotExists（User User）（如果您使用Java