使用node-mysql，NodeJS和Q更新多行

Question

我正在使用node-mysql，node-js和Q promises。

我已使用上面的内容成功更新，删除和插入了单行。以及在我的测试用例场景中的单个语句中插入多行。

但是，我需要在单个查询或for循环中更新具有不同值（批处理模式）的多个行。

有关如何在mysql2中使用预处理语句的信息（应该在node-mysql上进行改进）非常稀疏，并且没有示例，尽管这应该是自然的选择，同时还有补偿node-js异步性质的承诺。

另外，我已经在各种测试场景中成功使用了defered.makeNodeResolver（）。

我试图使用where子句和更改条件更新单个查询中的多个行。

当我更新单行时，它正在工作。但是，当我尝试使用单个查询更新多个行时，记录不会更新。

我准备切换到使用for循环执行多个更新，然后聚合结果并将其从服务器发送回客户端，这将是我的第二选择。如果没有太多的性能影响，我不明白为什么不应该这样做。但我没有找到任何这样做的例子。

var values = [
    { users: "tom", id: 101 },
    { users: "george", id: 102 }
    ];

    // var params = [values.users, values.id ];

    var sql = 'UPDATE tabletest SET users = ? WHERE id = ?;';


    connection.query(sql, [{users: values[0].users}, {id: values[0].id }], defered.makeNodeResolver());

上面显示的代码实际上并没有更新多行。我想我的语法有错误。

但无论如何，在这种特殊情况下，最好的方法是什么？准备好的语句，for循环中的重复查询或存储过程？

Answer 1

你可以这样做：

var values = [
  { users: "tom", id: 101 },
  { users: "george", id: 102 }
];
var queries = '';

values.forEach(function (item) {
  queries += mysql.format("UPDATE tabletest SET users = ? WHERE id = ?; ", item);
});

connection.query(queries, defered.makeNodeResolver());

要使用多个语句功能，您必须为连接启用它：

var connection = mysql.createConnection({
  ...
  multipleStatements: true,
});

Answer 2

我认为你不能（至少容易/有效地）以你尝试的方式更新多行。你基本上必须遍历你的values并为每个对象执行UPDATE。

Answer 3

这段代码是从vcl.js中获取的node.js，它是用typescript编写的，并在单个事务中提供了多个update，delete，inseer语句。

export class SQLStatment {
    sql: string;
    params: Object
}

var dbError: string;
var execCount: number = 0;
function DBexecuteBatchMYSQLSingle(connection: any, SQLStatmentArray: Array<SQLStatment>, index: number, callback: () => void) {
    execCount++;
    connection.query(SQLStatmentArray[index].sql, SQLStatmentArray[index].params, function (err, rows, fields) {
        if (err) dbError = err;
        if (index + 1 == SQLStatmentArray.length) callback();
        else {
            if (!dbError) {
                DBexecuteBatchMYSQLSingle(connection, SQLStatmentArray, index + 1, function () {
                    if (index == 0) callback();
                });
            }
        }
    });
}

function DBBatchUpdateMYSQL(SQLStatmentArray: Array<SQLStatment>, callback?: (err) => void) {
    var mysql = require('mysql');
    var connection = mysql.createConnection({
        host: "host",user: "user",database: "db",
        port: 1022, password: "pass"});
    dbError = null;
    execCount = 0;
    connection.beginTransaction(function (err) {
        if (err && callback) callback("Database error:" + err);
        else {
            DBexecuteBatchMYSQLSingle(connection, SQLStatmentArray, 0, () => {
                if (dbError) {
                    connection.rollback(function () {
                        if (callback) callback("Database error:" + dbError);
                    });
                } else {
                    connection.commit(function (err) {
                        if (callback) callback(null);
                    })
                }
            });
        }
    });
}

Answer 4

您应该采取以下方式

UPDATE DB.table
SET table.row = newValue WHERE table.someColumn in ('columnVal1', 'columnVal2');

恩。

UPDATE DB.Students
SET result = "pass" WHERE rollNo in (21, 34, 50);

Answer 5

不知道这个问题是否仍然有用，但我会给出2美分：

我找到的解决方案是使用Promise.all

基本上你需要构建一个promise数组，其中每个promise都是一个更新语句：

const getUpdatePromise = (row) => {
  return new Promise( (resolve, reject) => {
    mysqlConnection.query('UPDATE tableName SET foo = ? WHERE bar = ?', [row[0], row[1], (error, results, fields) => {
      if (error) reject(error)
      resolve(results)
    });
  })
}

将这个新的Promise添加到一个数组中，并将带有所有update语句的最终数组传递给Promise.all函数。

它对我有用。希望它适用于其他人。