Function run

crates/core/src/sql/execute.rs:52–64

Run the `SQL` string using the `auth` credentials If a `ModuleHost` is provided, the SQL query is executed via the module host, meaning the module’s core is used to run the statement. If no module host is provided, the SQL query is executed on the current thread.

(
    db: Arc<RelationalDB>,
    sql_text: String,
    auth: AuthCtx,
    subs: Option<ModuleSubscriptions>,
    module: Option<ModuleHost>,
    head: &mut Vec<(RawIdentifier, AlgebraicType)>,
)

/// meaning the module’s core is used to run the statement.
/// If no module host is provided, the SQL query is executed on the current thread.
pub async fn run(
    db: Arc<RelationalDB>,
    sql_text: String,
    auth: AuthCtx,
    subs: Option<ModuleSubscriptions>,
    module: Option<ModuleHost>,
    head: &mut Vec<(RawIdentifier, AlgebraicType)>,
) -> Result<SqlResult, DBError> {
    match module {
        Some(module) => module.call_sql(db, sql_text, auth, subs, head).await,
        None => run_inner::<crate::host::wasmtime::WasmtimeInstance>(None, db, sql_text, auth, subs, head).map(|x| x.0),
    }
}

/// Run the `SQL` string using the provided `WasmInstance` and `ModuleDef`
///