diff options
Diffstat (limited to 'connect-better-sqlite3.js')
| -rw-r--r-- | connect-better-sqlite3.js | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/connect-better-sqlite3.js b/connect-better-sqlite3.js index 6574346..1f5c9f4 100644 --- a/connect-better-sqlite3.js +++ b/connect-better-sqlite3.js @@ -31,15 +31,15 @@ module.exports = function (session) { let db = new SQLite(db_path, options.mode); db.pragma("journal_mode = WAL"); db.pragma("synchronous = OFF"); - db.exec("CREATE TABLE IF NOT EXISTS "+table+" (sid PRIMARY KEY, expires INTEGER, sess TEXT) WITHOUT ROWID"); - db.exec("DELETE FROM "+table+" WHERE "+now()+" > expires"); + db.exec(`CREATE TABLE IF NOT EXISTS ${table} (sid PRIMARY KEY, expires INTEGER, sess TEXT) WITHOUT ROWID`); + 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_destroy = db.prepare(`DELETE FROM ${table} WHERE sid = ?`); + this.sql_get = db.prepare(`SELECT sess FROM ${table} WHERE sid = ? AND ? <= expires`).pluck(); + this.sql_set = db.prepare(`INSERT OR REPLACE INTO ${table} VALUES (?,?,?)`); + this.sql_touch = db.prepare(`UPDATE ${table} SET expires = ? WHERE sid = ? AND expires < ?`); } destroy(sid, cb = noop) { @@ -55,7 +55,7 @@ module.exports = function (session) { try { let sess = this.sql_get.get(sid, now()); if (sess) - return cb(null, JSON.parse(sess.sess)); + return cb(null, JSON.parse(sess)); return cb(null, null); } catch (err) { return cb(err, null); |