Nodejs + mysql 如何批量 update ???

Nodejs + mysql 如何批量 update ???

如题!!! 网上查，只有批量insert的操作，没找到批量update的方法。

5 回复

Node.js + MySQL 如何批量 Update?

在 Node.js 中使用 MySQL 进行批量更新操作时，通常需要通过编写循环或使用批量查询的方式来实现。虽然 MySQL 本身没有直接支持批量更新的语法，但可以通过一些技巧来实现这一功能。

方法一：使用循环

最简单的方式是使用一个循环来逐个执行更新语句。这种方法的优点是简单易懂，缺点是可能会导致性能问题，尤其是在数据量较大的情况下。

const mysql = require('mysql');

// 创建数据库连接
const connection = mysql.createConnection({
    host: 'localhost',
    user: 'root',
    password: 'password',
    database: 'testdb'
});

connection.connect((err) => {
    if (err) throw err;
    console.log('Connected!');
    
    const updates = [
        { id: 1, name: 'Alice' },
        { id: 2, name: 'Bob' },
        { id: 3, name: 'Charlie' }
    ];

    // 批量更新
    updates.forEach(update => {
        const query = `UPDATE users SET name = ? WHERE id = ?`;
        connection.query(query, [update.name, update.id], (err, result) => {
            if (err) throw err;
            console.log(`Updated row with id ${update.id}`);
        });
    });

    connection.end();
});

方法二：使用批量查询

另一种方法是将多个更新语句组合成一个大的 SQL 查询，并一次性执行。这种方法可以提高性能，但需要注意 SQL 注入风险，因此需要确保参数的安全性。

const mysql = require('mysql');

// 创建数据库连接
const connection = mysql.createConnection({
    host: 'localhost',
    user: 'root',
    password: 'password',
    database: 'testdb'
});

connection.connect((err) => {
    if (err) throw err;
    console.log('Connected!');
    
    const updates = [
        { id: 1, name: 'Alice' },
        { id: 2, name: 'Bob' },
        { id: 3, name: 'Charlie' }
    ];

    // 构建批量更新的SQL语句
    const queries = updates.map(update => 
        `UPDATE users SET name = '${update.name}' WHERE id = ${update.id}`
    ).join('; ');

    // 执行批量更新
    connection.query(queries, (err, results) => {
        if (err) throw err;
        console.log('All updates executed');
    });

    connection.end();
});

注意事项

  • 在生产环境中，建议使用预编译语句来避免 SQL 注入攻击。
  • 考虑到性能问题，如果数据量较大，可以考虑使用事务来保证数据一致性。

希望这些示例能帮助你更好地理解和实现 Node.js 中的批量更新操作。


如果你做批量一定涉及到事物吧，目前驱动还不支持事物。如果你真想这么做，只能建议你在数据库上创建个存储过程，然后用node去调用了。

怎么个批量法？一般我们批量操作是直接生成大SQL语句开启事务执行。

update 表 SET 字段 = CASE Id WHEN 1 THEN 123 END WHERE ID = 1; 亲，你的mysql都没有学好。

要实现 Node.js 中使用 MySQL 进行批量更新，你可以通过构建一个包含多个 UPDATE 语句的事务来实现。MySQL 支持在一个事务中执行多条 SQL 语句，这样可以确保数据的一致性和完整性。

以下是一个简单的示例代码，展示如何使用 mysql 模块在 Node.js 中进行批量更新：

const mysql = require('mysql');
const connection = mysql.createConnection({
  host: 'localhost',
  user: 'yourusername',
  password: 'yourpassword',
  database: 'yourdatabase'
});

connection.connect();

// 示例数据：要更新的记录列表
const updates = [
  { id: 1, name: 'Alice', age: 30 },
  { id: 2, name: 'Bob', age: 25 },
  { id: 3, name: 'Charlie', age: 35 }
];

// 开始事务
connection.beginTransaction(function(err) {
  if (err) {
    throw err;
  }

  // 执行多条更新语句
  const updatePromises = updates.map(update => {
    return new Promise((resolve, reject) => {
      connection.query(
        'UPDATE users SET name = ?, age = ? WHERE id = ?',
        [update.name, update.age, update.id],
        function(error, results, fields) {
          if (error) {
            reject(error);
          } else {
            resolve(results);
          }
        }
      );
    });
  });

  // 当所有更新完成后提交事务
  Promise.all(updatePromises)
    .then(() => {
      connection.commit((err) => {
        if (err) {
          return connection.rollback(() => {
            throw err;
          });
        }
        console.log('All updates are done!');
        connection.end();
      });
    })
    .catch((error) => {
      connection.rollback(() => {
        throw error;
      });
    });
});

在这个示例中：

  1. 创建了一个数据库连接。
  2. 定义了要更新的数据列表。
  3. 使用 beginTransaction 方法开始一个事务。
  4. 遍历更新列表，并为每个更新创建一个 Promise，以异步方式执行 SQL 更新语句。
  5. 使用 Promise.all 确保所有更新都成功后，调用 commit 方法提交事务。
  6. 如果任何更新失败，则调用 rollback 回滚事务。

这种方式确保了批量更新操作的一致性，并且提供了错误处理机制。

回到顶部