Adding upstream version 1.29.0.upstream/1.29.0

Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>

1 files changed, 1022 insertions, 0 deletions

diff --git a/database/sqlite/sqlite_functions.c b/database/sqlite/sqlite_functions.c
new file mode 100644
index 000000000..ab6c59cfa
--- /dev/null
+++ b/database/sqlite/sqlite_functions.c
@@ -0,0 +1,1022 @@
+// SPDX-License-Identifier: GPL-3.0-or-later
+
+#include "sqlite_functions.h"
+
+const char *database_config[] = {
+    "PRAGMA auto_vacuum=incremental; PRAGMA synchronous=1 ; PRAGMA journal_mode=WAL; PRAGMA temp_store=MEMORY;",
+    "PRAGMA journal_size_limit=16777216;",
+    "CREATE TABLE IF NOT EXISTS host(host_id blob PRIMARY KEY, hostname text, "
+    "registry_hostname text, update_every int, os text, timezone text, tags text);",
+    "CREATE TABLE IF NOT EXISTS chart(chart_id blob PRIMARY KEY, host_id blob, type text, id text, name text, "
+    "family text, context text, title text, unit text, plugin text, module text, priority int, update_every int, "
+    "chart_type int, memory_mode int, history_entries);",
+    "CREATE TABLE IF NOT EXISTS dimension(dim_id blob PRIMARY KEY, chart_id blob, id text, name text, "
+    "multiplier int, divisor int , algorithm int, options text);",
+    "CREATE TABLE IF NOT EXISTS chart_active(chart_id blob PRIMARY KEY, date_created int);",
+    "CREATE TABLE IF NOT EXISTS dimension_active(dim_id blob primary key, date_created int);",
+    "CREATE TABLE IF NOT EXISTS metadata_migration(filename text, file_size, date_created int);",
+    "CREATE INDEX IF NOT EXISTS ind_d1 on dimension (chart_id, id, name);",
+    "CREATE INDEX IF NOT EXISTS ind_c1 on chart (host_id, id, type, name);",
+
+    "delete from chart_active;",
+    "delete from dimension_active;",
+
+    "delete from chart where chart_id not in (select chart_id from dimension);",
+    "delete from host where host_id not in (select host_id from chart);",
+    NULL
+};
+
+sqlite3 *db_meta = NULL;
+
+static uv_mutex_t sqlite_transaction_lock;
+
+static int execute_insert(sqlite3_stmt *res)
+{
+    int rc;
+
+    while ((rc = sqlite3_step(res)) != SQLITE_DONE && unlikely(netdata_exit)) {
+        if (likely(rc == SQLITE_BUSY || rc == SQLITE_LOCKED))
+            usleep(SQLITE_INSERT_DELAY * USEC_PER_MS);
+        else {
+            error_report("SQLite error %d", rc);
+            break;
+        }
+    }
+
+    return rc;
+}
+
+/*
+ * Store a chart or dimension UUID in  chart_active or dimension_active
+ * The statement that will be prepared determines that
+ */
+
+static int store_active_uuid_object(sqlite3_stmt **res, char *statement, uuid_t *uuid)
+{
+    int rc;
+
+    // Check if we should need to prepare the statement
+    if (!*res) {
+        rc = sqlite3_prepare_v2(db_meta, statement, -1, res, 0);
+        if (unlikely(rc != SQLITE_OK)) {
+            error_report("Failed to prepare statement to store active object, rc = %d", rc);
+            return rc;
+        }
+    }
+
+    rc = sqlite3_bind_blob(*res, 1, uuid, sizeof(*uuid), SQLITE_STATIC);
+    if (unlikely(rc != SQLITE_OK))
+        error_report("Failed to bind input parameter to store active object, rc = %d", rc);
+    else
+        rc = execute_insert(*res);
+    return rc;
+}
+
+/*
+ * Marks a chart with UUID as active
+ * Input: UUID
+ */
+void store_active_chart(uuid_t *chart_uuid)
+{
+    sqlite3_stmt *res = NULL;
+    int rc;
+
+    if (unlikely(!db_meta)) {
+        error_report("Database has not been initialized");
+        return;
+    }
+
+    if (unlikely(!chart_uuid))
+        return;
+
+    rc = store_active_uuid_object(&res, SQL_STORE_ACTIVE_CHART, chart_uuid);
+    if (rc != SQLITE_DONE)
+        error_report("Failed to store active chart, rc = %d", rc);
+
+    rc = sqlite3_finalize(res);
+    if (unlikely(rc != SQLITE_OK))
+        error_report("Failed to finalize statement in store active chart, rc = %d", rc);
+    return;
+}
+
+/*
+ * Marks a dimension with UUID as active
+ * Input: UUID
+ */
+void store_active_dimension(uuid_t *dimension_uuid)
+{
+    sqlite3_stmt *res = NULL;
+    int rc;
+
+    if (unlikely(!db_meta)) {
+        error_report("Database has not been initialized");
+        return;
+    }
+
+    if (unlikely(!dimension_uuid))
+        return;
+
+    rc = store_active_uuid_object(&res, SQL_STORE_ACTIVE_DIMENSION, dimension_uuid);
+    if (rc != SQLITE_DONE)
+        error_report("Failed to store active dimension, rc = %d", rc);
+
+    rc = sqlite3_finalize(res);
+    if (unlikely(rc != SQLITE_OK))
+        error_report("Failed to finalize statement in store active dimension, rc = %d", rc);
+    return;
+}
+
+/*
+ * Initialize the SQLite database
+ * Return 0 on success
+ */
+int sql_init_database(void)
+{
+    char *err_msg = NULL;
+    char sqlite_database[FILENAME_MAX + 1];
+    int rc;
+
+    fatal_assert(0 == uv_mutex_init(&sqlite_transaction_lock));
+
+    snprintfz(sqlite_database, FILENAME_MAX, "%s/netdata-meta.db", netdata_configured_cache_dir);
+    rc = sqlite3_open(sqlite_database, &db_meta);
+    if (rc != SQLITE_OK) {
+        error_report("Failed to initialize database at %s", sqlite_database);
+        return 1;
+    }
+
+    info("SQLite database %s initialization", sqlite_database);
+
+    for (int i = 0; database_config[i]; i++) {
+        debug(D_METADATALOG, "Executing %s", database_config[i]);
+        rc = sqlite3_exec(db_meta, database_config[i], 0, 0, &err_msg);
+        if (rc != SQLITE_OK) {
+            error_report("SQLite error during database setup, rc = %d (%s)", rc, err_msg);
+            error_report("SQLite failed statement %s", database_config[i]);
+            sqlite3_free(err_msg);
+            return 1;
+        }
+    }
+    info("SQLite database initialization completed");
+    return 0;
+}
+
+/*
+ * Close the sqlite database
+ */
+
+void sql_close_database(void)
+{
+    int rc;
+    if (unlikely(!db_meta))
+        return;
+
+    info("Closing SQLite database");
+    rc = sqlite3_close(db_meta);
+    if (unlikely(rc != SQLITE_OK))
+        error_report("Error %d while closing the SQLite database", rc);
+    return;
+}
+
+#define FIND_UUID_TYPE  "select 1 from host where host_id = @uuid union select 2 from chart where chart_id = @uuid union select 3 from dimension where dim_id = @uuid;"
+
+int find_uuid_type(uuid_t *uuid)
+{
+    static __thread sqlite3_stmt *res = NULL;
+    int rc;
+    int uuid_type = 3;
+
+    if (unlikely(!res)) {
+        rc = sqlite3_prepare_v2(db_meta, FIND_UUID_TYPE, -1, &res, 0);
+        if (rc != SQLITE_OK) {
+            error_report("Failed to bind prepare statement to find UUID type in the database");
+            return 0;
+        }
+    }
+
+    rc = sqlite3_bind_blob(res, 1, uuid, sizeof(*uuid), SQLITE_STATIC);
+    if (unlikely(rc != SQLITE_OK))
+        goto bind_fail;
+
+    rc = sqlite3_step(res);
+    if (likely(rc == SQLITE_ROW))
+        uuid_type = sqlite3_column_int(res, 0);
+
+    rc = sqlite3_reset(res);
+    if (unlikely(rc != SQLITE_OK))
+        error_report("Failed to reset statement during find uuid type, rc = %d", rc);
+
+    return uuid_type;
+
+bind_fail:
+    return 0;
+}
+
+uuid_t *find_dimension_uuid(RRDSET *st, RRDDIM *rd)
+{
+    static __thread sqlite3_stmt *res = NULL;
+    uuid_t *uuid = NULL;
+    int rc;
+
+    if (unlikely(!res)) {
+        rc = sqlite3_prepare_v2(db_meta, SQL_FIND_DIMENSION_UUID, -1, &res, 0);
+        if (rc != SQLITE_OK) {
+            error_report("Failed to bind prepare statement to lookup dimension UUID in the database");
+            return NULL;
+        }
+    }
+
+    rc = sqlite3_bind_blob(res, 1, st->chart_uuid, sizeof(*st->chart_uuid), SQLITE_STATIC);
+    if (unlikely(rc != SQLITE_OK))
+        goto bind_fail;
+
+    rc = sqlite3_bind_text(res, 2, rd->id, -1, SQLITE_STATIC);
+    if (unlikely(rc != SQLITE_OK))
+        goto bind_fail;
+
+    rc = sqlite3_bind_text(res, 3, rd->name, -1, SQLITE_STATIC);
+    if (unlikely(rc != SQLITE_OK))
+        goto bind_fail;
+
+    rc = sqlite3_step(res);
+    if (likely(rc == SQLITE_ROW)) {
+        uuid = mallocz(sizeof(uuid_t));
+        uuid_copy(*uuid, sqlite3_column_blob(res, 0));
+    }
+
+    rc = sqlite3_reset(res);
+    if (unlikely(rc != SQLITE_OK))
+        error_report("Failed to reset statement find dimension uuid, rc = %d", rc);
+
+#ifdef NETDATA_INTERNAL_CHECKS
+    char  uuid_str[GUID_LEN + 1];
+    if (likely(uuid)) {
+        uuid_unparse_lower(*uuid, uuid_str);
+        debug(D_METADATALOG, "Found UUID %s for dimension %s", uuid_str, rd->name);
+    }
+    else
+        debug(D_METADATALOG, "UUID not found for dimension %s", rd->name);
+#endif
+    return uuid;
+
+bind_fail:
+    error_report("Failed to bind input parameter to perform dimension UUID database lookup, rc = %d", rc);
+    return NULL;
+}
+
+uuid_t *create_dimension_uuid(RRDSET *st, RRDDIM *rd)
+{
+    uuid_t *uuid = NULL;
+    int rc;
+
+    uuid = mallocz(sizeof(uuid_t));
+    uuid_generate(*uuid);
+
+#ifdef NETDATA_INTERNAL_CHECKS
+    char uuid_str[GUID_LEN + 1];
+    uuid_unparse_lower(*uuid, uuid_str);
+    debug(D_METADATALOG,"Generating uuid [%s] for dimension %s under chart %s", uuid_str, rd->name, st->id);
+#endif
+
+    rc = sql_store_dimension(uuid, st->chart_uuid, rd->id, rd->name, rd->multiplier, rd->divisor, rd->algorithm);
+    if (unlikely(rc))
+       error_report("Failed to store dimension metadata in the database");
+
+    return uuid;
+}
+
+#define DELETE_DIMENSION_UUID   "delete from dimension where dim_id = @uuid;"
+
+void delete_dimension_uuid(uuid_t *dimension_uuid)
+{
+    static __thread sqlite3_stmt *res = NULL;
+    int rc;
+
+#ifdef NETDATA_INTERNAL_CHECKS
+    char uuid_str[GUID_LEN + 1];
+    uuid_unparse_lower(*dimension_uuid, uuid_str);
+    debug(D_METADATALOG,"Deleting dimension uuid %s", uuid_str);
+#endif
+
+    if (unlikely(!res)) {
+        rc = sqlite3_prepare_v2(db_meta, DELETE_DIMENSION_UUID, -1, &res, 0);
+        if (rc != SQLITE_OK) {
+            error_report("Failed to prepare statement to delete a dimension uuid");
+            return;
+        }
+    }
+
+    rc = sqlite3_bind_blob(res, 1, dimension_uuid,  sizeof(*dimension_uuid), SQLITE_STATIC);
+    if (unlikely(rc != SQLITE_OK))
+        goto bind_fail;
+
+    rc = sqlite3_step(res);
+    if (unlikely(rc != SQLITE_DONE))
+        error_report("Failed to delete dimension uuid, rc = %d", rc);
+
+bind_fail:
+    rc = sqlite3_reset(res);
+    if (unlikely(rc != SQLITE_OK))
+        error_report("Failed to reset statement when deleting dimension UUID, rc = %d", rc);
+    return;
+}
+
+/*
+ * Do a database lookup to find the UUID of a chart
+ *
+ */
+uuid_t *find_chart_uuid(RRDHOST *host, const char *type, const char *id, const char *name)
+{
+    static __thread sqlite3_stmt *res = NULL;
+    uuid_t *uuid = NULL;
+    int rc;
+
+    if (unlikely(!res)) {
+        rc = sqlite3_prepare_v2(db_meta, SQL_FIND_CHART_UUID, -1, &res, 0);
+        if (rc != SQLITE_OK) {
+            error_report("Failed to prepare statement to lookup chart UUID in the database");
+            return NULL;
+        }
+    }
+
+    rc = sqlite3_bind_blob(res, 1, &host->host_uuid, sizeof(host->host_uuid), SQLITE_STATIC);
+    if (unlikely(rc != SQLITE_OK))
+            goto bind_fail;
+
+    rc = sqlite3_bind_text(res, 2, type, -1, SQLITE_STATIC);
+    if (unlikely(rc != SQLITE_OK))
+        goto bind_fail;
+
+    rc = sqlite3_bind_text(res, 3, id, -1, SQLITE_STATIC);
+    if (unlikely(rc != SQLITE_OK))
+        goto bind_fail;
+
+    rc = sqlite3_bind_text(res, 4, name ? name : id, -1, SQLITE_STATIC);
+    if (unlikely(rc != SQLITE_OK))
+        goto bind_fail;
+
+    rc = sqlite3_step(res);
+    if (likely(rc == SQLITE_ROW)) {
+        uuid = mallocz(sizeof(uuid_t));
+        uuid_copy(*uuid, sqlite3_column_blob(res, 0));
+    }
+
+    rc = sqlite3_reset(res);
+    if (unlikely(rc != SQLITE_OK))
+        error_report("Failed to reset statement when searching for a chart UUID, rc = %d", rc);
+
+#ifdef NETDATA_INTERNAL_CHECKS
+    char  uuid_str[GUID_LEN + 1];
+    if (likely(uuid)) {
+        uuid_unparse_lower(*uuid, uuid_str);
+        debug(D_METADATALOG, "Found UUID %s for chart %s.%s", uuid_str, type, name ? name : id);
+    }
+    else
+        debug(D_METADATALOG, "UUID not found for chart %s.%s", type, name ? name : id);
+#endif
+    return uuid;
+
+bind_fail:
+    error_report("Failed to bind input parameter to perform chart UUID database lookup, rc = %d", rc);
+    rc = sqlite3_reset(res);
+    if (unlikely(rc != SQLITE_OK))
+        error_report("Failed to reset statement when searching for a chart UUID, rc = %d", rc);
+    return NULL;
+}
+
+int update_chart_metadata(uuid_t *chart_uuid, RRDSET *st, const char *id, const char *name)
+{
+    int rc;
+
+    rc = sql_store_chart(
+        chart_uuid, &st->rrdhost->host_uuid, st->type, id, name, st->family, st->context, st->title, st->units, st->plugin_name,
+        st->module_name, st->priority, st->update_every, st->chart_type, st->rrd_memory_mode, st->entries);
+
+    return rc;
+}
+
+uuid_t *create_chart_uuid(RRDSET *st, const char *id, const char *name)
+{
+    uuid_t *uuid = NULL;
+    int rc;
+
+    uuid = mallocz(sizeof(uuid_t));
+    uuid_generate(*uuid);
+
+#ifdef NETDATA_INTERNAL_CHECKS
+    char uuid_str[GUID_LEN + 1];
+    uuid_unparse_lower(*uuid, uuid_str);
+    debug(D_METADATALOG,"Generating uuid [%s] for chart %s under host %s", uuid_str, st->id, st->rrdhost->hostname);
+#endif
+
+    rc = update_chart_metadata(uuid, st, id, name);
+
+    if (unlikely(rc))
+        error_report("Failed to store chart metadata in the database");
+
+    return uuid;
+}
+
+// Functions to create host, chart, dimension in the database
+
+int sql_store_host(
+    uuid_t *host_uuid, const char *hostname, const char *registry_hostname, int update_every, const char *os,
+    const char *tzone, const char *tags)
+{
+    static __thread sqlite3_stmt *res = NULL;
+    int rc;
+
+    if (unlikely(!db_meta)) {
+        error_report("Database has not been initialized");
+        return 1;
+    }
+
+    if (unlikely((!res))) {
+        rc = sqlite3_prepare_v2(db_meta, SQL_STORE_HOST, -1, &res, 0);
+        if (unlikely(rc != SQLITE_OK)) {
+            error_report("Failed to prepare statement to store host, rc = %d", rc);
+            return 1;
+        }
+    }
+
+    rc = sqlite3_bind_blob(res, 1, host_uuid, sizeof(*host_uuid), SQLITE_STATIC);
+    if (unlikely(rc != SQLITE_OK))
+        goto bind_fail;
+
+    rc = sqlite3_bind_text(res, 2, hostname, -1, SQLITE_STATIC);
+    if (unlikely(rc != SQLITE_OK))
+        goto bind_fail;
+
+    rc = sqlite3_bind_text(res, 3, registry_hostname, -1, SQLITE_STATIC);
+    if (unlikely(rc != SQLITE_OK))
+        goto bind_fail;
+
+    rc = sqlite3_bind_int(res, 4, update_every);
+    if (unlikely(rc != SQLITE_OK))
+        goto bind_fail;
+
+    rc = sqlite3_bind_text(res, 5, os, -1, SQLITE_STATIC);
+    if (unlikely(rc != SQLITE_OK))
+        goto bind_fail;
+
+    rc = sqlite3_bind_text(res, 6, tzone, -1, SQLITE_STATIC);
+    if (unlikely(rc != SQLITE_OK))
+        goto bind_fail;
+
+    rc = sqlite3_bind_text(res, 7, tags, -1, SQLITE_STATIC);
+    if (unlikely(rc != SQLITE_OK))
+        goto bind_fail;
+
+    int store_rc = sqlite3_step(res);
+    if (unlikely(store_rc != SQLITE_DONE))
+        error_report("Failed to store host %s, rc = %d", hostname, rc);
+
+    rc = sqlite3_reset(res);
+    if (unlikely(rc != SQLITE_OK))
+        error_report("Failed to reset statement to store host %s, rc = %d", hostname, rc);
+
+    return !(store_rc == SQLITE_DONE);
+bind_fail:
+    error_report("Failed to bind parameter to store host %s, rc = %d", hostname, rc);
+    rc = sqlite3_reset(res);
+    if (unlikely(rc != SQLITE_OK))
+        error_report("Failed to reset statement to store host %s, rc = %d", hostname, rc);
+    return 1;
+}
+
+/*
+ * Store a chart in the database
+ */
+
+int sql_store_chart(
+    uuid_t *chart_uuid, uuid_t *host_uuid, const char *type, const char *id, const char *name, const char *family,
+    const char *context, const char *title, const char *units, const char *plugin, const char *module, long priority,
+    int update_every, int chart_type, int memory_mode, long history_entries)
+{
+    static __thread sqlite3_stmt *res;
+    int rc, param = 0;
+
+    if (unlikely(!db_meta)) {
+        error_report("Database has not been initialized");
+        return 1;
+    }
+
+    if (unlikely(!res)) {
+        rc = sqlite3_prepare_v2(db_meta, SQL_STORE_CHART, -1, &res, 0);
+        if (unlikely(rc != SQLITE_OK)) {
+            error_report("Failed to prepare statement to store chart, rc = %d", rc);
+            return 1;
+        }
+    }
+
+    param++;
+    rc = sqlite3_bind_blob(res, 1, chart_uuid, sizeof(*chart_uuid), SQLITE_STATIC);
+    if (unlikely(rc != SQLITE_OK))
+        goto bind_fail;
+
+    param++;
+    rc = sqlite3_bind_blob(res, 2, host_uuid, sizeof(*host_uuid), SQLITE_STATIC);
+    if (unlikely(rc != SQLITE_OK))
+        goto bind_fail;
+
+    param++;
+    rc = sqlite3_bind_text(res, 3, type, -1, SQLITE_STATIC);
+    if (unlikely(rc != SQLITE_OK))
+        goto bind_fail;
+
+    param++;
+    rc = sqlite3_bind_text(res, 4, id, -1, SQLITE_STATIC);
+    if (unlikely(rc != SQLITE_OK))
+        goto bind_fail;
+
+    param++;
+    if (name) {
+        rc = sqlite3_bind_text(res, 5, name, -1, SQLITE_STATIC);
+        if (unlikely(rc != SQLITE_OK))
+            goto bind_fail;
+    }
+
+    param++;
+    rc = sqlite3_bind_text(res, 6, family, -1, SQLITE_STATIC);
+    if (unlikely(rc != SQLITE_OK))
+        goto bind_fail;
+
+    param++;
+    rc = sqlite3_bind_text(res, 7, context, -1, SQLITE_STATIC);
+    if (unlikely(rc != SQLITE_OK))
+        goto bind_fail;
+
+    param++;
+    rc = sqlite3_bind_text(res, 8, title, -1, SQLITE_STATIC);
+    if (unlikely(rc != SQLITE_OK))
+        goto bind_fail;
+
+    param++;
+    rc = sqlite3_bind_text(res, 9, units, -1, SQLITE_STATIC);
+    if (unlikely(rc != SQLITE_OK))
+        goto bind_fail;
+
+    param++;
+    rc = sqlite3_bind_text(res, 10, plugin, -1, SQLITE_STATIC);
+    if (unlikely(rc != SQLITE_OK))
+        goto bind_fail;
+
+    param++;
+    rc = sqlite3_bind_text(res, 11, module, -1, SQLITE_STATIC);
+    if (unlikely(rc != SQLITE_OK))
+        goto bind_fail;
+
+    param++;
+    rc = sqlite3_bind_int(res, 12, priority);
+    if (unlikely(rc != SQLITE_OK))
+        goto bind_fail;
+
+    param++;
+    rc = sqlite3_bind_int(res, 13, update_every);
+    if (unlikely(rc != SQLITE_OK))
+        goto bind_fail;
+
+    param++;
+    rc = sqlite3_bind_int(res, 14, chart_type);
+    if (unlikely(rc != SQLITE_OK))
+        goto bind_fail;
+
+    param++;
+    rc = sqlite3_bind_int(res, 15, memory_mode);
+    if (unlikely(rc != SQLITE_OK))
+        goto bind_fail;
+
+    param++;
+    rc = sqlite3_bind_int(res, 16, history_entries);
+    if (unlikely(rc != SQLITE_OK))
+        goto bind_fail;
+
+    rc = execute_insert(res);
+    if (unlikely(rc != SQLITE_DONE))
+        error_report("Failed to store chart, rc = %d", rc);
+
+    rc = sqlite3_reset(res);
+    if (unlikely(rc != SQLITE_OK))
+        error_report("Failed to reset statement in chart store function, rc = %d", rc);
+
+    return 0;
+
+bind_fail:
+    error_report("Failed to bind parameter %d to store chart, rc = %d", param, rc);
+    rc = sqlite3_reset(res);
+    if (unlikely(rc != SQLITE_OK))
+        error_report("Failed to reset statement in chart store function, rc = %d", rc);
+    return 1;
+}
+
+/*
+ * Store a dimension
+ */
+int sql_store_dimension(
+    uuid_t *dim_uuid, uuid_t *chart_uuid, const char *id, const char *name, collected_number multiplier,
+    collected_number divisor, int algorithm)
+{
+    static __thread sqlite3_stmt *res = NULL;
+    int rc;
+
+    if (unlikely(!db_meta)) {
+        error_report("Database has not been initialized");
+        return 1;
+    }
+
+    if (unlikely(!res)) {
+        rc = sqlite3_prepare_v2(db_meta, SQL_STORE_DIMENSION, -1, &res, 0);
+        if (unlikely(rc != SQLITE_OK)) {
+            error_report("Failed to prepare statement to store dimension, rc = %d", rc);
+            return 1;
+        }
+    }
+
+    rc = sqlite3_bind_blob(res, 1, dim_uuid, sizeof(*dim_uuid), SQLITE_STATIC);
+    if (unlikely(rc != SQLITE_OK))
+        goto bind_fail;
+
+    rc = sqlite3_bind_blob(res, 2, chart_uuid, sizeof(*chart_uuid), SQLITE_STATIC);
+    if (unlikely(rc != SQLITE_OK))
+        goto bind_fail;
+
+    rc = sqlite3_bind_text(res, 3, id, -1, SQLITE_STATIC);
+    if (unlikely(rc != SQLITE_OK))
+        goto bind_fail;
+
+    rc = sqlite3_bind_text(res, 4, name, -1, SQLITE_STATIC);
+    if (unlikely(rc != SQLITE_OK))
+        goto bind_fail;
+
+    rc = sqlite3_bind_int(res, 5, multiplier);
+    if (unlikely(rc != SQLITE_OK))
+        goto bind_fail;
+
+    rc = sqlite3_bind_int(res, 6, divisor);
+    if (unlikely(rc != SQLITE_OK))
+        goto bind_fail;
+
+    rc = sqlite3_bind_int(res, 7, algorithm);
+    if (unlikely(rc != SQLITE_OK))
+        goto bind_fail;
+
+    rc = execute_insert(res);
+    if (unlikely(rc != SQLITE_DONE))
+        error_report("Failed to store dimension, rc = %d", rc);
+
+    rc = sqlite3_reset(res);
+    if (unlikely(rc != SQLITE_OK))
+        error_report("Failed to reset statement in store dimension, rc = %d", rc);
+    return 0;
+
+bind_fail:
+    error_report("Failed to bind parameter to store dimension, rc = %d", rc);
+    rc = sqlite3_reset(res);
+    if (unlikely(rc != SQLITE_OK))
+        error_report("Failed to reset statement in store dimension, rc = %d", rc);
+    return 1;
+}
+
+
+//
+// Support for archived charts
+//
+#define SELECT_DIMENSION "select d.id, d.name from dimension d where d.chart_id = @chart_uuid;"
+
+void sql_rrdim2json(sqlite3_stmt *res_dim, uuid_t *chart_uuid, BUFFER *wb, size_t *dimensions_count)
+{
+    int rc;
+
+    rc = sqlite3_bind_blob(res_dim, 1, chart_uuid, sizeof(*chart_uuid), SQLITE_STATIC);
+    if (rc != SQLITE_OK)
+        return;
+
+    int dimensions = 0;
+    buffer_sprintf(wb, "\t\t\t\"dimensions\": {\n");
+
+    while (sqlite3_step(res_dim) == SQLITE_ROW) {
+        if (dimensions)
+            buffer_strcat(wb, ",\n\t\t\t\t\"");
+        else
+            buffer_strcat(wb, "\t\t\t\t\"");
+        buffer_strcat_jsonescape(wb, (const char *) sqlite3_column_text(res_dim, 0));
+        buffer_strcat(wb, "\": { \"name\": \"");
+        buffer_strcat_jsonescape(wb, (const char *) sqlite3_column_text(res_dim, 1));
+        buffer_strcat(wb, "\" }");
+        dimensions++;
+    }
+    *dimensions_count += dimensions;
+    buffer_sprintf(wb, "\n\t\t\t}");
+}
+
+#define SELECT_CHART "select chart_id, id, name, type, family, context, title, priority, plugin, " \
+    "module, unit, chart_type, update_every from chart " \
+    "where host_id = @host_uuid and chart_id not in (select chart_id from chart_active) order by chart_id asc;"
+
+void sql_rrdset2json(RRDHOST *host, BUFFER *wb)
+{
+    //    time_t first_entry_t = 0; //= rrdset_first_entry_t(st);
+    //   time_t last_entry_t = 0; //rrdset_last_entry_t(st);
+    static char *custom_dashboard_info_js_filename = NULL;
+    int rc;
+
+    sqlite3_stmt *res_chart = NULL;
+    sqlite3_stmt *res_dim = NULL;
+    time_t now = now_realtime_sec();
+
+    rc = sqlite3_prepare_v2(db_meta, SELECT_CHART, -1, &res_chart, 0);
+    if (unlikely(rc != SQLITE_OK)) {
+        error_report("Failed to prepare statement to fetch host archived charts");
+        return;
+    }
+
+    rc = sqlite3_bind_blob(res_chart, 1, &host->host_uuid, sizeof(host->host_uuid), SQLITE_STATIC);
+    if (unlikely(rc != SQLITE_OK)) {
+        error_report("Failed to bind host parameter to fetch archived charts");
+        return;
+    }
+
+    rc = sqlite3_prepare_v2(db_meta, SELECT_DIMENSION, -1, &res_dim, 0);
+    if (unlikely(rc != SQLITE_OK)) {
+        error_report("Failed to prepare statement to fetch chart archived dimensions");
+        goto failed;
+    };
+
+    if(unlikely(!custom_dashboard_info_js_filename))
+        custom_dashboard_info_js_filename = config_get(CONFIG_SECTION_WEB, "custom dashboard_info.js", "");
+
+    buffer_sprintf(wb, "{\n"
+                       "\t\"hostname\": \"%s\""
+                       ",\n\t\"version\": \"%s\""
+                       ",\n\t\"release_channel\": \"%s\""
+                       ",\n\t\"os\": \"%s\""
+                       ",\n\t\"timezone\": \"%s\""
+                       ",\n\t\"update_every\": %d"
+                       ",\n\t\"history\": %ld"
+                       ",\n\t\"memory_mode\": \"%s\""
+                       ",\n\t\"custom_info\": \"%s\""
+                       ",\n\t\"charts\": {"
+        , host->hostname
+        , host->program_version
+        , get_release_channel()
+        , host->os
+        , host->timezone
+        , host->rrd_update_every
+        , host->rrd_history_entries
+        , rrd_memory_mode_name(host->rrd_memory_mode)
+        , custom_dashboard_info_js_filename
+    );
+
+    size_t c = 0;
+    size_t dimensions = 0;
+
+    while (sqlite3_step(res_chart) == SQLITE_ROW) {
+        char id[512];
+        sprintf(id, "%s.%s", sqlite3_column_text(res_chart, 3), sqlite3_column_text(res_chart, 1));
+        RRDSET *st = rrdset_find(host, id);
+        if (st && !rrdset_flag_check(st, RRDSET_FLAG_ARCHIVED))
+            continue;
+
+        if (c)
+            buffer_strcat(wb, ",\n\t\t\"");
+        else
+            buffer_strcat(wb, "\n\t\t\"");
+        c++;
+
+        buffer_strcat(wb, id);
+        buffer_strcat(wb, "\": ");
+
+        buffer_sprintf(
+            wb,
+            "\t\t{\n"
+            "\t\t\t\"id\": \"%s\",\n"
+            "\t\t\t\"name\": \"%s\",\n"
+            "\t\t\t\"type\": \"%s\",\n"
+            "\t\t\t\"family\": \"%s\",\n"
+            "\t\t\t\"context\": \"%s\",\n"
+            "\t\t\t\"title\": \"%s (%s)\",\n"
+            "\t\t\t\"priority\": %ld,\n"
+            "\t\t\t\"plugin\": \"%s\",\n"
+            "\t\t\t\"module\": \"%s\",\n"
+            "\t\t\t\"enabled\": %s,\n"
+            "\t\t\t\"units\": \"%s\",\n"
+            "\t\t\t\"data_url\": \"/api/v1/data?chart=%s\",\n"
+            "\t\t\t\"chart_type\": \"%s\",\n",
+            id //sqlite3_column_text(res_chart, 1)
+            ,
+            id // sqlite3_column_text(res_chart, 2)
+            ,
+            sqlite3_column_text(res_chart, 3), sqlite3_column_text(res_chart, 4), sqlite3_column_text(res_chart, 5),
+            sqlite3_column_text(res_chart, 6), id //sqlite3_column_text(res_chart, 2)
+            ,
+            (long ) sqlite3_column_int(res_chart, 7),
+            (const char *) sqlite3_column_text(res_chart, 8) ? (const char *) sqlite3_column_text(res_chart, 8) : (char *) "",
+            (const char *) sqlite3_column_text(res_chart, 9) ? (const char *) sqlite3_column_text(res_chart, 9) : (char *) "", (char *) "false",
+            (const char *) sqlite3_column_text(res_chart, 10), id //sqlite3_column_text(res_chart, 2)
+            ,
+            rrdset_type_name(sqlite3_column_int(res_chart, 11)));
+
+        sql_rrdim2json(res_dim, (uuid_t *) sqlite3_column_blob(res_chart, 0), wb, &dimensions);
+
+        rc = sqlite3_reset(res_dim);
+        if (unlikely(rc != SQLITE_OK))
+            error_report("Failed to reset the prepared statement when reading archived chart dimensions");
+        buffer_strcat(wb, "\n\t\t}");
+    }
+
+    buffer_sprintf(wb
+        , "\n\t}"
+          ",\n\t\"charts_count\": %zu"
+          ",\n\t\"dimensions_count\": %zu"
+          ",\n\t\"alarms_count\": %zu"
+          ",\n\t\"rrd_memory_bytes\": %zu"
+          ",\n\t\"hosts_count\": %zu"
+          ",\n\t\"hosts\": ["
+        , c
+        , dimensions
+        , (size_t) 0
+        , (size_t) 0
+        , rrd_hosts_available
+    );
+
+    if(unlikely(rrd_hosts_available > 1)) {
+        rrd_rdlock();
+
+        size_t found = 0;
+        RRDHOST *h;
+        rrdhost_foreach_read(h) {
+            if(!rrdhost_should_be_removed(h, host, now) && !rrdhost_flag_check(h, RRDHOST_FLAG_ARCHIVED)) {
+                buffer_sprintf(wb
+                    , "%s\n\t\t{"
+                      "\n\t\t\t\"hostname\": \"%s\""
+                      "\n\t\t}"
+                    , (found > 0) ? "," : ""
+                    , h->hostname
+                );
+
+                found++;
+            }
+        }
+
+        rrd_unlock();
+    }
+    else {
+        buffer_sprintf(wb
+            , "\n\t\t{"
+              "\n\t\t\t\"hostname\": \"%s\""
+              "\n\t\t}"
+            , host->hostname
+        );
+    }
+
+    buffer_sprintf(wb, "\n\t]\n}\n");
+
+    rc = sqlite3_finalize(res_dim);
+    if (unlikely(rc != SQLITE_OK))
+        error_report("Failed to finalize the prepared statement when reading archived chart dimensions");
+
+failed:
+    rc = sqlite3_finalize(res_chart);
+    if (unlikely(rc != SQLITE_OK))
+        error_report("Failed to finalize the prepared statement when reading archived charts");
+
+    return;
+}
+
+#define SELECT_HOST "select host_id, registry_hostname, update_every, os, timezone, tags from host where hostname = @hostname;"
+
+RRDHOST *sql_create_host_by_uuid(char *hostname)
+{
+    int rc;
+    RRDHOST *host = NULL;
+
+    sqlite3_stmt *res = NULL;
+
+    rc = sqlite3_prepare_v2(db_meta, SELECT_HOST, -1, &res, 0);
+    if (unlikely(rc != SQLITE_OK)) {
+        error_report("Failed to prepare statement to fetch host");
+        return NULL;
+    }
+
+    rc = sqlite3_bind_text(res, 1, hostname, -1, SQLITE_STATIC);
+    if (unlikely(rc != SQLITE_OK)) {
+        error_report("Failed to bind hostname parameter to fetch host information");
+        return NULL;
+    }
+
+    rc = sqlite3_step(res);
+    if (unlikely(rc != SQLITE_ROW)) {
+        error_report("Failed to find hostname %s", hostname);
+        goto failed;
+    }
+
+    char uuid_str[GUID_LEN + 1];
+    uuid_unparse_lower(*((uuid_t *) sqlite3_column_blob(res, 0)), uuid_str);
+
+    host = callocz(1, sizeof(RRDHOST));
+
+    set_host_properties(host, sqlite3_column_int(res, 2), RRD_MEMORY_MODE_DBENGINE, hostname,
+                            (char *) sqlite3_column_text(res, 1), (const char *) uuid_str,
+                        (char *) sqlite3_column_text(res, 3), (char *) sqlite3_column_text(res, 5),
+                        (char *) sqlite3_column_text(res, 4), NULL, NULL);
+
+    uuid_copy(host->host_uuid, *((uuid_t *) sqlite3_column_blob(res, 0)));
+
+    host->system_info = NULL;
+
+failed:
+    rc = sqlite3_finalize(res);
+    if (unlikely(rc != SQLITE_OK))
+        error_report("Failed to finalize the prepared statement when reading host information");
+
+    return host;
+}
+
+void db_execute(char *cmd)
+{
+    int rc;
+    char *err_msg;
+    rc = sqlite3_exec(db_meta, cmd, 0, 0, &err_msg);
+    if (rc != SQLITE_OK) {
+        error_report("Failed to execute '%s', rc = %d (%s)", cmd, rc, err_msg);
+        sqlite3_free(err_msg);
+    }
+
+    return;
+}
+
+void db_lock(void)
+{
+    uv_mutex_lock(&sqlite_transaction_lock);
+    return;
+}
+
+void db_unlock(void)
+{
+    uv_mutex_unlock(&sqlite_transaction_lock);
+    return;
+}
+
+
+#define SELECT_MIGRATED_FILE    "select 1 from metadata_migration where filename = @path;"
+
+int file_is_migrated(char *path)
+{
+    sqlite3_stmt *res = NULL;
+    int rc;
+
+    rc = sqlite3_prepare_v2(db_meta, SELECT_MIGRATED_FILE, -1, &res, 0);
+    if (unlikely(rc != SQLITE_OK)) {
+        error_report("Failed to prepare statement to fetch host");
+        return 0;
+    }
+
+    rc = sqlite3_bind_text(res, 1, path, -1, SQLITE_STATIC);
+    if (unlikely(rc != SQLITE_OK)) {
+        error_report("Failed to bind filename parameter to check migration");
+        return 0;
+    }
+
+    rc = sqlite3_step(res);
+
+    if (unlikely(sqlite3_finalize(res) != SQLITE_OK))
+        error_report("Failed to finalize the prepared statement when checking if metadata file is migrated");
+
+    return (rc == SQLITE_ROW);
+}
+
+#define STORE_MIGRATED_FILE    "insert or replace into metadata_migration (filename, file_size, date_created) " \
+                                "values (@file, @size, strftime('%s'));"
+
+void add_migrated_file(char *path, uint64_t file_size)
+{
+    sqlite3_stmt *res = NULL;
+    int rc;
+
+    rc = sqlite3_prepare_v2(db_meta, STORE_MIGRATED_FILE, -1, &res, 0);
+    if (unlikely(rc != SQLITE_OK)) {
+        error_report("Failed to prepare statement to fetch host");
+        return;
+    }
+
+    rc = sqlite3_bind_text(res, 1, path, -1, SQLITE_STATIC);
+    if (unlikely(rc != SQLITE_OK)) {
+        error_report("Failed to bind filename parameter to store migration information");
+        return;
+    }
+
+    rc = sqlite3_bind_int64(res, 2, file_size);
+    if (unlikely(rc != SQLITE_OK)) {
+        error_report("Failed to bind size parameter to store migration information");
+        return;
+    }
+
+    rc = execute_insert(res);
+    if (unlikely(rc != SQLITE_DONE))
+        error_report("Failed to store migrated file, rc = %d", rc);
+
+    if (unlikely(sqlite3_finalize(res) != SQLITE_OK))
+        error_report("Failed to finalize the prepared statement when checking if metadata file is migrated");
+
+    return;
+}