Struct Db 

pub struct Db { /* private fields */ }

Handles database interactions for registering JSON objects.

This struct manages the connection pool and executes SQL queries to insert or retrieve JSON objects. It uses optimized queries to handle concurrency and minimize round-trips.

Implementations

impl Db

pub async fn new( connection_string: &str, table_name: &str, id_column: &str, jsonb_column: &str, pool_size: u32, acquire_timeout_secs: Option<u64>, idle_timeout_secs: Option<u64>, max_lifetime_secs: Option<u64>, ) -> Result<Self, Error>

Creates a new Db instance.

Arguments

• connection_string - The PostgreSQL connection string.
• table_name - The name of the table.
• id_column - The name of the ID column.
• jsonb_column - The name of the JSONB column.
• pool_size - The maximum number of connections in the pool.
• acquire_timeout_secs - Optional timeout for acquiring connections (default: 5s).
• idle_timeout_secs - Optional timeout for idle connections (default: 600s).
• max_lifetime_secs - Optional maximum lifetime for connections (default: 1800s).

Returns

A Result containing the new Db instance or a sqlx::Error.

pub async fn register_object(&self, json_str: &str) -> Result<i32, Error>

Registers a single JSON object string in the database.

Arguments

• json_str - The canonicalised JSON string.

Returns

A Result containing the ID (i32) or a sqlx::Error.

pub async fn register_batch_objects( &self, json_strs: &[String], ) -> Result<Vec<i32>, Error>

Registers a batch of JSON object strings in the database.

Arguments

• json_strs - A slice of canonicalised JSON strings.

Returns

A Result containing a vector of IDs or a sqlx::Error.

pub fn pool_size(&self) -> usize

Returns the current size of the connection pool.

This is the total number of connections (both idle and active) currently in the pool. Useful for monitoring pool utilization.

Returns

The number of connections in the pool.

pub fn idle_connections(&self) -> usize

Returns the number of idle connections in the pool.

Idle connections are available for immediate use. A low idle count during high load may indicate the pool is undersized.

Returns

The number of idle connections.

pub fn is_closed(&self) -> bool

Checks if the connection pool is closed.

A closed pool cannot create new connections and will error on acquire attempts.

Returns

true if the pool is closed, false otherwise.