如何检查firestore中是否已经存在某些数据

Question

在将新数据添加到 Firestore 之前，我想检查数据库中是否存在相同类型的数据。如果已经存在数据意味着我想防止用户在数据库中输入重复数据。在我的情况下，如果已经存在同一时间的预订，它就像预约预订，我想防止用户在同一时间预订。我尝试使用查询功能，但它不能防止重复数据输入。请帮助我

private boolean alreadyBooked(final String boname, final String bodept, final String botime) {
        final int[] flag = {0};
        CollectionReference cref=db.collection("bookingdetails");
        Query q1=cref.whereEqualTo("time",botime).whereEqualTo("dept",bodept);
        q1.get().addOnSuccessListener(new OnSuccessListener<QuerySnapshot>() {
            @Override
            public void onSuccess(QuerySnapshot queryDocumentSnapshots) {
                for (DocumentSnapshot ds : queryDocumentSnapshots) {
                    String rname, rdept, rtime;
                    rname = ds.getString("name");
                    rdept = ds.getString("dept");
                    rtime = ds.getString("time");
                    if (rdept.equals(botime)) {
                        if (rtime.equals(botime)) {
                            flag[0] = 1;
                            return;
                        }
                    }
                }
            }
        });
        if(flag[0]==1){
            return true;
        }
        else {
            return false;
        }
    }

Answer 1

从 Cloud Firestore 加载数据是异步发生的。当您从 中返回时alreadyBooked，数据尚未加载，onSuccess尚未运行，并且flag仍具有默认值。

查看此内容的最简单方法是使用一些日志语句：

private boolean alreadyBooked(final String boname, final String bodept, final String botime) {
    CollectionReference cref=db.collection("bookingdetails");
    Query q1=cref.whereEqualTo("time",botime).whereEqualTo("dept",bodept);
    System.out.println("Starting listener");
    q1.get().addOnSuccessListener(new OnSuccessListener<QuerySnapshot>() {
        @Override
        public void onSuccess(QuerySnapshot queryDocumentSnapshots) {
            System.out.println("Got data from Firestore");
        }
    });
    System.out.println("Returning");
}

如果运行此代码，它将打印：

启动监听器

返回

从 Firestore 获取数据

这可能不是您期望的顺序。但这完美地解释了为什么您false在调用时总是会收到alreadyBooked：数据根本没有及时从 Firestore 返回。

解决这个问题的方法是改变你思考问题的方式。您当前的代码具有逻辑：“首先检查是否已预订，然后添加新项目”。我们需要将其重新定义为：“开始检查是否已被预订。一旦我们知道尚未预订，请添加新项目。” 在代码中，这意味着需要来自 Firestore 的数据的所有代码都必须位于 内部onSuccess或必须从那里调用。

最简单的版本是将代码移至 onSuccess：

private void alreadyBooked(final String boname, final String bodept, final String botime) {
    CollectionReference cref=db.collection("bookingdetails");
    Query q1=cref.whereEqualTo("time",botime).whereEqualTo("dept",bodept);
    q1.get().addOnSuccessListener(new OnSuccessListener<QuerySnapshot>() {
        @Override
        public void onSuccess(QuerySnapshot queryDocumentSnapshots) {
            boolean isExisting = false
            for (DocumentSnapshot ds : queryDocumentSnapshots) {
                String rname, rdept, rtime;
                rname = ds.getString("name");
                rdept = ds.getString("dept");
                rtime = ds.getString("time");
                if (rdept.equals(botime)) {
                    if (rtime.equals(botime)) {
                        isExisting = true;
                    }
                }
            }
            if (!isExisting) {
                // TODO: add item to Firestore
            }
        }
    });
}

虽然这很简单，但它的可alreadyBooked重用性较差，因为现在它也包含插入新项目的代码。您可以通过定义自己的回调接口来解决这个问题：

public interface AlreadyBookedCallback {
  void onCallback(boolean isAlreadyBooked);
}

private void alreadyBooked(final String boname, final String bodept, final String botime, AlreadyBookedCallback callback) {
    CollectionReference cref=db.collection("bookingdetails");
    Query q1=cref.whereEqualTo("time",botime).whereEqualTo("dept",bodept);
    q1.get().addOnSuccessListener(new OnSuccessListener<QuerySnapshot>() {
        @Override
        public void onSuccess(QuerySnapshot queryDocumentSnapshots) {
            for (DocumentSnapshot ds : queryDocumentSnapshots) {
                String rname, rdept, rtime;
                rname = ds.getString("name");
                rdept = ds.getString("dept");
                rtime = ds.getString("time");
                if (rdept.equals(botime)) {
                    if (rtime.equals(botime)) {
                        isExisting = true;
                    }
                }
            }
            callback.onCallback(isExisting)
        }
    });
}

然后你将其称为：

alreadyBooked(boname, bodept, botime, new AlreadyBookedCallback() {
  @Override
  public void onCallback(boolean isAlreadyBooked) {
    // TODO: insert item
  }
});

另请参阅（其中许多适用于 Firebase 实时数据库，其中应用相同的逻辑）：

• getContactsFromFirebase() 方法返回一个空列表
• Doug 关于异步回调的博客文章
• 在 Firebase Listener 中设置 Singleton 属性值
• Android + Firebase：将同步 for 转换为异步函数
• 是否可以从 Firebase 同步加载数据？
• 从 firebase 查询数据