如何从Firebase数据库高效获取单个用户关联的所有Jobs数据？

嘿，针对你这个Firebase Realtime Database获取用户关联Jobs的优化需求，我给你梳理两个实用的方案，帮你提升数据获取效率～

优化方案1：批量查询Jobs数据（减少请求次数） #

你当前的做法应该是先读取用户节点拿到所有bid-Id，再逐个去Jobs节点查询对应数据，这会产生N+1次数据库请求（1次读用户，N次读Jobs），当bid数量多的时候效率很低。

Realtime Database提供了orderByKey().in()方法，可以一次性查询多个指定key的节点，这样只需要两次请求就能搞定：

1. 先读取用户的所有bid-Id列表
2. 用in()批量查询对应的Jobs数据

注意：in()方法最多支持同时查询10个key，如果你的bid数量超过10，需要把列表拆分成多个批次分别查询，再合并结果。

代码示例：

final DatabaseReference mDatabaseJobs = FirebaseDatabase.getInstance().getReference().child("Jobs");
DatabaseReference mDatabaseUser = FirebaseDatabase.getInstance().getReference().child("Users").child(currentUser.getUid());

mDatabaseUser.addListenerForSingleValueEvent(new ValueEventListener() {
    @Override
    public void onDataChange(@NonNull DataSnapshot snapshot) {
        List<String> bidIds = new ArrayList<>();
        // 假设你的User节点下，bid-Id是作为子节点的key存储的（比如"bid-Ids": {"bid1": true, "bid2": true}）
        for (DataSnapshot bidSnapshot : snapshot.child("bid-Ids").getChildren()) {
            String bidId = bidSnapshot.getKey();
            bidIds.add(bidId);
        }

        if (!bidIds.isEmpty()) {
            // 批量查询Jobs
            mDatabaseJobs.orderByKey().in(bidIds).addListenerForSingleValueEvent(new ValueEventListener() {
                @Override
                public void onDataChange(@NonNull DataSnapshot jobsSnapshot) {
                    // 遍历拿到所有关联的Jobs数据
                    for (DataSnapshot jobSnapshot : jobsSnapshot.getChildren()) {
                        Job job = jobSnapshot.getValue(Job.class);
                        // 这里处理你的业务逻辑，比如添加到列表展示
                    }
                }

                @Override
                public void onCancelled(@NonNull DatabaseError error) {
                    Log.e("Firebase", "获取Jobs失败", error.toException());
                }
            });
        }
    }

    @Override
    public void onCancelled(@NonNull DatabaseError error) {
        Log.e("Firebase", "获取用户bid-Ids失败", error.toException());
    }
});

优化方案2：反规范化数据结构（读取一次到位） #

如果你的业务场景中，用户需要频繁获取关联的Jobs数据，或者bid数量经常超过10个，那么可以考虑反规范化数据——也就是在User节点中存储Jobs的部分或全部数据副本，这样只需要读取一次User节点就能拿到所有关联Jobs，完全避免跨节点查询。

当然，这种方案的 trade-off 是增加了写入时的复杂度：当Jobs节点的数据更新时，你需要同时更新User节点中的对应副本，保证数据一致性。可以用Firebase的批量更新来处理这个问题。

示例数据结构 #

调整后的User节点结构：

"Users": {
  "userUid1": {
    "bid-Ids": {
      "bid1": true,
      "bid2": true
    },
    "associatedJobs": {
      "bid1": {
        "title": "前端开发项目",
        "status": "pending",
        "createdAt": 1620000000
      },
      "bid2": {
        "title": "后端维护任务",
        "status": "accepted",
        "createdAt": 1620100000
      }
    }
  }
}

读取代码（一次请求搞定） #

DatabaseReference mDatabaseUser = FirebaseDatabase.getInstance().getReference().child("Users").child(currentUser.getUid());

mDatabaseUser.addListenerForSingleValueEvent(new ValueEventListener() {
    @Override
    public void onDataChange(@NonNull DataSnapshot snapshot) {
        DataSnapshot jobsSnapshot = snapshot.child("associatedJobs");
        for (DataSnapshot jobSnapshot : jobsSnapshot.getChildren()) {
            Job job = jobSnapshot.getValue(Job.class);
            // 直接处理Jobs数据
        }
    }

    @Override
    public void onCancelled(@NonNull DatabaseError error) {
        Log.e("Firebase", "获取用户关联Jobs失败", error.toException());
    }
});

批量更新保证一致性 #

当需要更新某个Job的数据时，同时更新Jobs节点和User节点中的副本：

String bidId = "xxx";
Job updatedJob = new Job("更新后的标题", "completed", System.currentTimeMillis());

Map<String, Object> updates = new HashMap<>();
updates.put("Jobs/" + bidId, updatedJob);
updates.put("Users/" + currentUser.getUid() + "/associatedJobs/" + bidId, updatedJob);

FirebaseDatabase.getInstance().getReference().updateChildren(updates)
        .addOnSuccessListener(aVoid -> {
            Log.d("Firebase", "Job数据更新成功");
        })
        .addOnFailureListener(e -> {
            Log.e("Firebase", "Job数据更新失败", e);
        });

方案选择建议 #

• 如果你的用户关联bid数量较少（≤10），且不需要频繁获取Jobs数据，优先用批量查询方案，实现简单，不需要维护数据副本。
• 如果bid数量较多，或者需要高频次读取用户关联Jobs，选择反规范化方案，用写入时的一点复杂度换取读取性能的大幅提升。

内容的提问来源于stack exchange，提问作者DsCpp