diff options
| -rw-r--r-- | connect-better-sqlite3.js | 8 | ||||
| -rw-r--r-- | server.js | 2 |
2 files changed, 8 insertions, 2 deletions
diff --git a/connect-better-sqlite3.js b/connect-better-sqlite3.js index 2bfdb12..de858ed 100644 --- a/connect-better-sqlite3.js +++ b/connect-better-sqlite3.js @@ -29,14 +29,17 @@ module.exports = function (session) { db_path = (options.dir || '.') + '/' + db_path; let db = new SQLite(db_path, options.mode); + db.pragma("journal_mode = WAL"); + db.pragma("synchronous = NORMAL"); db.exec("CREATE TABLE IF NOT EXISTS "+table+" (sid PRIMARY KEY, expires INTEGER, sess TEXT)"); db.exec("DELETE FROM "+table+" WHERE "+now()+" > expires"); db.exec("VACUUM"); + db.exec("PRAGMA wal_checkpoint(TRUNCATE)"); this.sql_destroy = db.prepare("DELETE FROM "+table+" WHERE sid = ?"); this.sql_get = db.prepare("SELECT sess FROM "+table+" WHERE sid = ? AND ? <= expires"); this.sql_set = db.prepare("INSERT OR REPLACE INTO "+table+" VALUES (?,?,?)"); - this.sql_touch = db.prepare("UPDATE "+table+" SET expires = ? WHERE sid = ? AND ? <= expires"); + this.sql_touch = db.prepare("UPDATE "+table+" SET expires = ? WHERE sid = ? AND expires < ?"); } destroy(sid, cb = noop) { @@ -77,7 +80,8 @@ module.exports = function (session) { try { if (sess && sess.cookie && sess.cookie.expires) { let expires = seconds(sess.cookie.expires); - this.sql_touch.run(expires, sid, now()); + let limit = expires - 3600; + this.sql_touch.run(expires, sid, limit); cb(null); } else { cb(null); @@ -20,6 +20,8 @@ const MAX_OPEN_GAMES = 5; let session_store = new SQLiteStore(); let db = new sqlite3(process.env.DATABASE || "./db"); +db.pragma("journal_mode = WAL"); +db.pragma("synchronous = NORMAL"); let app = express(); let server = null; |