如何按需读取Firebase实时数据库？引用查询代码失效求助

原本全库查询代码可正常运行，但为了适配安全规则改用分引用查询后失效。核心需求：

• 先读取solal节点下partagé字段的值，获取共享用户列表
• 根据列表读取对应用户的lat（纬度）和lon（经度）
• 实现按需读取（仅主动触发时读取，而非数据变更时自动触发）

可正常运行但无法适配安全规则的代码 #

mdatabase.addValueEventListener(new ValueEventListener() {
    @Override
    public void onDataChange(DataSnapshot dataSnapshot) {
        // 初始加载及数据更新时触发
        nom = "jacque";
        String partage,pers;
        String[] partage2 ;
        ArrayList<String> accèsposition = new ArrayList<String>();
        partage = dataSnapshot.child("solal").child("partagé").getValue().toString();
        partage2 = partage.split(",");
        System.out.println(partage2);
        Log.i("2", Arrays.toString(partage2));
        for (int i = 0; i < partage2.length; i++) {
            pers = partage2[i];
            latitude = Double.parseDouble(dataSnapshot.child(pers).child("lat").getValue().toString());
            longitude = Double.parseDouble(dataSnapshot.child(pers).child("lon").getValue().toString());
            Toast.makeText(MainActivity.this,pers+latitude+longitude,Toast.LENGTH_SHORT).show();
            System.out.println(pers+latitude+longitude);
            ajouterunpoint(pers,latitude,longitude);
        }

    }

    @Override
    public void onCancelled(DatabaseError error) {
        // 读取失败
        Log.w("2", "Failed to read value.", error.toException());
    }
});  

失效的分引用查询代码 #

DatabaseReference ref2 = database.getReference("solal/partagé");
// 读取数据库
ref2.addValueEventListener(new ValueEventListener() {
    @Override
    public void onDataChange(DataSnapshot snapshot) {
        // 初始加载及数据更新时触发
        nom = "jacque";
        String partage,pers;
        ArrayList<String> accèsposition = new ArrayList<String>();
        partage = snapshot.getValue().toString();
        partage2 = partage.split(",");
        Log.i("2", Arrays.toString(partage2));
        for (int i = 0; i < partage2.length; i++) {


        DatabaseReference ref1 = FirebaseDatabase.getInstance().getReference(partage2[i]+"/"+ "lat");
        ref1.addListenerForSingleValueEvent(new ValueEventListener() {
            @Override
            public void onDataChange(DataSnapshot snapshot) {
                latitude = Double.parseDouble(snapshot.getValue().toString());
            }
            @Override
            public void onCancelled(@NonNull DatabaseError error) { }
        });

        DatabaseReference ref2 = FirebaseDatabase.getInstance().getReference(partage2[i]+"/"+"lon");
        ref2.addListenerForSingleValueEvent(new ValueEventListener() {
            @Override
            public void onDataChange(DataSnapshot snapshot) {
                longitude = Double.parseDouble(snapshot.getValue().toString());
            }
            @Override
            public void onCancelled(@NonNull DatabaseError error) { }
        });
            ajouterunpoint(partage2[i],latitude,longitude);
            Toast.makeText(MainActivity.this,partage2[i]+latitude+longitude,Toast.LENGTH_SHORT).show();
        }
                       
    }

    @Override
    public void onCancelled(DatabaseError error) {
        // 读取失败
        Log.w("2", "Failed to read value.", error.toException());
    }
});

实时数据库结构 #

问题原因与修复方案 #

核心问题 #

1. 异步回调时序错误：Firebase数据库读取是异步操作，addListenerForSingleValueEvent的onDataChange会在数据返回后执行，但你在回调外直接调用ajouterunpoint，此时latitude和longitude还未被赋值，导致使用旧值或默认值。
2. 监听类型错误：你用了addValueEventListener（实时监听数据变更），不符合“按需读取”的需求，应该全程用addListenerForSingleValueEvent。

修复后的代码 #

// 第一步：按需读取solal的partagé字段
DatabaseReference partageRef = database.getReference("solal/partagé");
partageRef.addListenerForSingleValueEvent(new ValueEventListener() {
    @Override
    public void onDataChange(DataSnapshot snapshot) {
        nom = "jacque";
        String partage = snapshot.getValue().toString();
        String[] partage2 = partage.split(",");
        Log.i("2", Arrays.toString(partage2));

        for (String userId : partage2) {
            // 第二步：按需读取该用户的lat和lon，合并为一个请求减少开销
            DatabaseReference userLocationRef = database.getReference(userId);
            userLocationRef.addListenerForSingleValueEvent(new ValueEventListener() {
                @Override
                public void onDataChange(DataSnapshot userSnapshot) {
                    // 确保字段存在再解析，避免空指针
                    if (userSnapshot.hasChild("lat") && userSnapshot.hasChild("lon")) {
                        double latitude = userSnapshot.child("lat").getValue(Double.class);
                        double longitude = userSnapshot.child("lon").getValue(Double.class);
                        // 数据获取完成后再执行后续操作
                        ajouterunpoint(userId, latitude, longitude);
                        Toast.makeText(MainActivity.this, userId + latitude + longitude, Toast.LENGTH_SHORT).show();
                    } else {
                        Log.w("2", "用户 " + userId + " 缺少位置字段");
                    }
                }

                @Override
                public void onCancelled(@NonNull DatabaseError error) {
                    Log.w("2", "读取用户 " + userId + " 位置失败", error.toException());
                }
            });
        }
    }

    @Override
    public void onCancelled(DatabaseError error) {
        Log.w("2", "读取partagé字段失败", error.toException());
    }
});

额外优化建议 #

1. 安全规则适配：确保你的安全规则允许当前用户读取solal/partagé，以及读取partagé列表中每个用户的lat和lon。示例规则（根据实际需求调整）：

{
  "rules": {
    "solal": {
      "partagé": {
        ".read": "auth != null && auth.uid == 'solal'" // 仅solal自己能读取共享列表
      }
    },
    "$userId": {
      "lat": {
        ".read": "auth != null && (auth.uid == $userId || exists(/databases/$(database)/users/solal/partagé/$userId))"
      },
      "lon": {
        ".read": "auth != null && (auth.uid == $userId || exists(/databases/$(database)/users/solal/partagé/$userId))"
      }
    }
  }
}

2. 避免多次拆分请求：直接读取用户节点而非单独读取lat和lon，减少网络请求次数，提升性能。
3. 空值判断：添加字段存在性检查，防止因数据缺失导致崩溃。

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