Production infrastructure for AI agents

Website · Documentation · Guides · Core · Template · Discord

systemprompt-database

One PostgreSQL holds every prompt, key, and audit record your deployment produces, on infrastructure you run. This crate is how the rest of the workspace reaches it: a pooled SQLx handle, generic repository traits, and compile-time-verified queries.

Layer: Infra. Infrastructure primitives consumed by the domain and application crates. Part of the systemprompt-core workspace.

What it does

Every service reaches the database through the same audited path. Static SQL goes through the compile-time-verified sqlx::query! / query_as! / query_scalar! macros; dynamic SQL is contained to two allowlisted surfaces (the admin CLI and the provider implementation) where dynamic SQL is the contract. Domain crates never write raw queries; they build on the repository traits.

The crate owns the pool, the transaction helpers, the extension migration runner, and the resilience primitives (circuit breaker, bulkhead, retry) that wrap its own connection and transaction attempts.

Modules

Schema DDL lives in schema/ (functions.sql, extension_migrations.sql).

Usage

[dependencies]
systemprompt-database = "0.21"

use systemprompt_database::{DatabaseResult, DbPool, with_transaction};

async fn example(pool: &DbPool) -> DatabaseResult<()> {
    with_transaction(pool, |tx| Box::pin(async move {
        // Execute queries within transaction
        Ok(())
    })).await
}

use systemprompt_database::{DatabaseResult, DbPool, with_transaction};

async fn count_users(pool: &DbPool) -> DatabaseResult<i64> {
    with_transaction(pool, |tx| Box::pin(async move {
        let row: (i64,) = sqlx::query_as("SELECT COUNT(*) FROM users")
            .fetch_one(&mut **tx)
            .await?;
        Ok(row.0)
    }))
    .await
}

Public API

Types

Traits

Functions

Macros

Resilience

The resilience module is publicly exported and domain-agnostic. ResilienceGuard, CircuitBreaker, Bulkhead, and retry_async wrap outbound calls; the crate's own connection and transaction retries run on them.

Re-exports

From systemprompt-traits: DbValue, ToDbValue, FromDbValue, JsonRow, parse_database_datetime

From systemprompt-identifiers: UserId, TaskId, SessionId, ContextId, TraceId, ArtifactId, ExecutionStepId, SkillId, ContentId, FileId, ClientId, TokenId, LogId

From sqlx: PgPool, Pool, Postgres, Transaction, Json

Dependencies

• systemprompt-traits — core traits
• systemprompt-identifiers — typed identifiers
• systemprompt-models — shared model types
• systemprompt-extension — extension framework registration
• sqlx — PostgreSQL driver with compile-time-verified macros
• tokio — async runtime
• serde / serde_json — serialization
• chrono — timestamps
• uuid — UUID support
• rust_decimal — decimal support
• base64 — encoded value support
• thiserror — error derivation
• async-trait — dyn-compatible async traits
• tracing — structured logging
• inventory — extension registration

License

BSL-1.1 (Business Source License). Source-available for evaluation, testing, and non-production use. Production use requires a commercial license. Each version converts to Apache 2.0 four years after publication. See LICENSE.

systemprompt.io · Documentation · Guides · Live Demo · Template · crates.io · docs.rs · Discord

Infra layer · Own how your organization uses AI.