Mirror/SponsorBlockServer
1
0
Fork 0
mirror of https://github.com/ajayyy/SponsorBlockServer.git synced 2025-12-14 15:37:07 +03:00
Code Issues Packages Projects Releases Wiki Activity

Added schema upgrades for both DBs

Browse Source
This commit is contained in:
Ajay Ramachandran
2020-05-03 13:25:45 -04:00
parent d4328f4d54
commit 8638698d61
3 changed files with 21 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
databases/_private.db.sql
View File

@@ -24,6 +24,11 @@ CREATE TABLE IF NOT EXISTS "sponsorTimes" (
"timeSubmitted" INTEGER NOT NULL "timeSubmitted" INTEGER NOT NULL
); );
CREATE TABLE IF NOT EXISTS "config" (
"key" TEXT NOT NULL,
"value" TEXT NOT NULL
);
CREATE INDEX IF NOT EXISTS sponsorTimes_hashedIP on sponsorTimes(hashedIP); CREATE INDEX IF NOT EXISTS sponsorTimes_hashedIP on sponsorTimes(hashedIP);
CREATE INDEX IF NOT EXISTS votes_userID on votes(UUID); CREATE INDEX IF NOT EXISTS votes_userID on votes(UUID);

0
databases/_upgrade_1.sql → databases/_upgrade_sponsorTimes_1.sql
View File

27
src/databases/databases.js
View File

@@ -26,16 +26,8 @@ if (config.createDatabaseIfNotExist && !config.readOnly) {
// Upgrade database if required // Upgrade database if required
if (!config.readOnly) { if (!config.readOnly) {
let versionCodeInfo = db.prepare("SELECT value FROM config WHERE key = ?").get("version"); ugradeDB(db, "sponsorTimes");
let versionCode = versionCodeInfo ? versionCodeInfo.value : 0; ugradeDB(privateDB, "private")
let path = config.schemaFolder + "/_upgrade_" + (versionCode + 1) + ".sql";
while (fs.existsSync(path)) {
db.exec(fs.readFileSync(path).toString());
versionCode = db.prepare("SELECT value FROM config WHERE key = ?").get("version").value;
path = config.schemaFolder + "/_upgrade_" + (versionCode + 1) + ".sql";
}
} }
// Enable WAL mode checkpoint number // Enable WAL mode checkpoint number
@@ -51,4 +43,17 @@ privateDB.exec("pragma mmap_size= 500000000;");
module.exports = { module.exports = {
db: db, db: db,
privateDB: privateDB privateDB: privateDB
}; };
function ugradeDB(db, prefix) {
let versionCodeInfo = db.prepare("SELECT value FROM config WHERE key = ?").get("version");
let versionCode = versionCodeInfo ? versionCodeInfo.value : 0;
let path = config.schemaFolder + "/_upgrade_" + prefix + "_" + (versionCode + 1) + ".sql";
while (fs.existsSync(path)) {
db.exec(fs.readFileSync(path).toString());
versionCode = db.prepare("SELECT value FROM config WHERE key = ?").get("version").value;
path = config.schemaFolder + "/_upgrade_" + prefix + "_" + (versionCode + 1) + ".sql";
}
}