Nodejs Sqlite3未刷新到磁盘

zhte4eai 于 12个月前发布在 SQLite

关注(0)|答案(1)|浏览(184)

我遇到了sqlite3不刷新到磁盘的问题。我使用的代码如下。我的总文件数超过470k，程序往往使用几个千兆字节的内存。当程序运行test.db是0字节，没有使用日志。它只有在db.close()运行时才开始写入磁盘。

var fs = require('fs');
var sqlite3 = require('sqlite3').verbose();
var db = new sqlite3.Database('test.db');

db.serialize(function () {
    db.run("BEGIN;");
    db.run("CREATE TABLE if not exists Files (name TEXT);");
    db.run("COMMIT;");
    var files = fs.readdirSync("./files/");
    console.log("File list completed: " + files.length);
    for (var i = 0; i < files.length; i++) {
        db.run("INSERT INTO Files VALUES (?);",files[i]);
    }
});
db.close();

字符串
我已经尝试删除db.run("BEGIN;");和db.run("COMMIT;");，但它没有帮助。
臭虫
我在github上报告这是一个bug

sqlite

来源：https://stackoverflow.com/questions/39547260/nodejs-sqllite3-not-flushing-to-disk

1条答案

按热度按时间

lxkprmvk1#

我认为transaction和db.serialize存在问题。
db.serialize是不受控制的代码，不知道什么时候有用。
尝试如下所示的控制流

var fs = require('fs');
var sqlite3 = require('sqlite3'); 
var async = require('async');

var db = new sqlite3.Database('test.db');

async.series ([
        function(cb) { 
            db.run('CREATE TABLE if not exists Files (name TEXT)', cb);
        },

        function(cb) { 
            db.run('begin transaction', cb); 
        },

        function(cb) {
            var files = fs.readdirSync("./files/");
            async.each(
                files, 
                function(file, cb) { db.run('INSERT INTO Files VALUES (?)', file, cb); }, 
                cb  
            );
        },

        function(cb) {
            db.run('commit transaction', cb);
        }
    ],
    function(err) {
        if (err) {
            console.log(err);
            db.run('rollback transaction'); // can fail if error occurs on create table
        }
        db.close();
    }
)

字符串
如果您不需要insert all rows or nothing，则可以尝试下一个代码

var fs = require('fs');
var sqlite3 = require('sqlite3'); 
var async = require('async');

var db = new sqlite3.Database('test.db');

db.run('CREATE TABLE if not exists Files (name TEXT)', function (err) {
    if (err)
        return console.log(err);

    var files = fs.readdirSync("./files/");
    async.eachSeries(
        files, 
        function(file, cb) { db.run('INSERT INTO Files VALUES (?)', file, cb); }, 
        function(err) {
            console.log((err) ? err : 'Done');
            db.close();
        }  
    );
});

型

赞(0）回复(0）举报 12个月前

我来回答

Nodejs Sqlite3未刷新到磁盘

1条答案

相关问题

热门标签

最新问答