Node.js，多个MySQL插入

Question

我想为我的服务器-客户端应用程序在一个特定的命令器中执行多个MySQL插入。

var con = createDatabaseConnection();

function createDatabaseConnection() {
return (mysql.createConnection({
        host: // hostIp,
        user: // user,
        password: //pw,
        database: //databasename
    });
}

function writeFoo(fooObject) {
   var sql = // prepare sql insert for fooObject;
   con.query(sql, function (err) {
      // ? Is inserted data ready to use ?
   }
});

function writeBar(barObject) {
   var sql = // prepare sql insert for barObject;
   con.query(sql, function (err) {
      // ? Is inserted data ready to use ?
   });
});

// Both arrays containing an unpredictable amount of objects
var fooArray = [];
var barArray = [];

关键的一点是，我必须绝对肯定，在插入fooObject之前，fooArray中的barArray是插入的。因为writeBar()中使用的SELECT语句包含一个SELECT语句，该语句必须找到插入到writeFoo()中的数据。在任何时候，事件都可能发生(客户端发送需要插入的数据)，这也需要这种功能。

实际情况有点复杂，但我认为这是目前的主要问题。

Answer 1

您可以将它们链接到一个承诺中，这样您就可以确保每个调用都是正常的，例如：

var con;
function createDatabaseConnection() {
    return new Promise(function (resolve, reject) {
        mysql.createConnection({
            host: hostIp,
            user: user,
            password: pw,
            database: databasename
        }, function(err, res){
            if(err) reject(err);
            else resolve(res);
        });
    });
}

function writeFoo(fooObject) {
    let sql = fooObject;
    return new Promise(function (resolve, reject) {
        con.query(sql, function (err, res) {
            if(err) reject(err);
            else resolve(res);
        });
    });
}

function writeBar(barObject) {
    let sql = barObject;
    return new Promise(function (resolve, reject) {
        con.query(sql, function (err, res) {
            if(err) reject(err);
            else resolve(res);
        });
    });
}

createDatabaseConnection()
    .catch(function (error) {
        // connection failed
        // log info
        console.error(error);
        process.exit(0);
    })
    .then(function (res) {
        con = res;
        return writeFoo(fooObject);
    })
    .catch(function (error) {
        // writeFoo(fooObject) failed
        // log info
        console.error(error);
        process.exit(0);
    })
    .then(function () {
        return writeBar(barObject);
    })
    .catch(function (error) {
        // writeBar(barObject) failed
        // log info
        console.error(error);
        process.exit(0);
    });

Answer 2

并不是说ORM总是最好的，但是http://docs.sequelizejs.com/在节点上工作得很好。这里有一个大容量插入选项。