使用react-redux-firebase查询Firebase二级节点指定code的购买记录

首先得指出你的数据结构在查询时的小局限：Firebase Realtime Database的orderByChild是针对当前节点的直接子节点字段生效的，而你的code字段嵌套在purchase/{userId}/{purchaseId}层级下，所以直接在purchase根节点查code是不会得到结果的。下面给你两种可行方案，你可以根据用户体量来选择：

方案一：基于现有结构查询（适合用户量不大的场景） #

这种方案需要先遍历所有用户节点，再逐个查询每个用户下符合条件的购买记录。用react-redux-firebase的useFirebase hook实现的话，代码如下：

import { useState, useEffect } from 'react';
import { useFirebase } from 'react-redux-firebase';

const MatchingPurchases = () => {
  const firebase = useFirebase();
  const [matchingPurchases, setMatchingPurchases] = useState([]);

  useEffect(() => {
    const fetchMatches = async () => {
      const purchaseRootRef = firebase.database().ref('purchase');
      const usersSnapshot = await purchaseRootRef.once('value');
      let results = [];

      // 遍历每个用户的购买记录节点
      usersSnapshot.forEach(userSnap => {
        const userId = userSnap.key;
        // 查询该用户下code为'3XB1'的购买记录
        userSnap.ref.orderByChild('code').equalTo('3XB1').once('value')
          .then(purchaseSnap => {
            purchaseSnap.forEach(itemSnap => {
              results.push({
                userId,
                purchaseId: itemSnap.key,
                ...itemSnap.val()
              });
            });
            setMatchingPurchases([...results]);
          });
      });
    };

    fetchMatches();
  }, [firebase]);

  return (
    <div>
      {matchingPurchases.map(purchase => (
        <div key={purchase.purchaseId}>
          用户ID: {purchase.userId} | 价格: {purchase.price} | 码: {purchase.code}
        </div>
      ))}
    </div>
  );
};

export default MatchingPurchases;

⚠️ 注意事项：

• 必须在Firebase控制台的数据库规则中给每个用户的购买节点添加索引，否则查询会很慢甚至被Firebase限制：

{
  "rules": {
    "purchase": {
      "$userId": {
        ".indexOn": "code"
      }
    }
  }
}

• 如果平台用户数量较多，这种方案会产生大量请求，性能表现不佳，建议优先考虑下面的优化方案。

方案二：优化数据结构（推荐，适合大用户量场景） #

Firebase官方推荐扁平化数据结构，我们可以额外维护一个codeIndex节点，用来映射code值到对应的购买记录，这样查询会非常高效。

第一步：写入数据时同步更新索引 #

当创建新的购买记录时，同时写入主数据和索引节点，确保数据一致性：

import { useFirebase } from 'react-redux-firebase';

const addPurchase = (userId, purchaseData) => {
  const firebase = useFirebase();
  // 生成唯一的purchaseId
  const purchaseRef = firebase.database().ref(`purchase/${userId}`).push();
  const purchaseId = purchaseRef.key;

  // 写入主购买记录
  purchaseRef.set(purchaseData);

  // 写入code索引，方便后续快速查询
  firebase.database().ref(`codeIndex/${purchaseData.code}/${purchaseId}`).set({
    userId,
    price: purchaseData.price
  });
};

第二步：用react-redux-firebase查询索引节点 #

借助useFirebaseConnect可以把数据自动同步到Redux store中，实现实时更新，代码示例：

import { useFirebaseConnect } from 'react-redux-firebase';
import { useSelector } from 'react-redux';

const MatchingPurchases = () => {
  // 同步code为'3XB1'的购买记录到Redux
  useFirebaseConnect([
    {
      path: 'codeIndex/3XB1',
      storeAs: 'matchingPurchases' // 自定义Redux中的存储键名
    }
  ]);

  // 从Redux中获取数据
  const purchasesData = useSelector(state => state.firebase.data.matchingPurchases || {});
  // 转换为数组以便渲染
  const matchingPurchases = Object.keys(purchasesData).map(purchaseId => ({
    purchaseId,
    ...purchasesData[purchaseId]
  }));

  return (
    <div>
      {matchingPurchases.map(purchase => (
        <div key={purchase.purchaseId}>
          用户ID: {purchase.userId} | 价格: {purchase.price} | 码: 3XB1
        </div>
      ))}
    </div>
  );
};

export default MatchingPurchases;

⚠️ 注意事项：

• 需要在Firebase规则中给codeIndex设置合适的读写权限，根据你的业务需求调整：

{
  "rules": {
    "codeIndex": {
      "$code": {
        ".read": true,
        ".write": true
      }
    }
  }
}

• 这种方案是实时同步的，如果购买记录有更新，Redux中的数据会自动刷新，非常适合生产环境使用。

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