Method substitute

nodedb/src/control/planner/procedural/executor/bindings.rs:175–209

Substitute NEW.field, OLD.field, TG_OP, TG_TABLE_NAME, TG_WHEN in SQL text. Replaces: - `NEW.field_name` → SQL literal of the field value - `OLD.field_name` → SQL literal of the field value - `TG_OP` → 'INSERT' / 'UPDATE' / 'DELETE' - `TG_TABLE_NAME` → 'collection_name' - `TG_WHEN` → 'BEFORE' / 'AFTER' - `COALESCE(NEW.field, OLD.field)` handled naturally since each is replaced

(&self, sql: &str)

    /// - `TG_WHEN` → 'BEFORE' / 'AFTER'
    /// - `COALESCE(NEW.field, OLD.field)` handled naturally since each is replaced
    pub fn substitute(&self, sql: &str) -> String {
        let mut result = sql.to_string();

        // Replace NEW.field references.
        if let Some(ref new_row) = self.new_row {
            for (field, value) in new_row {
                let literal = value.to_sql_literal();
                result = replace_qualified_field_reference(&result, "NEW", field, &literal);
            }
        }

        // Replace OLD.field references.
        if let Some(ref old_row) = self.old_row {
            for (field, value) in old_row {
                let literal = value.to_sql_literal();
                result = replace_qualified_field_reference(&result, "OLD", field, &literal);
            }
        }

        // Replace user-defined variables (loop vars, procedure params).
        for (name, value) in &self.variables {
            result = replace_case_insensitive(&result, name, value);
        }

        // Replace statement-level variables.
        result = replace_case_insensitive(&result, "TG_OP", &format!("'{}'", self.tg_op));
        result = replace_case_insensitive(
            &result,
            "TG_TABLE_NAME",
            &format!("'{}'", self.tg_table_name),
        );
        result = replace_case_insensitive(&result, "TG_WHEN", &format!("'{}'", self.tg_when));

        result
    }
}

fn replace_qualified_field_reference(