Struct UnitOfWork 

pub struct UnitOfWork { /* private fields */ }

Tracks and manages all pending changes in a session.

The Unit of Work is responsible for:

• Maintaining the set of new, dirty, and deleted objects
• Computing the correct flush order based on FK dependencies
• Detecting dependency cycles before flush

Implementations

impl UnitOfWork

pub fn new() -> Self

Create a new empty Unit of Work.

pub fn register_model<T: Model>(&mut self)

Register a model type for dependency tracking.

This extracts foreign key relationships from the model’s metadata and registers them for flush ordering.

pub fn track_new<T: Model + Serialize>(&mut self, model: &T, key: ObjectKey)

Track a new object for insertion.

The object will be INSERTed during flush.

pub fn track_dirty<T: Model + Serialize>( &mut self, model: &T, key: ObjectKey, changed_columns: Vec<&'static str>, )

Track a dirty object for update.

The object will be UPDATEd during flush (only changed columns).

pub fn track_dirty_auto<T: Model + Serialize>( &mut self, model: &T, key: ObjectKey, )

Track a dirty object for update (auto-detect changed fields).

Uses the change tracker to determine which fields changed.

pub fn track_deleted<T: Model>(&mut self, model: &T, key: ObjectKey)

Track an object for deletion.

The object will be DELETEd during flush.

pub fn snapshot<T: Model + Serialize>(&mut self, key: ObjectKey, model: &T)

Take a snapshot of an object for later dirty detection.

pub fn is_dirty<T: Model + Serialize>(&self, key: &ObjectKey, model: &T) -> bool

Check if an object is dirty (has changed since snapshot).

pub fn changed_fields<T: Model + Serialize>( &self, key: &ObjectKey, model: &T, ) -> Vec<&'static str>

Get the changed fields for an object.

pub fn check_cycles(&self) -> Result<(), UowError>

Check for dependency cycles in the registered tables.

Returns Err(UowError::CycleDetected) if a cycle is found.

pub fn compute_flush_plan(&self) -> Result<FlushPlan, UowError>

Compute the flush plan.

This checks for cycles and orders operations by dependencies.

Errors

Returns Err if a dependency cycle is detected.

pub fn clear(&mut self)

Clear all tracked changes.

Call this after a successful commit.

pub fn has_changes(&self) -> bool

Check if there are any pending changes.

pub fn pending_count(&self) -> PendingCounts

Get the count of pending operations.

pub fn change_tracker(&self) -> &ChangeTracker

Get a reference to the change tracker.

pub fn change_tracker_mut(&mut self) -> &mut ChangeTracker

Get a mutable reference to the change tracker.

Trait Implementations

impl Default for UnitOfWork

fn default() -> UnitOfWork

Returns the “default value” for a type.