Struct CreateTriggerStatement

Source

pub struct CreateTriggerStatement { /* private fields */ }

Expand description

CREATE TRIGGER statement builder

This struct provides a fluent API for constructing CREATE TRIGGER queries.

§Backend Support

PostgreSQL: Full support (BEFORE/AFTER/INSTEAD OF, FOR EACH ROW/STATEMENT, WHEN clause)
MySQL: Basic support (BEFORE/AFTER, FOR EACH ROW only, FOLLOWS/PRECEDES)
SQLite: Basic support (BEFORE/AFTER/INSTEAD OF, FOR EACH ROW, WHEN clause)

§Examples

use reinhardt_query::prelude::*;
use reinhardt_query::types::{TriggerEvent, TriggerTiming, TriggerScope, TriggerBody};

// PostgreSQL: Call a function when a row is inserted
let query = Query::create_trigger()
    .name("audit_insert")
    .timing(TriggerTiming::After)
    .event(TriggerEvent::Insert)
    .on_table("users")
    .for_each(TriggerScope::Row)
    .execute_function("audit_log_insert");

// MySQL: Multiple statements on update
let query = Query::create_trigger()
    .name("update_timestamp")
    .timing(TriggerTiming::Before)
    .event(TriggerEvent::Update { columns: None })
    .on_table("users")
    .for_each(TriggerScope::Row)
    .body(TriggerBody::multiple(vec![
        "SET NEW.updated_at = NOW()",
    ]));

Implementations§

Source §

impl CreateTriggerStatement

Source

pub fn new() -> Self

Create a new CREATE TRIGGER statement

Source

pub fn take(&mut self) -> Self

Take the ownership of data in the current CreateTriggerStatement

Source

pub fn name<N>(&mut self, name: N) -> &mut Self
where N: IntoIden,

Set the trigger name

§Examples

use reinhardt_query::prelude::*;

let query = Query::create_trigger()
    .name("audit_insert");

Source

pub fn timing(&mut self, timing: TriggerTiming) -> &mut Self

Set the trigger timing (BEFORE, AFTER, INSTEAD OF)

§Examples

use reinhardt_query::prelude::*;
use reinhardt_query::types::TriggerTiming;

let query = Query::create_trigger()
    .timing(TriggerTiming::Before);

Source

pub fn event(&mut self, event: TriggerEvent) -> &mut Self

Add a trigger event (INSERT, UPDATE, DELETE)

Can be called multiple times to add multiple events (PostgreSQL only).

§Examples

use reinhardt_query::prelude::*;
use reinhardt_query::types::TriggerEvent;

let query = Query::create_trigger()
    .event(TriggerEvent::Insert)
    .event(TriggerEvent::Update { columns: None });

Source

pub fn on_table<T>(&mut self, table: T) -> &mut Self
where T: IntoTableRef,

Set the table on which the trigger operates

§Examples

use reinhardt_query::prelude::*;

let query = Query::create_trigger()
    .on_table("users");

Source

pub fn for_each(&mut self, scope: TriggerScope) -> &mut Self

Set the trigger scope (FOR EACH ROW or FOR EACH STATEMENT)

§Examples

use reinhardt_query::prelude::*;
use reinhardt_query::types::TriggerScope;

let query = Query::create_trigger()
    .for_each(TriggerScope::Row);

Source

pub fn when_condition(&mut self, condition: SimpleExpr) -> &mut Self

Set the WHEN condition (optional filter for when trigger fires)

§Examples

use reinhardt_query::prelude::*;

let query = Query::create_trigger()
    .when_condition(Expr::col("status").eq("active"));

Source

pub fn body(&mut self, body: TriggerBody) -> &mut Self

Set the trigger body (SQL statements to execute)

§Examples

use reinhardt_query::prelude::*;
use reinhardt_query::types::TriggerBody;

let query = Query::create_trigger()
    .body(TriggerBody::single("UPDATE counters SET count = count + 1"));

Source

pub fn execute_function<S: Into<String>>( &mut self, function_name: S, ) -> &mut Self

Set the PostgreSQL function to execute (EXECUTE FUNCTION function_name())

This is a convenience method for PostgreSQL triggers.

§Examples

use reinhardt_query::prelude::*;

let query = Query::create_trigger()
    .execute_function("audit_log_insert");

Source

pub fn order(&mut self, order: TriggerOrder) -> &mut Self

Set the MySQL trigger order (FOLLOWS or PRECEDES)

MySQL-specific feature to control trigger execution order.

§Examples

use reinhardt_query::prelude::*;
use reinhardt_query::types::TriggerOrder;

let query = Query::create_trigger()
    .order(TriggerOrder::Follows("other_trigger".to_string()));