Function sql_syntax_check

db/sqlglue.c:2245–2334

Force an update on sqlite_master to perform a syntax check for * partial index and CHECK constraint expressions. * Also, used to resolve scalar functions used by the dbtable */

 * Also, used to resolve scalar functions used by the dbtable
 */
int sql_syntax_check(struct ireq *iq, struct dbtable *db)
{
    int rc = 0;
    int resolve_rc = 0;
    sqlite3 *hndl = NULL;
    struct schema_mem sm = {0};
    const char *temp = "select 1 from sqlite_master limit 1";
    char *err = NULL;
    int got_curtran = 0;
    master_entry_t *ents = NULL;
    int nents = 0;

    if (!do_syntax_check(db)) {
        return rc;
    }

    sql_mem_init(NULL);
    thread_memcreate(INDEXES_THREAD_MEMORY);

    rc = create_sqlmaster_record(db, NULL);
    if (rc) {
        logmsg(LOGMSG_ERROR, "%s: failed to create sqlmaster record\n",
               __func__);
        sql_mem_shutdown(NULL);
        return -1;
    }
    ents = create_master_entry_array(&db, 1, thedb->view_hash, &nents);
    if (!ents) {
        logmsg(LOGMSG_ERROR, "%s: failed to create master entries\n", __func__);
        sql_mem_shutdown(NULL);
        return -1;
    }

    struct sqlclntstate clnt;
    start_internal_sql_clnt(&clnt);
    clnt.sql = (char *)temp;

    /* schema_mems is used to pass db->schema to is_comdb2_index_blob so we can
     * mark db->schema->ix_blob if the index expression has blob fields */
    sm.sc = db->schema;
    clnt.verify_indexes = 1;
    clnt.schema_mems = &sm;

    struct sql_thread *sqlthd = start_sql_thread();
    sql_get_query_id(sqlthd);
    clnt.debug_sqlclntstate = pthread_self();
    sqlthd->clnt = &clnt;

    get_copy_rootpages_custom(sqlthd, ents, nents);

    destroy_sqlite_master(ents, nents);

    struct sqlthdstate thd = {0};
    rc = sqlite3_open_serial("db", &hndl, &thd);
    if (rc) {
        logmsg(LOGMSG_ERROR, "%s: sqlite3_open failed\n", __func__);
        goto done;
    }