execute_command

Function execute_command 

Source
pub async fn execute_command(
    engine: StandardEngine,
    statements: Vec<String>,
    identity: Identity,
    params: Params,
    timeout: Duration,
) -> ExecuteResult<Vec<Frame>>
Expand description

Execute a command on the blocking thread pool with timeout.

Commands are write operations (INSERT, UPDATE, DELETE, DDL) that modify the database state.

§Arguments

  • engine - The database engine to execute the command on
  • statements - The RQL command statements
  • identity - The identity context for permission checking
  • params - Command parameters
  • timeout - Maximum time to wait for command completion

§Returns

  • Ok(Vec<Frame>) - Command results on success
  • Err(ExecuteError::Timeout) - If the command exceeds the timeout
  • Err(ExecuteError::TaskPanic) - If the blocking task panics
  • Err(ExecuteError::Engine) - If the engine returns an error