MySQL Sequelize 中删除 JSON 对象的全面指南：防止服务器崩溃并确保原子性

2024-03-22 22:34:07

从 MySQL Sequelize 中删除 JSON 对象的终极指南

简介

在使用 MySQL Sequelize 时，存储在 JSON 列中的数据可以通过JSON_REMOVE()函数有效地删除。本文将深入探讨如何使用事务处理和Sequelize方法删除和更新 JSON 对象，从而避免服务器崩溃并确保操作的原子性。

问题：从 JSON 对象中删除数据

在 Node.js Express 和 MySQL Sequelize 中，将 JSON 对象存储在文本字段中。直接从文本字段中删除数据可能既耗时又容易出错，尤其是当数据量较大时。因此，我们需要一种更有效的方法来管理 JSON 数据。

解决方案：事务处理

为了确保删除和插入操作的原子性，我们使用事务处理。事务处理确保要么两个操作都成功，要么都不成功，从而防止部分更新导致数据不一致。

步骤：使用 JSON_REMOVE() 函数

要删除 JSON 对象，我们需要使用JSON_REMOVE()函数。该函数接受两个参数：要更新的 JSON 列和要删除的对象的路径。路径使用点号表示法指定，例如$.[0]表示删除数组中的第一个对象。

步骤：执行查询

使用 Sequelize 的 query() 方法执行查询，并提供userId参数来指定要更新的用户：

const updateQuery = `UPDATE Users
SET files = JSON_REMOVE(files, '$.[0]')
WHERE id = :userId`;

步骤：设置新 JSON

删除现有 JSON 对象后，使用 set() 方法将新 JSON 设置为模型。我们使用扩展运算符...来保留现有数组中的其他对象，并添加新的对象：

User.set("files", [
  ...User.files,
  {
    fileName: file.originalname,
    fileData: newjson,
    uploadTime: new Date(),
  },
]);

步骤：保存模型

最后，调用 save() 方法将更改保存到数据库：

await User.save();

示例代码

以下示例代码展示了如何使用事务处理和 Sequelize 方法来删除和更新 JSON 对象：

const transaction = await sequelize.transaction();

try {
  const updateQuery = `UPDATE Users
SET files = JSON_REMOVE(files, '$.[0]')
WHERE id = :userId`;

  await sequelize.query(updateQuery, {
    replacements: { userId },
    type: sequelize.QueryTypes.UPDATE,
    transaction,
  });

  User.set("files", [
    ...User.files,
    {
      fileName: file.originalname,
      fileData: newjson,
      uploadTime: new Date(),
    },
  ]);

  await User.save({ transaction });

  await transaction.commit();
} catch (error) {
  await transaction.rollback();
}