MyFavMirrors/owntone-server
1
0
Fork 0
mirror of https://github.com/owntone/owntone-server.git synced 2025-04-23 03:55:42 -04:00
Code Issues Packages Projects Releases Wiki Activity

Handle database schema upgrade from v1 to v2

Browse Source
This commit is contained in:
Julien BLACHE 2009-12-26 09:18:56 +01:00
parent 42a7715c69
commit 66716841ea
1 changed files with 77 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

81
src/db.c
View File

@ -2834,11 +2834,58 @@ db_create_tables(void)
return 0; return 0;
} }
/* Upgrade from schema v1 to v2 */
#define U_V2_FILES \
"ALTER TABLE files ADD COLUMN media_kind INTEGER NOT NULL DEFAULT 0;" \
"ALTER TABLE files ADD COLUMN tv_series_name VARCHAR(1024) DEFAULT NULL;" \
"ALTER TABLE files ADD COLUMN tv_episode_num_str VARCHAR(1024) DEFAULT NULL;" \
"ALTER TABLE files ADD COLUMN tv_network_name VARCHAR(1024) DEFAULT NULL;" \
"ALTER TABLE files ADD COLUMN tv_episode_sort INTEGER NOT NULL DEFAULT 0;" \
"ALTER TABLE files ADD COLUMN tv_season_num INTEGER NOT NULL DEFAULT 0;"
#define U_V2_SCVER \
"UPDATE admin SET value = '2' WHERE key = 'schema_version';"
static struct db_init_query db_upgrade_v2_queries[] =
{
{ U_V2_FILES, "upgrade table files" },
{ U_V2_SCVER, "set schema_version to 2" },
};
static int
db_upgrade_v2(void)
{
char *errmsg;
int i;
int ret;
for (i = 0; i < (sizeof(db_upgrade_v2_queries) / sizeof(db_upgrade_v2_queries[0])); i++)
{
DPRINTF(E_DBG, L_DB, "DB upgrade query: %s\n", db_upgrade_v2_queries[i].desc);
ret = sqlite3_exec(hdl, db_upgrade_v2_queries[i].query, NULL, NULL, &errmsg);
if (ret != SQLITE_OK)
{
DPRINTF(E_FATAL, L_DB, "DB upgrade error: %s\n", errmsg);
sqlite3_free(errmsg);
return -1;
}
}
return 0;
}
static int static int
db_check_version(void) db_check_version(void)
{ {
#define Q_VER "SELECT value FROM admin WHERE key = 'schema_version';" #define Q_VER "SELECT value FROM admin WHERE key = 'schema_version';"
#define Q_VACUUM "VACUUM;"
sqlite3_stmt *stmt; sqlite3_stmt *stmt;
char *errmsg;
int cur_ver;
int ret; int ret;
DPRINTF(E_DBG, L_DB, "Running query '%s'\n", Q_VER); DPRINTF(E_DBG, L_DB, "Running query '%s'\n", Q_VER);
@ -2859,17 +2906,40 @@ db_check_version(void)
return -1; return -1;
} }
ret = sqlite3_column_int(stmt, 0); cur_ver = sqlite3_column_int(stmt, 0);
sqlite3_finalize(stmt); sqlite3_finalize(stmt);
if (ret < SCHEMA_VERSION) if (cur_ver < SCHEMA_VERSION)
{ {
DPRINTF(E_LOG, L_DB, "Database schema outdated, schema upgrade needed\n"); DPRINTF(E_LOG, L_DB, "Database schema outdated, schema upgrade needed v%d -> v%d\n", cur_ver, SCHEMA_VERSION);
/* We'll handle the upgrade */
switch (cur_ver)
{
case 1:
ret = db_upgrade_v2();
if (ret < 0)
return -1;
break;
default:
DPRINTF(E_LOG, L_DB, "No upgrade path from DB schema v%d to v%d\n", cur_ver, SCHEMA_VERSION);
return -1; return -1;
} }
else if (ret > SCHEMA_VERSION)
/* What about some housekeeping work, eh? */
DPRINTF(E_INFO, L_DB, "Now vacuuming database, this may take some time...\n");
ret = sqlite3_exec(hdl, Q_VACUUM, NULL, NULL, &errmsg);
if (ret != SQLITE_OK)
{
DPRINTF(E_LOG, L_DB, "Could not VACUUM database: %s\n", errmsg);
sqlite3_free(errmsg);
return -1;
}
}
else if (cur_ver > SCHEMA_VERSION)
{ {
DPRINTF(E_LOG, L_DB, "Database schema is newer than the supported version\n"); DPRINTF(E_LOG, L_DB, "Database schema is newer than the supported version\n");
return -1; return -1;
@ -2878,6 +2948,7 @@ db_check_version(void)
return 0; return 0;
#undef Q_VER #undef Q_VER
#undef Q_VACUUM
} }
int int