Flutter从Firestore嵌套子集合获取文档数量的问题

1. 这种查询是否可行？ #

可行，但你当前的代码逻辑存在核心错误——调用.doc()会生成一个不存在的随机学生文档ID，而非指向已创建的学生文档，导致查询的是一个空的子集合，自然无法得到正确计数。要获取所有学生下子集合的总文档数，需要遍历已存在的学生文档统计对应子集合，或通过聚合查询、预存计数器的方式实现。

2. 性能和费用方面是否值得？ #

不同实现方式的性能与成本差异明显：

• 直接遍历学生文档+全量查询子集合：若学生数量较多（几百/上千级），会产生学生数×3次全文档读操作，费用高且查询耗时随学生数线性增长，不推荐。
• 使用Firestore聚合查询（count()）：同样遍历学生文档，但聚合查询仅获取计数，无需加载全量文档，单条聚合查询按1次读操作计费，性能和成本远优于全量读取，适合中等规模数据。
• 预存计数器：在添加/删除子集合文档时实时更新计数（存储在user或student文档的字段中），查询时直接读取计数值，仅需1次读操作，性能和成本最优，是生产环境首选方案。

3. 正确的实现方式 #

错误代码分析 #

你的fetchLengthOfAllRecords函数中，.doc()生成了全新的随机文档ID，而非指向已存在的学生文档，导致查询的子集合不存在，返回size为0。

方案1：遍历学生文档统计（适合小规模数据） #

先获取所有学生文档，再逐个查询其子集合的文档数并累加：

// 获取所有学生下指定子集合的总文档数
Future<int> fetchTotalSubcollectionCount(String subcollectionPath) async {
  // 先获取当前用户下的所有学生文档
  QuerySnapshot studentsSnapshot = await firestore
      .collection(FC.pathUserCollection)
      .doc(firebaseAuth.currentUser!.uid)
      .collection(FC.pathStudentCollection)
      .get();
  
  int totalCount = 0;
  // 遍历每个学生文档，查询对应子集合
  for (var studentDoc in studentsSnapshot.docs) {
    QuerySnapshot subSnapshot = await studentDoc.reference.collection(subcollectionPath).get();
    totalCount += subSnapshot.size;
  }
  return totalCount;
}

方案2：使用Firestore聚合查询（更高效） #

利用Firestore的count()聚合函数，无需加载全量文档，仅获取计数：

import 'package:cloud_firestore/cloud_firestore.dart';

Future<int> fetchTotalSubcollectionCount(String subcollectionPath) async {
  QuerySnapshot studentsSnapshot = await firestore
      .collection(FC.pathUserCollection)
      .doc(firebaseAuth.currentUser!.uid)
      .collection(FC.pathStudentCollection)
      .get();
  
  int totalCount = 0;
  for (var studentDoc in studentsSnapshot.docs) {
    // 调用count()聚合查询获取子集合计数
    AggregateQuerySnapshot countSnapshot = await studentDoc.reference
        .collection(subcollectionPath)
        .count()
        .get();
    totalCount += countSnapshot.count;
  }
  return totalCount;
}

方案3：预存计数器（生产环境最优） #

在添加/删除子集合文档时，通过事务实时更新对应计数字段，避免后续查询的额外开销：

1. 添加文档时更新计数器：

// 向指定学生的revisionCollection添加文档，并更新计数器
Future<void> addRevisionDocument(String studentId, Map<String, dynamic> data) async {
  DocumentReference studentRef = firestore
      .collection(FC.pathUserCollection)
      .doc(firebaseAuth.currentUser!.uid)
      .collection(FC.pathStudentCollection)
      .doc(studentId);
  
  // 用事务保证计数准确性
  await firestore.runTransaction((transaction) async {
    // 添加子集合文档
    await transaction.set(
      studentRef.collection(FC.pathMurajaatRDCollection).doc(),
      data,
    );
    // 更新学生文档中的子集合计数
    DocumentSnapshot studentDoc = await transaction.get(studentRef);
    int currentCount = studentDoc.data()?['revisionCount'] ?? 0;
    transaction.update(studentRef, {'revisionCount': currentCount + 1});
    // 可选：更新用户文档中的总计数
    DocumentReference userRef = firestore.collection(FC.pathUserCollection).doc(firebaseAuth.currentUser!.uid);
    DocumentSnapshot userDoc = await transaction.get(userRef);
    int totalRevisionCount = userDoc.data()?['totalRevisionCount'] ?? 0;
    transaction.update(userRef, {'totalRevisionCount': totalRevisionCount + 1});
  });
}

2. 查询时直接读取计数器：

Future<int> fetchTotalRevisionCount() async {
  DocumentSnapshot userDoc = await firestore
      .collection(FC.pathUserCollection)
      .doc(firebaseAuth.currentUser!.uid)
      .get();
  return userDoc.data()?['totalRevisionCount'] ?? 0;
}

修改BlocCubit逻辑 #

若使用方案1或2，修改后的fetchRecordsLength如下：

Future<void> fetchRecordsLength() async {
  emit(FetchRecordsLengthState.loading());
  try {
    int studentLength = await firestoreRepository.fetchLengthOfStudentRecords();
    int murajaatLength = await firestoreRepository.fetchTotalSubcollectionCount(FC.pathMurajaatRDCollection);
    int juzHaliLength = await firestoreRepository.fetchTotalSubcollectionCount(FC.pathJuzHaaliRDCollection);
    int jadeedLength = await firestoreRepository.fetchTotalSubcollectionCount(FC.pathJadeedRDCollection);
    
    emit(FetchRecordsLengthState.success(
      student: studentLength,
      murajaat: murajaatLength,
      juzHaali: juzHaliLength,
      jadeed: jadeedLength,
    ));
    print('student length: $studentLength');
    print('murajaat length: $murajaatLength');
    print('juzHaali length: $juzHaliLength');
    print('jadeed length: $jadeedLength');
  } catch (e) {
    if (kDebugMode) {
      print('fetch records length failure $e');
    }
    emit(FetchRecordsLengthState.failure());
  }
}

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