node-mysql一次查询多条语句

Question

我使用的是NodeJS 10.26+Express 3.5+Node-MySQL 2.1.1+MySQL-Server Version:5.6.16。

我得到了4个DELETE,只想要一个数据库请求,所以我用一个“；”连接了DELETE命令...但总是失败。

var sql_string = "DELETE FROM user_tables WHERE name = 'Testbase';";
sql_string += "DELETE FROM user_tables_structure WHERE parent_table_name = 'Testbase';";
sql_string += "DELETE FROM user_tables_rules WHERE parent_table_name = 'Testbase';";
sql_string += "DELETE FROM user_tables_columns WHERE parent_table_name = 'Testbase';";

connection.query(sql_string, function(err, rows, fields) {
   if (err) throw err;
   res.send('true');
});

它会抛出以下错误：

Error: ER_PARSE_ERROR: You have an error in your SQL syntax; check the manual that corresponds to your MySQL server version for the right syntax to use near 'DELETE FROM user_tables_structure WHERE parent_table_name = 'Testbase';DELETE FR' at line 1

但如果我将此SQL粘贴到PhpMyAdmin中，它总是成功的...

如果我在单个查询中编写它，它也会成功。

        connection.query("DELETE FROM user_tables WHERE name = 'Testbase'", function(err, rows, fields) {
        if (err) throw err;

        connection.query("DELETE FROM user_tables_structure WHERE parent_table_name = 'Testbase'", function(err, rows, fields) {
            if (err) throw err;


            connection.query("DELETE FROM user_tables_rules WHERE parent_table_name = 'Testbase'", function(err, rows, fields) {
                if (err) throw err;

                connection.query("DELETE FROM user_tables_columns WHERE parent_table_name = 'Testbase'", function(err, rows, fields) {
                    if (err) throw err;

                    res.send('true');
                });
            });
        });
    });

多谢帮忙！

Answer 1

我猜您使用的是Node-MySQL。（但也适用于node-mysql2)

文件上说：

出于安全原因，禁用了对多条语句的支持（如果值未正确转义，则允许SQL注入攻击）。

要使用此功能,您必须为连接启用此功能：

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

启用后，可以通过使用分号；分隔每个语句来执行具有多个语句的查询。结果将是每个语句的数组。

connection.query('SELECT ?; SELECT ?', [1, 2], function(err, results) {
  if (err) throw err;

  // `results` is an array with one element for every statement in the query:
  console.log(results[0]); // [{1: 1}]
  console.log(results[1]); // [{2: 2}]
});

因此，如果您启用了multiplestatements，那么您的第一个代码应该可以工作。