Struct SqliteReadPool 

pub struct SqliteReadPool { /* private fields */ }

SQLite Read Connection Pool

Manages a pool of read-only SQLite connections for concurrent reads. Each connection is opened with SQLITE_OPEN_READ_ONLY flag.

Example

let pool = SqliteReadPool::new(&db_path, ReadPoolConfig::enabled(4))?;

// Acquire a pooled connection
let conn = pool.acquire().await?;
let count: i64 = conn.query_row("SELECT COUNT(*) FROM users", [], |row| row.get(0))?;
// Connection is returned to pool when `conn` is dropped

Implementations

impl SqliteReadPool

pub fn new(db_path: &Path, config: ReadPoolConfig) -> Result<Self>

Create a new read pool with the given configuration

Opens pool_size read-only connections to the database.

pub async fn acquire(&self) -> Result<PooledSqliteConnection<'_>>

Acquire a pooled read-only connection

Waits up to the configured timeout for a connection to become available. Returns an error if the timeout is exceeded.

pub fn try_acquire(&self) -> Result<Option<PooledSqliteConnection<'_>>>

Try to acquire a pooled read-only connection without waiting

Returns None if no connection is immediately available.

pub fn available_permits(&self) -> usize

Get the number of available connections in the pool

pub fn is_enabled(&self) -> bool

Check if pooling is enabled

pub fn db_path(&self) -> &Path

Get the database path

pub fn pool_size(&self) -> usize

Get the pool size

pub fn acquire_blocking(&self) -> Result<PooledSqliteConnection<'_>>

Acquire a pooled read-only connection (blocking)

Blocks up to acquire_timeout waiting for an available connection.