AngularFire2+Firestore+Angular5/6嵌套查询：如何根据子文档内容获取父文档？

当然可行！不过得先明确Firestore的一个核心特性：它不支持跨集合的深度关联查询，没法直接写一个语句遍历所有rooms下的messages子集合并匹配字段。不过我们有两种实用的方案来实现你的需求，下面分别说明：

方案一：反规范化数据结构（推荐） #

这是Firestore官方推荐的设计思路——通过冗余数据来简化查询。具体来说，我们可以在每个message文档里添加一个roomId字段，用来记录它所属的聊天室ID。这样就能分两步完成查询：

1. 先找到所有包含目标消息的message文档，提取对应的roomId
2. 根据roomId查询rooms集合，拿到聊天室的名称

AngularFire代码示例 #

import { AngularFirestore } from '@angular/fire/compat/firestore';
import { Observable } from 'rxjs';
import { mergeMap, toArray } from 'rxjs/operators';

constructor(private afs: AngularFirestore) {}

searchMessageAndGetRooms(msgContent: string): Observable<any[]> {
  // 第一步：查询所有名为messages的子集合中匹配的消息
  return this.afs.collectionGroup('messages', ref => 
    ref.where('msg', '==', msgContent)
  ).snapshotChanges().pipe(
    // 提取唯一的roomId，避免重复查询
    mergeMap(messages => {
      const uniqueRoomIds = [...new Set(messages.map(msg => msg.payload.doc.data().roomId))];
      // 第二步：批量查询对应的聊天室文档
      const roomObservables = uniqueRoomIds.map(roomId => 
        this.afs.collection('rooms').doc(roomId).valueChanges()
      );
      return mergeMap(() => roomObservables);
    }),
    toArray()
  );
}

// 调用示例
this.searchMessageAndGetRooms('Hello World!').subscribe(rooms => {
  console.log('匹配的聊天室：', rooms.map(room => room.name));
});

这里用collectionGroup直接查询所有名为messages的子集合，比逐个遍历rooms高效得多，完全符合Firestore的设计逻辑。

方案二：遍历所有聊天室查询（不推荐生产环境） #

如果暂时不想修改数据结构，也可以遍历所有rooms文档，逐个查询其messages子集合是否包含目标消息。但这种方式的问题很明显：

• 聊天室数量越多，请求次数越多，性能越差
• 容易触发Firestore的请求频率限制

代码示例 #

searchMessageInAllRooms(msgContent: string) {
  this.afs.collection('rooms').get().subscribe(roomsSnapshot => {
    roomsSnapshot.forEach(roomDoc => {
      this.afs.collection(`rooms/${roomDoc.id}/messages`, ref => 
        ref.where('msg', '==', msgContent)
      ).get().subscribe(messagesSnapshot => {
        if (!messagesSnapshot.empty) {
          console.log('找到匹配的聊天室：', roomDoc.data().name);
        }
      });
    });
  });
}

额外提示 #

如果需要实时监听数据变化（比如消息或聊天室更新时自动刷新结果），可以把get()换成valueChanges()或snapshotChanges()，这样能获得实时数据流。

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