Struct Sql 

pub struct Sql<DB: Database>(/* private fields */);

SQL database executor for event sourcing operations.

A generic wrapper around a SQLx connection pool that implements the Executor trait for storing and querying events.

Type Parameters

• DB - The SQLx database type (e.g., sqlx::Sqlite, sqlx::MySql, sqlx::Postgres)

Example

use evento_sql::Sql;
use sqlx::sqlite::SqlitePoolOptions;

// Create a connection pool
let pool = SqlitePoolOptions::new()
    .connect(":memory:")
    .await?;

// Convert to Sql executor
let executor: Sql<sqlx::Sqlite> = pool.into();

// Or use the type alias
let executor: evento_sql::Sqlite = pool.into();

Executor Implementation

The Sql type implements Executor with the following operations:

• read - Query events with filtering and cursor-based pagination
• write - Persist events with optimistic concurrency control
• get_subscriber_cursor - Get the current cursor position for a subscriber
• is_subscriber_running - Check if a subscriber is active with a specific worker
• upsert_subscriber - Create or update a subscriber record
• acknowledge - Update subscriber cursor after processing events

Trait Implementations

impl<D: Database> Clone for Sql<D>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<DB> Executor for Sql<DB>

where DB: Database, for<'c> &'c mut DB::Connection: Executor<'c, Database = DB>, SqlxValues: for<'q> IntoArguments<'q, DB>, String: for<'r> Decode<'r, DB> + Type<DB>, bool: for<'r> Decode<'r, DB> + Type<DB>, Vec<u8>: for<'r> Decode<'r, DB> + Type<DB>, usize: ColumnIndex<DB::Row>, SqlEvent: for<'r> FromRow<'r, DB::Row>,

fn read<'life0, 'async_trait>( &'life0 self, aggregators: Option<Vec<ReadAggregator>>, routing_key: Option<RoutingKey>, args: Args, ) -> Pin<Box<dyn Future<Output = Result<ReadResult<Event>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Queries events with filtering and pagination.

fn get_subscriber_cursor<'life0, 'async_trait>( &'life0 self, key: String, ) -> Pin<Box<dyn Future<Output = Result<Option<Value>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Gets the current cursor position for a subscription.

fn is_subscriber_running<'life0, 'async_trait>( &'life0 self, key: String, worker_id: Ulid, ) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Checks if a subscription is running with the given worker ID.

fn upsert_subscriber<'life0, 'async_trait>( &'life0 self, key: String, worker_id: Ulid, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Creates or updates a subscription record.

fn write<'life0, 'async_trait>( &'life0 self, events: Vec<Event>, ) -> Pin<Box<dyn Future<Output = Result<(), WriteError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Persists events atomically.

fn acknowledge<'life0, 'async_trait>( &'life0 self, key: String, cursor: Value, lag: u64, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Updates subscription cursor after processing events.

fn get_snapshot<'life0, 'async_trait>( &'life0 self, aggregator_type: String, aggregator_revision: String, id: String, ) -> Pin<Box<dyn Future<Output = Result<Option<(Vec<u8>, Value)>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Retrieves a stored snapshot for an aggregate.

fn save_snapshot<'life0, 'async_trait>( &'life0 self, aggregator_type: String, aggregator_revision: String, id: String, data: Vec<u8>, cursor: Value, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Stores a snapshot for an aggregate.

impl From<&Sql<MySql>> for Evento

Available on crate feature mysql only.

fn from(value: &MySql) -> Self

Converts to this type from the input type.

impl From<&Sql<Postgres>> for Evento

Available on crate feature postgres only.

fn from(value: &Postgres) -> Self

Converts to this type from the input type.

impl From<&Sql<Sqlite>> for Evento

Available on crate feature sqlite only.

fn from(value: &Sqlite) -> Self

Converts to this type from the input type.

impl<D: Database> From<Pool<D>> for Sql<D>

fn from(value: Pool<D>) -> Self

Converts to this type from the input type.

impl From<Sql<MySql>> for Evento

Available on crate feature mysql only.

fn from(value: MySql) -> Self

Converts to this type from the input type.

impl From<Sql<Postgres>> for Evento

Available on crate feature postgres only.

fn from(value: Postgres) -> Self

Converts to this type from the input type.

impl From<Sql<Sqlite>> for Evento

Available on crate feature sqlite only.

fn from(value: Sqlite) -> Self

Converts to this type from the input type.