2

我有一个 sqlite3 嵌套查询案例。希望将每个查询结果推送到 json 数组并将其返回。但是对于第二次选择调用，总是得到“错误：SQLITE_MISUSE：数据库句柄已关闭”。似乎 db.close() 在第二个查询之前被调用。

为什么会这样，我认为序列化可以解决这个问题。请问如何解决？

var getMyDbInfo = function(callback) {
    var db = new sqlite3.Database("MyDB.sqlite3");

    db.serialize(function() {

        var myJsonObj = {};

        db.each("select * from Table1",
            function(err, row) {
                console.log("\n---- 0 ----\n");
                // calculate doorId from row
                doorId = ...

                db.all("select * from Table2 where ID=" + doorId,
                       function(err, row2) {
                           console.log("---- 6 ----\n");
                           if(err) {
                               console.log("-- ERR: " + err);
                           } else {
                               console.log(row2);
                               var myJsonElem = {ID:row.ID,
                                   DoorName: row2.DoorName,
                                   TimeSpec: row2.TimeSpec };

                               myJsonObj.data.push(myJsonElem);
                           }
                       }
               );
            }
        );
        callback(null, myJsonObj);
    });

    console.log("---- 10 ----\n");
    db.close();

};
4

1 回答 1

2

该db.all()调用嵌套在 的回调函数中db.each()。根据文档，db.serialize()仅序列化直接在db.serialize()回调函数中进行的调用。就db.serialize()目前而言，一旦调用回调 for，它的工作就完成了db.each()，因为没有更多的内联调用 make，因此db.close()被执行。

db.serialize()这里有一个解决方案 -因为您只在其中调用，所以摆脱它，并在调用所有行之后db.each()使用第二个“完成”回调函数。db.each()db.close()db.each()

如果需要在 之后进行更多 DB 调用，请在完成db.each()回调中添加一个并从那里继续。db.serialize() db.each()

var getMyDbInfo = function(callback) {
    var db = new sqlite3.Database("MyDB.sqlite3");

    var myJsonObj = {};

    db.each("select * from Table1",
        function(err, row) {
            console.log("\n---- 0 ----\n");
            // calculate doorId from row
            doorId = ...

            db.all("select * from Table2 where ID=" + doorId,
                    function(err, row2) {
                        console.log("---- 6 ----\n");
                        if(err) {
                            console.log("-- ERR: " + err);
                        } else {
                            console.log(row2);
                            var myJsonElem = {ID:row.ID,
                                DoorName: row2.DoorName,
                                TimeSpec: row2.TimeSpec };

                            myJsonObj.data.push(myJsonElem);
                        }
                    }
            );
        },
        function (err, rows) {
            callback(null, myJsonObj);
            db.close();
            console.log("---- 10 ----\n");
        }
    );

};
于 2019-02-09T23:06:54.253 回答