Struct UpdateExecutor 

pub struct UpdateExecutor;

Executor for UPDATE statements

Implementations

impl UpdateExecutor

pub fn execute( stmt: &UpdateStmt, database: &mut Database, ) -> Result<usize, ExecutorError>

Execute an UPDATE statement

Arguments

• stmt - The UPDATE statement AST node
• database - The database to update

Returns

Number of rows updated or error

Examples

use vibesql_ast::{Assignment, Expression, UpdateStmt};
use vibesql_catalog::{ColumnSchema, TableSchema};
use vibesql_executor::UpdateExecutor;
use vibesql_storage::Database;
use vibesql_types::{DataType, SqlValue};

let mut db = Database::new();

// Create table
let schema = TableSchema::new(
    "employees".to_string(),
    vec![
        ColumnSchema::new("id".to_string(), DataType::Integer, false),
        ColumnSchema::new("salary".to_string(), DataType::Integer, false),
    ],
);
db.create_table(schema).unwrap();

// Insert a row
db.insert_row(
    "employees",
    vibesql_storage::Row::new(vec![SqlValue::Integer(1), SqlValue::Integer(50000)]),
)
.unwrap();

// Update salary
let stmt = UpdateStmt {
    table_name: "employees".to_string(),
    assignments: vec![Assignment {
        column: "salary".to_string(),
        value: Expression::Literal(SqlValue::Integer(60000)),
    }],
    where_clause: None,
};

let count = UpdateExecutor::execute(&stmt, &mut db).unwrap();
assert_eq!(count, 1);

pub fn execute_with_procedural_context( stmt: &UpdateStmt, database: &mut Database, procedural_context: &ExecutionContext, ) -> Result<usize, ExecutorError>

Execute an UPDATE statement with procedural context Supports procedural variables in SET and WHERE clauses

pub fn execute_with_trigger_context( stmt: &UpdateStmt, database: &mut Database, trigger_context: &TriggerContext<'_>, ) -> Result<usize, ExecutorError>

Execute an UPDATE statement with trigger context This allows UPDATE statements within trigger bodies to reference OLD/NEW pseudo-variables

pub fn execute_with_schema( stmt: &UpdateStmt, database: &mut Database, schema: Option<&TableSchema>, ) -> Result<usize, ExecutorError>

Execute an UPDATE statement with optional pre-fetched schema

This method allows cursor-level schema caching to reduce redundant catalog lookups. If schema is provided, skips the catalog lookup step.

Arguments

• stmt - The UPDATE statement AST node
• database - The database to update
• schema - Optional pre-fetched schema (from cursor cache)

Returns

Number of rows updated or error