Firebase实时数据库深层节点过滤：查询指定配送状态订单返回null

问题根源 #

你的数据结构为Orders/year/userid/orderid，shippingStatus字段存于orderid节点下。当前代码在orders/${year}节点（所有userid的父节点）执行orderByChild("shippingStatus")，Firebase会尝试在每个**直接子节点（即userid节点）**中查找shippingStatus字段，但userid节点本身并不包含该字段，因此查询返回null。

解决方法 #

方法1：调整数据结构（推荐）

将订单结构改为Orders/year/orderid，同时在每个orderid节点中保留userId字段，结构如下：

Orders
  └── 2024
      ├── order_123
      │   ├── userId: "user_abc"
      │   ├── shippingStatus: "shipped"
      │   └── ...其他订单字段
      └── order_456
          ├── userId: "user_def"
          ├── shippingStatus: "pending"
          └── ...其他订单字段

此时原查询代码即可正常工作，因为orders/${year}的直接子节点是orderid，每个orderid下都包含shippingStatus字段：

const db = getDatabase(app);
const _query = query(
  ref(db, `orders/${year}`),
  orderByChild("shippingStatus"),
  equalTo(shippingStatus)
);

get(_query)
  .then((snapshot) => {
    const result = snapshot.val();
    console.log(result);
  })

方法2：遍历用户节点逐个查询（小数据量适用）

若无法修改数据结构，可先获取指定年份下的所有用户，再遍历每个用户的订单节点执行查询：

const db = getDatabase(app);
// 获取指定年份下的所有用户ID
get(ref(db, `orders/${year}`))
  .then(userSnapshot => {
    const userIds = Object.keys(userSnapshot.val() || {});
    // 为每个用户创建订单查询Promise
    const queryPromises = userIds.map(userId => {
      const orderQuery = query(
        ref(db, `orders/${year}/${userId}`),
        orderByChild("shippingStatus"),
        equalTo(shippingStatus)
      );
      return get(orderQuery);
    });
    // 等待所有查询完成
    return Promise.all(queryPromises);
  })
  .then(orderSnapshots => {
    // 合并所有符合条件的订单
    const allMatchingOrders = {};
    orderSnapshots.forEach(snapshot => {
      const orders = snapshot.val();
      if (orders) Object.assign(allMatchingOrders, orders);
    });
    console.log(allMatchingOrders);
  })

注意：该方法会产生与用户数量对等的读操作，用户量较大时性能和成本较高，仅适合小数据场景。

方法3：使用云函数查询（大数据量适用）

针对大规模数据，推荐通过Firebase云函数在服务端执行查询，减少客户端请求次数：

// 云函数示例（Node.js）
exports.getOrdersByStatus = functions.https.onCall(async (data, context) => {
  const { year, shippingStatus } = data;
  const db = admin.database();
  const yearRef = db.ref(`orders/${year}`);
  const userSnapshots = await yearRef.once('value');
  const allOrders = [];

  await Promise.all(
    userSnapshots.forEach(userSnapshot => {
      const userId = userSnapshot.key;
      return db.ref(`orders/${year}/${userId}`)
        .orderByChild('shippingStatus')
        .equalTo(shippingStatus)
        .once('value')
        .then(orderSnapshot => {
          orderSnapshot.forEach(order => {
            allOrders.push({
              userId,
              orderId: order.key,
              ...order.val()
            });
          });
        });
    })
  );

  return allOrders;
});

客户端调用该云函数即可获取所有符合条件的订单，将复杂逻辑放在服务端优化性能。

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