Function lua_prepare_sql_int

lua/sp.c:2214–2257

}

static int lua_prepare_sql_int(SP sp, const char *sql, sqlite3_stmt **stmt,
                               struct sql_state *rec, int flags)
{
    Lua L = sp->lua;
    int maxRetries = ATOMIC_LOAD32(gbl_lua_prepare_max_retries);
    int nRetry = 0;
    struct errstat err;
    struct sql_state rec_lcl = {0};
    struct sql_state *rec_ptr = rec ? rec : &rec_lcl;
    rec_ptr->sql = sql;

    /* Reset logger. This clears table names (see reqlog_add_table) and
       print events (see reqlog_logv_int) in the logger. */
    reqlog_reset_logger(sp->thd->logger);

retry:
    memset(&err, 0, sizeof(struct errstat));
    if (sp->initial) {
        sp->rc = get_prepared_stmt_try_lock(sp->thd, sp->clnt, rec_ptr, &err, flags | PREPARE_RECREATE);
    } else if (flags & PREPARE_ALLOW_TEMP_DDL) {
        sp->rc = get_prepared_stmt_no_lock(sp->thd, sp->clnt, rec_ptr, &err, flags);
        assert(sp->rc != SQLITE_PERM);
    } else {
        /* NOTE: Only this call can return SQLITE_PERM. */
        sp->rc = get_prepared_stmt_try_lock(sp->thd, sp->clnt, rec_ptr, &err, flags & ~PREPARE_RECREATE);
    }
    sp->initial = 0;
    if ((sp->rc == SQLITE_PERM) && (maxRetries != 0) &&
            ((maxRetries == -1) || (nRetry++ < maxRetries))) {
        int sleepms = ATOMIC_LOAD32(gbl_lua_prepare_retry_sleep);
        if (sleepms >= 0) poll(NULL, 0, sleepms);
        goto retry;
    }
    if (sp->rc == SQLITE_PERM) sp->rc = SQLITE_SCHEMA; /* R7 compat */
    if (sp->rc == 0) {
        *stmt = rec_ptr->stmt;
        rec_ptr->sql = sqlite3_sql(*stmt);
    } else if (sp->rc == SQLITE_SCHEMA) {
        return luaL_error(L, sqlite3ErrStr(sp->rc));
    } else {
        luabb_error(L, sp, "%s in stmt: %s", err.errstr, sql);
    }
    return sp->rc;
}

static void lua_begin_step(struct sqlclntstate *clnt, SP sp,
                           sqlite3_stmt *pStmt)