MongoDB如何实现级联删除？Node.js中删Folder1时同步删file.txt

一、MongoDB级联删除的通用方案 #

MongoDB本身没有内置的级联删除机制，常用实现方式有三种：

• 应用层手动关联删除：删除父文档后，主动查询并删除所有关联子文档，这是最灵活、最常用的方案。
• 数据库触发器/Change Streams：监听父文档的删除事件，自动触发子文档删除操作，适合无需业务代码介入的自动化场景。
• 嵌入式文档结构：将子文档直接嵌入父文档，删除父文档时子文档会被一并删除，仅适合子文档数量少、结构简单的场景。

二、针对给定文档结构的Node.js实现 #

你的文档结构为分离的文件夹与文件集合，通过parentId关联父文件夹的_id：

[
{ _id: 1, name: "Folder1", parentId: null },
{ _id: 2, name: "file.txt", parentId: 1 }
]

下面分别给出原生MongoDB驱动和Mongoose两种实现方式：

1. 原生MongoDB驱动实现 #

const { MongoClient } = require('mongodb');

async function deleteFolderAndAssociatedFiles(folderId) {
  const client = new MongoClient('mongodb://localhost:27017');
  try {
    await client.connect();
    const db = client.db('your-database-name');
    const foldersCol = db.collection('folders');
    const filesCol = db.collection('files');

    // 删除目标文件夹
    const folderDeleteRes = await foldersCol.deleteOne({ _id: folderId });
    if (folderDeleteRes.deletedCount === 0) {
      console.log('未找到指定文件夹');
      return;
    }

    // 删除所有关联子文件
    const filesDeleteRes = await filesCol.deleteMany({ parentId: folderId });
    console.log(`成功删除1个文件夹和${filesDeleteRes.deletedCount}个关联文件`);
  } catch (err) {
    console.error('删除操作失败:', err);
  } finally {
    await client.close();
  }
}

// 调用示例：删除_id为1的Folder1
deleteFolderAndAssociatedFiles(1);

2. Mongoose实现（更常用） #

基础手动删除版本

const mongoose = require('mongoose');
mongoose.connect('mongodb://localhost:27017/your-database-name');

// 定义Schema与Model
const FolderSchema = new mongoose.Schema({
  name: String,
  parentId: mongoose.Schema.Types.ObjectId
});
const FileSchema = new mongoose.Schema({
  name: String,
  parentId: mongoose.Schema.Types.ObjectId
});

const Folder = mongoose.model('Folder', FolderSchema);
const File = mongoose.model('File', FileSchema);

async function deleteFolderAndFiles(folderId) {
  try {
    // 删除文件夹
    const deletedFolder = await Folder.findByIdAndDelete(folderId);
    if (!deletedFolder) {
      console.log('未找到要删除的文件夹');
      return;
    }

    // 删除关联文件
    const filesDeleteRes = await File.deleteMany({ parentId: folderId });
    console.log(`已删除1个文件夹和${filesDeleteRes.deletedCount}个关联文件`);
  } catch (err) {
    console.error('删除操作出错:', err);
  } finally {
    await mongoose.connection.close();
  }
}

// 调用示例
deleteFolderAndFiles(1);

自动级联的中间件版本

如果想让删除文件夹时自动清理关联文件，可使用Mongoose的post删除中间件：

// 在Folder Schema上添加后置删除钩子
FolderSchema.post('findOneAndDelete', async function(doc) {
  if (doc) {
    await File.deleteMany({ parentId: doc._id });
  }
});

// 此时只需调用文件夹删除方法即可
async function deleteFolder(folderId) {
  try {
    const deletedFolder = await Folder.findByIdAndDelete(folderId);
    if (!deletedFolder) {
      console.log('未找到指定文件夹');
      return;
    }
    console.log('文件夹已删除，关联文件已自动清理');
  } catch (err) {
    console.error('删除失败:', err);
  }
}

内容的提问来源于stack exchange，提问作者Đạt Huỳnh