如何使用 mysql 库在 Node.js 中创建存储过程？

Question

如何使用 mysql 库在 Node.js 中创建存储过程？ npm包mysql支持创建存储过程还是这段代码有错误？这是我正在使用的 npm 库：https : //www.npmjs.com/package/mysql

我正在尝试为一个开源项目自动设置数据库，以帮助新的贡献者启动并运行他们的开发环境（并使我们所有人都使用相同的数据库架构）。

为了实现这一点，我编写了一个脚本，该脚本应该将所有命令发送到 mysql 实例以设置数据库。创建表是有效的，但创建新的存储过程总是导致错误。当我在 MySQL Workbench 中运行命令时，创建脚本确实有效，所以问题似乎仅限于脚本。

var emails =
        "CREATE TABLE emails (" +
            "`id` INT NOT NULL AUTO_INCREMENT PRIMARY KEY," +
            "`email` VARCHAR(2048) CHARACTER SET utf8" +
        ");";

var addEmail =
        "DELIMITER //\n" +
        "CREATE PROCEDURE addEmail(IN email VARCHAR(2048))\n" +
        "BEGIN\n" +
        "INSERT INTO emails (email) VALUES (email);\n" +
        "END //\n" +
        "DELIMITER ;";

var query = [];
query.push(emails);
query.push(addEmail);

for(var i = 0; i < query.length; i++) {

    console.log(query[i]);
    connection.query(query[i], function (err, rows, fields) {
        if (!err) {
            console.log("success"); //emails succeeds, as do other create table commands
        } else {
            console.log('Error while performing Query.'); //any queries that create stored procedures fail
        }
    });

}

从接受的答案中汲取极好的建议，更正后的代码如下所示：

var addEmail =
        "CREATE PROCEDURE addEmail(IN email VARCHAR(2048))\n" +
        "BEGIN\n" +
        "INSERT INTO emails (email) VALUES (email);\n" +
        "END";

Answer 1

1. 以DELIMITER编程方式运行 SQL 时不需要使用。仅当使用mysql客户端手动或从脚本文件执行 SQL 语句流时才需要 DELIMITER 。当您一次运行一个查询时，您不必解决关于;过程定义内部是否是语句结尾的任何歧义。

2. 从查询中检查错误状态很好，但您也应该养成检查错误类型和错误消息的习惯。这将帮助您解决多种类型的问题——无需发布到 Stack Overflow 并希望有人及时回答您的问题！

   connection.query(query[i], function (err, rows, fields) {
       if (!err) {
           console.log("success");
       } else {
           console.log('Error while performing Query.');
           console.log(err.code);
           console.log(err.message);
       }
   });