nodejs中的Sqlite事务

Question

根据 nodejs sqlite 库 (https://github.com/mapbox/node-sqlite3)，您可以使用 db.serialize 函数序列化 sql 事务。此函数中的所有执行都将按照指定的顺序执行。 但是使用 for 循环如何获取有关事务的信息是成功还是失败？

function transaction(callback) {
    db.serialize(function() {
        db.run("BEGIN");

        for(...) {
            db.run("INSERT", function(err) {
                //this code is not serialized with the parent serialize function (this is my problem)
                //if one run throw error i must resolve the callback with the error code

                if (err)
                    callback("error");
            });
        }

        db.run("END");

        callback("ok");
    }
}

Answer 1

在开始交易之前，您可以定义一些变量，例如var results = [];。在回调中完成每个查询后，您可以将错误或 null 收集为results.push(err) 并检查results.length。当results.length 等于for 的长度时，所有查询都会执行，现在检查results.every((i) => i === null) 的值。如果为真，则执行commit，否则执行rollback。

---

更好地控制流程是使用异步模块。

'use strict'
var async = require('async');
...
db.run('begin', function(err){
    if (err)
        return console.log(err);

    let run = (sql, callback) => db.run(sql, callback);    
    async.eachSeries(sqls, run, function(err){
        db.run((err) ? 'rollback' : 'commit', ...)
    })
})

如果将begin添加到sqls中，那么代码会更简单。