如何将MySQL的JOIN查询迁移至Mongoose/MongoDB？

嘿，针对你从SQL查询迁移到Mongoose/MongoDB的需求，我整理了两种实用的方案，还有后续的处理建议，你可以根据自己的业务场景选择：

方案一：保持两个独立Schema（对应原SQL的两张表） #

这种方式最贴近你原来的SQL JOIN逻辑，用MongoDB的$lookup操作实现关联查询，适合需要单独维护domains和favicons数据的场景。

1. 定义两个Schema #

首先分别创建对应的数据模型：

// domains.schema.js
const mongoose = require('mongoose');

const domainsSchema = new mongoose.Schema({
  tag0: String,
  tag1: String,
  url: String,
  title: String,
  domain: String // 用于和favicons关联的字段
});

module.exports = mongoose.model('Domain', domainsSchema);

// favicons.schema.js
const mongoose = require('mongoose');

const faviconsSchema = new mongoose.Schema({
  domain: String, // 关联字段
  favicon_local: String
});

// 给domain字段加索引，提升关联查询的性能
faviconsSchema.index({ domain: 1 });

module.exports = mongoose.model('Favicon', faviconsSchema);

2. 实现关联查询（对应你的SQL语句） #

用Mongoose的aggregate方法配合$lookup来实现和SQL JOIN一样的效果，同时加上排序：

const Domain = require('./domains.schema');

async function getJoinedData() {
  const result = await Domain.aggregate([
    // 关联favicons集合，类似SQL的INNER JOIN
    {
      $lookup: {
        from: 'favicons', // 对应favicons模型的集合名（默认是模型名小写复数）
        localField: 'domain', // domains集合里的关联字段
        foreignField: 'domain', // favicons集合里的关联字段
        as: 'faviconInfo' // 关联结果的别名
      }
    },
    // 将$lookup返回的数组展开为单个对象（对应INNER JOIN，只保留有匹配的文档）
    { $unwind: '$faviconInfo' },
    // 把favicon_local字段提取到顶层，和你的SQL查询结果结构一致
    {
      $project: {
        tag0: 1,
        tag1: 1,
        url: 1,
        title: 1,
        domain: 1,
        favicon_local: '$faviconInfo.favicon_local'
      }
    },
    // 按tag0排序，对应SQL的ORDER BY
    { $sort: { tag0: 1 } }
  ]);

  return result;
}

方案二：合并为单一Schema（嵌入文档） #

如果你的favicon_local和domain是强关联，且很少单独更新favicon数据，那把数据嵌入到同一个文档里会更高效，查询速度更快，不需要关联操作。

1. 定义合并后的Schema #

const mongoose = require('mongoose');

const domainWithFaviconSchema = new mongoose.Schema({
  tag0: String,
  tag1: String,
  url: String,
  title: String,
  domain: String,
  favicon_local: String
});

module.exports = mongoose.model('DomainWithFavicon', domainWithFaviconSchema);

2. 查询数据 #

这种方式的查询非常简单，直接用find加排序即可，和SQL的查询结果结构完全一致：

const DomainWithFavicon = require('./domain-with-favicon.schema');

async function getJoinedData() {
  const result = await DomainWithFavicon.find({})
    .sort({ tag0: 1 })
    .select('tag0 tag1 url title domain favicon_local'); // 可选，指定返回的字段

  return result;
}

如何选择方案？ #

• 选独立Schema：如果favicons数据需要单独维护（比如批量更新某个domain的favicon，或者多个domain共享同一个favicon），或者数据量很大，分开存储更灵活。
• 选单一Schema：如果每个domain对应唯一的favicon，且favicon很少更新，嵌入查询更高效，代码也更简洁。

后续处理建议 #

1. 索引优化：不管选哪种方案，都给domain字段加索引（方案一已经加了，方案二也可以加domain: 1的索引），提升查询和关联的性能。
2. 数据同步：如果选独立Schema，要保证domains和favicons的domain字段一致，避免出现关联不上的情况，可以在新增/更新数据的时候做校验。
3. 批量操作：如果选单一Schema，批量更新favicon的时候，要用updateMany来批量修改符合条件的文档。

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