Function create_sqlmaster_record

db/sqlglue.c:1860–2053

This creates SQL statements that correspond to a table's schema. These statements are used to bootstrap sqlite. */

/* This creates SQL statements that correspond to a table's schema. These
   statements are used to bootstrap sqlite. */
static int create_sqlmaster_record(struct dbtable *tbl, void *tran)
{
    int field;
    char namebuf[128];
    char *tablename = tbl->sqlaliasname ? tbl->sqlaliasname : tbl->tablename;

    struct schema *schema = tbl->schema;
    if (schema == NULL) {
        logmsg(LOGMSG_ERROR, "No .ONDISK tag for table %s.\n", tablename);
        return -1;
    }

    if (is_sqlite_stat(tablename)) {
        create_sqlite_stat_sqlmaster_record(tbl);
        return 0;
    }

    strbuf *sql = strbuf_new();
    strbuf_clear(sql);
    strbuf_appendf(sql, "create table \"%s\"(", tablename);

    /* Fields */
    for (field = 0; field < schema->nmembers; field++) {
        char *type = sqltype(&schema->member[field], namebuf, sizeof(namebuf));
        if (type == NULL) {
            logmsg(LOGMSG_ERROR,
                   "Unsupported type in schema: column '%s' [%d] "
                   "table %s\n",
                   schema->member[field].name, field, tablename);
            strbuf_free(sql);
            return -1;
        }
        strbuf_appendf(sql, "\"%s\" %s", schema->member[field].name, type);
        /* add defaults for write sql */
        if (schema->member[field].in_default) {
            strbuf_append(sql, " DEFAULT");
            char *dstr = sql_field_default_trans(&schema->member[field], 0);

            if (dstr) {
                strbuf_appendf(sql, " %s", dstr);
                sqlite3_free(dstr);
            } else {
                logmsg(LOGMSG_ERROR,
                       "Failed to convert default value column '%s' table "
                       "%s type %d\n",
                       schema->member[field].name, tablename,
                       schema->member[field].type);
                strbuf_free(sql);
                return -1;
            }
        }

        if (field != schema->nmembers - 1)
            strbuf_append(sql, ", ");
    }

    /* CHECK constraints */
    for (int i = 0; i < tbl->n_check_constraints; i++) {