如何在Node.js中通过PostgreSQL批量删除多条记录？

你已经实现了单条车辆记录的删除接口，以下是基于现有代码扩展批量删除功能的具体思路和代码修改：

现有代码回顾 #

单条删除控制器 #

// 删除单条车辆记录
export async function deleteCar(req, res) {
  try {
    const car = await Car.findByIdAndDelete(req.params.car_id);
    if (!car) {
      return res.status(404).send();
    }
    res.send(car);
  } catch (error) {
    return res.status(500).json({
      success: false,
      message: "服务器错误，请重试",
      error: error.message,
    });
  }
}

Car 模型 #

import Sequelize from 'sequelize';

export const Car = sequelize.define("car", {
    car_id: {
      type: Sequelize.INTEGER,
      primaryKey: true, 
      autoIncrement:true,
    },
    name: {
      type: Sequelize.STRING,
      unique: true,
      required:  [true, '车辆名称必填'],
    },
    color: {
      type: Sequelize.STRING,
      unique: true,
      required: [true, '车辆颜色必填'],
    },
    brand: {
      type: Sequelize.STRING,
      unique: true,
      required: [true, '车辆品牌必填'],
    },
  }, { sequelize, freezeTableName: true}
)

export default Car;

路由配置 #

router.delete("/cars/:carId", deleteCar);

批量删除实现步骤 #

1. 新增批量删除路由 #

添加专门处理批量删除的路由，使用DELETE方法并通过请求体传递ID数组：

// 批量删除车辆路由
router.delete("/cars/batch", deleteCarsBatch);

2. 实现批量删除控制器 #

编写deleteCarsBatch函数，利用Sequelize的destroy方法结合PostgreSQL的IN操作符实现批量删除：

export async function deleteCarsBatch(req, res) {
  try {
    // 从请求体获取待删除的车辆ID数组
    const { carIds } = req.body;

    // 参数校验：确保传入的是有效非空数组
    if (!Array.isArray(carIds) || carIds.length === 0) {
      return res.status(400).json({
        success: false,
        message: "请提供有效的车辆ID数组"
      });
    }

    // 执行批量删除，返回删除的记录条数
    const deletedCount = await Car.destroy({
      where: {
        car_id: carIds // Sequelize自动转换为PostgreSQL的IN查询语句
      }
    });

    // 处理无匹配记录的情况
    if (deletedCount === 0) {
      return res.status(404).json({
        success: false,
        message: "未找到匹配的车辆记录"
      });
    }

    // 返回成功结果
    res.status(200).json({
      success: true,
      message: `成功删除${deletedCount}条车辆记录`,
      deletedCount
    });
  } catch (error) {
    return res.status(500).json({
      success: false,
      message: "服务器错误，请重试",
      error: error.message
    });
  }
}

3. 可选：事务保证原子性 #

如果需要确保批量删除的原子性（要么全部删除成功，要么全部回滚），可以添加Sequelize事务：

export async function deleteCarsBatch(req, res) {
  const transaction = await sequelize.transaction();
  try {
    const { carIds } = req.body;

    if (!Array.isArray(carIds) || carIds.length === 0) {
      return res.status(400).json({
        success: false,
        message: "请提供有效的车辆ID数组"
      });
    }

    const deletedCount = await Car.destroy({
      where: { car_id: carIds },
      transaction // 绑定事务
    });

    if (deletedCount === 0) {
      await transaction.rollback();
      return res.status(404).json({
        success: false,
        message: "未找到匹配的车辆记录"
      });
    }

    await transaction.commit();
    res.status(200).json({
      success: true,
      message: `成功删除${deletedCount}条车辆记录`,
      deletedCount
    });
  } catch (error) {
    await transaction.rollback();
    return res.status(500).json({
      success: false,
      message: "服务器错误，请重试",
      error: error.message
    });
  }
}

关键说明 #

• Sequelize的destroy方法配合where: { car_id: carIds }会自动生成DELETE FROM car WHERE car_id IN (...)的PostgreSQL语句，高效处理批量删除
• 必须添加参数校验，避免空数组或非数组参数导致的无效操作
• 事务可选，但在涉及关联数据删除时建议使用，确保数据一致性

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