Struct ConnectionManager 

pub struct ConnectionManager { /* private fields */ }

Multi-backend connection pool with optional automatic database creation.

The backend (Postgres, MySQL, or SQLite) is selected from the URL scheme. If auto_create_db is enabled (default) and the target database doesn’t exist, it is created before the pool is opened.

Implementations

impl ConnectionManager

pub async fn connect(config: DbkitConfig) -> Result<Self, DbkitError>

Connect using a DbkitConfig.

pub async fn new(url: &str) -> Result<Self, DbkitError>

Connect using a connection URL with default settings.

Shorthand for ConnectionManager::connect(DbkitConfig::from_url(url)).

pub fn pool(&self) -> &AnyPool

Get the underlying sqlx connection pool.

pub fn backend(&self) -> Backend

The detected backend for this connection.

pub async fn get_connection(&self) -> Result<PoolConnection<Any>, DbkitError>

Acquire a connection from the pool.

pub async fn is_connected(&self) -> bool

Check if the database is reachable.

pub fn db_name(&self) -> &str

The database name extracted from the connection URL.

pub fn connection_string(&self) -> &str

The full connection string.

pub fn config(&self) -> &DbkitConfig

The config used to create this connection.

pub async fn pg_native_pool(&self) -> Result<PgPool, DbkitError>

Create a native sqlx PgPool from this connection’s URL.

The multi-backend Any pool can only represent basic scalar types (bool/int/float/text/bytes). This native pool restores full Postgres type support — uuid, chrono timestamps, json/jsonb, arrays, etc. — for the queries that need it. Use it alongside pool: Any for portable work, the native pool for rich-typed Postgres work.

Errors if this connection is not Postgres.

let pg = conn.pg_native_pool().await?;
let row = sqlx::query("SELECT id, created_at FROM users WHERE id = $1")
    .bind(some_uuid)
    .fetch_one(&pg)
    .await?;
let id: sqlx::types::Uuid = row.get("id");

pub fn pool_status(&self) -> PoolStatus

Pool health metrics.