Struct DbSessionStore 

pub struct DbSessionStore { /* private fields */ }

Available on crate features model-mysql or model-postgres or model-sqlite only.

Session store backed by a relational database via the model-layer DbPool.

Sessions survive process restarts and are visible to every process that connects to the same database, making this suitable for multi-instance deployments and zero-downtime restarts.

The first call to DbSessionStore::new creates the rws_sessions table if it does not already exist:

CREATE TABLE IF NOT EXISTS rws_sessions (
    id         TEXT    PRIMARY KEY,
    data       TEXT    NOT NULL DEFAULT '',
    expires_at INTEGER NOT NULL
)

Session data is serialized as a URL-encoded string (key1=val1&key2=val2). Expired sessions are not removed automatically — call purge_expired periodically.

All methods are async fn — model-* features imply the http2 feature which provides a tokio runtime.

Example

use rust_web_server::model::DbPool;
use rust_web_server::session::DbSessionStore;

let pool = DbPool::memory().await?;
let store = DbSessionStore::new(pool, 3600).await?;

let mut sess = store.create().await?;
sess.set("user_id", "42");
store.save(&sess).await?;

let loaded = store.load(&sess.id).await?.unwrap();
assert_eq!(Some("42"), loaded.get("user_id"));

Implementations

impl DbSessionStore

pub async fn new(pool: DbPool, ttl_secs: u64) -> Result<Self, DbError>

Open (or reuse) a DbSessionStore backed by pool.

Creates the rws_sessions table on the first call if it is absent. Returns Err if the DDL fails.

pub async fn create(&self) -> Result<Session, DbError>

Create a new empty session and persist it immediately.

pub async fn create_with_id(&self, id: String) -> Result<Session, DbError>

Create a new empty session with a caller-supplied ID and persist it.

pub async fn load(&self, id: &str) -> Result<Option<Session>, DbError>

Load a session by ID. Returns None if unknown or expired.

pub async fn save(&self, session: &Session) -> Result<(), DbError>

Persist a session’s data back to the store.

pub async fn destroy(&self, id: &str) -> Result<(), DbError>

Delete a session immediately.

pub async fn purge_expired(&self) -> Result<(), DbError>

Delete all sessions whose TTL has elapsed.

pub async fn len(&self) -> Result<usize, DbError>

Total number of sessions in the store, including expired ones not yet purged.

pub async fn is_empty(&self) -> Result<bool, DbError>

true if the store contains no sessions.

Trait Implementations

impl Clone for DbSessionStore

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.