summaryrefslogtreecommitdiffstats
path: root/database/sqlite/sqlite_db_migration.c
diff options
context:
space:
mode:
Diffstat (limited to 'database/sqlite/sqlite_db_migration.c')
-rw-r--r--database/sqlite/sqlite_db_migration.c116
1 files changed, 102 insertions, 14 deletions
diff --git a/database/sqlite/sqlite_db_migration.c b/database/sqlite/sqlite_db_migration.c
index 9c7235fdb..1a6233fce 100644
--- a/database/sqlite/sqlite_db_migration.c
+++ b/database/sqlite/sqlite_db_migration.c
@@ -11,7 +11,6 @@ static int return_int_cb(void *data, int argc, char **argv, char **column)
return 0;
}
-
int table_exists_in_database(const char *table)
{
char *err_msg = NULL;
@@ -23,7 +22,7 @@ int table_exists_in_database(const char *table)
int rc = sqlite3_exec_monitored(db_meta, sql, return_int_cb, (void *) &exists, &err_msg);
if (rc != SQLITE_OK) {
- info("Error checking table existence; %s", err_msg);
+ netdata_log_info("Error checking table existence; %s", err_msg);
sqlite3_free(err_msg);
}
@@ -41,7 +40,7 @@ static int column_exists_in_table(const char *table, const char *column)
int rc = sqlite3_exec_monitored(db_meta, sql, return_int_cb, (void *) &exists, &err_msg);
if (rc != SQLITE_OK) {
- info("Error checking column existence; %s", err_msg);
+ netdata_log_info("Error checking column existence; %s", err_msg);
sqlite3_free(err_msg);
}
@@ -79,11 +78,15 @@ const char *database_migrate_v5_v6[] = {
NULL
};
+const char *database_migrate_v9_v10[] = {
+ "ALTER TABLE alert_hash ADD chart_labels TEXT;",
+ NULL
+};
static int do_migration_v1_v2(sqlite3 *database, const char *name)
{
UNUSED(name);
- info("Running \"%s\" database migration", name);
+ netdata_log_info("Running \"%s\" database migration", name);
if (table_exists_in_database("host") && !column_exists_in_table("host", "hops"))
return init_database_batch(database, DB_CHECK_NONE, 0, &database_migrate_v1_v2[0]);
@@ -93,7 +96,7 @@ static int do_migration_v1_v2(sqlite3 *database, const char *name)
static int do_migration_v2_v3(sqlite3 *database, const char *name)
{
UNUSED(name);
- info("Running \"%s\" database migration", name);
+ netdata_log_info("Running \"%s\" database migration", name);
if (table_exists_in_database("host") && !column_exists_in_table("host", "memory_mode"))
return init_database_batch(database, DB_CHECK_NONE, 0, &database_migrate_v2_v3[0]);
@@ -103,7 +106,7 @@ static int do_migration_v2_v3(sqlite3 *database, const char *name)
static int do_migration_v3_v4(sqlite3 *database, const char *name)
{
UNUSED(name);
- info("Running database migration %s", name);
+ netdata_log_info("Running database migration %s", name);
char sql[256];
@@ -135,7 +138,7 @@ static int do_migration_v3_v4(sqlite3 *database, const char *name)
static int do_migration_v4_v5(sqlite3 *database, const char *name)
{
UNUSED(name);
- info("Running \"%s\" database migration", name);
+ netdata_log_info("Running \"%s\" database migration", name);
return init_database_batch(database, DB_CHECK_NONE, 0, &database_migrate_v4_v5[0]);
}
@@ -143,7 +146,7 @@ static int do_migration_v4_v5(sqlite3 *database, const char *name)
static int do_migration_v5_v6(sqlite3 *database, const char *name)
{
UNUSED(name);
- info("Running \"%s\" database migration", name);
+ netdata_log_info("Running \"%s\" database migration", name);
return init_database_batch(database, DB_CHECK_NONE, 0, &database_migrate_v5_v6[0]);
}
@@ -151,7 +154,7 @@ static int do_migration_v5_v6(sqlite3 *database, const char *name)
static int do_migration_v6_v7(sqlite3 *database, const char *name)
{
UNUSED(name);
- info("Running \"%s\" database migration", name);
+ netdata_log_info("Running \"%s\" database migration", name);
char sql[256];
@@ -185,7 +188,7 @@ static int do_migration_v6_v7(sqlite3 *database, const char *name)
static int do_migration_v7_v8(sqlite3 *database, const char *name)
{
UNUSED(name);
- info("Running database migration %s", name);
+ netdata_log_info("Running database migration %s", name);
char sql[256];
@@ -214,12 +217,95 @@ static int do_migration_v7_v8(sqlite3 *database, const char *name)
return 0;
}
+static int do_migration_v8_v9(sqlite3 *database, const char *name)
+{
+ netdata_log_info("Running database migration %s", name);
+
+ char sql[2048];
+ int rc;
+ sqlite3_stmt *res = NULL;
+
+ //create the health_log table and it's index
+ snprintfz(sql, 2047, "CREATE TABLE IF NOT EXISTS health_log (health_log_id INTEGER PRIMARY KEY, host_id blob, alarm_id int, " \
+ "config_hash_id blob, name text, chart text, family text, recipient text, units text, exec text, " \
+ "chart_context text, last_transition_id blob, UNIQUE (host_id, alarm_id)) ;");
+ sqlite3_exec_monitored(database, sql, 0, 0, NULL);
+
+ //TODO indexes
+ snprintfz(sql, 2047, "CREATE INDEX IF NOT EXISTS health_log_ind_1 ON health_log (host_id);");
+ sqlite3_exec_monitored(database, sql, 0, 0, NULL);
+
+ snprintfz(sql, 2047, "CREATE TABLE IF NOT EXISTS health_log_detail (health_log_id int, unique_id int, alarm_id int, alarm_event_id int, " \
+ "updated_by_id int, updates_id int, when_key int, duration int, non_clear_duration int, " \
+ "flags int, exec_run_timestamp int, delay_up_to_timestamp int, " \
+ "info text, exec_code int, new_status real, old_status real, delay int, " \
+ "new_value double, old_value double, last_repeat int, transition_id blob, global_id int, host_id blob);");
+ sqlite3_exec_monitored(database, sql, 0, 0, NULL);
+
+ snprintfz(sql, 2047, "CREATE INDEX IF NOT EXISTS health_log_d_ind_1 ON health_log_detail (unique_id);");
+ sqlite3_exec_monitored(database, sql, 0, 0, NULL);
+ snprintfz(sql, 2047, "CREATE INDEX IF NOT EXISTS health_log_d_ind_2 ON health_log_detail (global_id);");
+ sqlite3_exec_monitored(database, sql, 0, 0, NULL);
+ snprintfz(sql, 2047, "CREATE INDEX IF NOT EXISTS health_log_d_ind_3 ON health_log_detail (transition_id);");
+ sqlite3_exec_monitored(database, sql, 0, 0, NULL);
+ snprintfz(sql, 2047, "CREATE INDEX IF NOT EXISTS health_log_d_ind_4 ON health_log_detail (health_log_id);");
+ sqlite3_exec_monitored(database, sql, 0, 0, NULL);
+
+ snprintfz(sql, 2047, "ALTER TABLE alert_hash ADD source text;");
+ sqlite3_exec_monitored(database, sql, 0, 0, NULL);
+
+ snprintfz(sql, 2047, "CREATE INDEX IF NOT EXISTS alert_hash_index ON alert_hash (hash_id);");
+ sqlite3_exec_monitored(database, sql, 0, 0, NULL);
+
+ snprintfz(sql, 2047, "SELECT name FROM sqlite_schema WHERE type ='table' AND name LIKE 'health_log_%%' AND name <> 'health_log_detail';");
+ rc = sqlite3_prepare_v2(database, sql, -1, &res, 0);
+ if (rc != SQLITE_OK) {
+ error_report("Failed to prepare statement to alter health_log tables");
+ return 1;
+ }
+
+ DICTIONARY *dict_tables = dictionary_create(DICT_OPTION_NONE);
+
+ while (sqlite3_step_monitored(res) == SQLITE_ROW) {
+ char *table = strdupz((char *) sqlite3_column_text(res, 0));
+ if (health_migrate_old_health_log_table(table)) {
+ dictionary_set(dict_tables, table, NULL, 0);
+ }
+ freez(table);
+ }
+
+ rc = sqlite3_finalize(res);
+ if (unlikely(rc != SQLITE_OK))
+ error_report("Failed to finalize statement when copying health_log tables, rc = %d", rc);
+
+ char *table = NULL;
+ dfe_start_read(dict_tables, table) {
+ sql_drop_table(table_dfe.name);
+ }
+ dfe_done(table);
+ dictionary_destroy(dict_tables);
+
+ snprintfz(sql, 2047, "ALTER TABLE health_log_detail DROP COLUMN host_id;");
+ sqlite3_exec_monitored(database, sql, 0, 0, NULL);
+
+ return 0;
+}
+
+static int do_migration_v9_v10(sqlite3 *database, const char *name)
+{
+ UNUSED(name);
+ netdata_log_info("Running \"%s\" database migration", name);
+
+ if (table_exists_in_database("alert_hash") && !column_exists_in_table("alert_hash", "chart_labels"))
+ return init_database_batch(database, DB_CHECK_NONE, 0, &database_migrate_v9_v10[0]);
+ return 0;
+}
static int do_migration_noop(sqlite3 *database, const char *name)
{
UNUSED(database);
UNUSED(name);
- info("Running database migration %s", name);
+ netdata_log_info("Running database migration %s", name);
return 0;
}
@@ -236,16 +322,16 @@ static int migrate_database(sqlite3 *database, int target_version, char *db_name
int rc = sqlite3_exec_monitored(database, "PRAGMA user_version;", return_int_cb, (void *) &user_version, &err_msg);
if (rc != SQLITE_OK) {
- info("Error checking the %s database version; %s", db_name, err_msg);
+ netdata_log_info("Error checking the %s database version; %s", db_name, err_msg);
sqlite3_free(err_msg);
}
if (likely(user_version == target_version)) {
- info("%s database version is %d (no migration needed)", db_name, target_version);
+ netdata_log_info("%s database version is %d (no migration needed)", db_name, target_version);
return target_version;
}
- info("Database version is %d, current version is %d. Running migration for %s ...", user_version, target_version, db_name);
+ netdata_log_info("Database version is %d, current version is %d. Running migration for %s ...", user_version, target_version, db_name);
for (int i = user_version; i < target_version && migration_list[i].func; i++) {
rc = (migration_list[i].func)(database, migration_list[i].name);
if (unlikely(rc)) {
@@ -266,6 +352,8 @@ DATABASE_FUNC_MIGRATION_LIST migration_action[] = {
{.name = "v5 to v6", .func = do_migration_v5_v6},
{.name = "v6 to v7", .func = do_migration_v6_v7},
{.name = "v7 to v8", .func = do_migration_v7_v8},
+ {.name = "v8 to v9", .func = do_migration_v8_v9},
+ {.name = "v9 to v10", .func = do_migration_v9_v10},
// the terminator of this array
{.name = NULL, .func = NULL}
};
generated by cgit v1.2.3 (git 2.39.1) at 2024-06-07 19:21:31 +0000