cratestack-sqlx 0.3.1

Rust-native schema-first framework for typed HTTP APIs, generated clients, and backend services.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99

/// Compatibility shim that exposes a `sqlx`-shaped API by re-exporting from
/// `sqlx-core` + `sqlx-postgres` directly.
///
/// **Why this shim exists:** depending on the `sqlx` umbrella crate transitively
/// pulls `sqlx-sqlite` into the resolve graph (Cargo's resolver materialises the
/// optional dep even when no feature activates it), which pins `libsqlite3-sys
/// ^0.30.1` and conflicts with `rusqlite 0.39`'s `libsqlite3-sys ^0.37` via the
/// `links = "sqlite3"` rule. Going direct to the split crates side-steps the
/// leak entirely. Downstream users keep writing `cratestack::sqlx::X` paths;
/// macro emissions stay unchanged.
///
/// **SemVer caveat:** `sqlx-core` documents itself as "not meant for general use"
/// without SemVer guarantees. The surface re-exported here is the narrow subset
/// the umbrella `sqlx` crate exposes, which is stable in practice across `0.8.x`.
/// If `sqlx-core` breaks at a `0.8` patch, this shim adapts in one place.
pub mod sqlx {
    pub use sqlx_core::Either;
    pub use sqlx_core::acquire::Acquire;
    pub use sqlx_core::arguments::{Arguments, IntoArguments};
    pub use sqlx_core::column::{Column, ColumnIndex};
    pub use sqlx_core::connection::{ConnectOptions, Connection};
    pub use sqlx_core::database::{self, Database};
    pub use sqlx_core::describe::Describe;
    pub use sqlx_core::executor::{Execute, Executor};
    pub use sqlx_core::from_row::FromRow;
    pub use sqlx_core::pool::{self, Pool};
    pub use sqlx_core::query::{query, query_with};
    pub use sqlx_core::query_as::{query_as, query_as_with};
    pub use sqlx_core::query_builder::{self, QueryBuilder};
    pub use sqlx_core::query_scalar::{query_scalar, query_scalar_with};
    pub use sqlx_core::raw_sql::{RawSql, raw_sql};
    pub use sqlx_core::row::Row;
    pub use sqlx_core::statement::Statement;
    pub use sqlx_core::transaction::{Transaction, TransactionManager};
    pub use sqlx_core::type_info::TypeInfo;
    pub use sqlx_core::value::{Value, ValueRef};

    pub use sqlx_core::error::{self, Error, Result};

    #[cfg(feature = "decimal-rust-decimal")]
    pub use sqlx_core::migrate;
    #[cfg(not(feature = "decimal-rust-decimal"))]
    pub use sqlx_core::migrate;

    pub use sqlx_postgres::{
        self as postgres, PgConnection, PgExecutor, PgPool, PgTransaction, Postgres,
    };

    pub mod types {
        pub use sqlx_core::types::*;
    }

    pub mod encode {
        pub use sqlx_core::encode::{Encode, IsNull};
    }
    pub use self::encode::Encode;

    pub mod decode {
        pub use sqlx_core::decode::Decode;
    }
    pub use self::decode::Decode;

    pub use sqlx_core::types::Type;
}

mod audit;
mod delegate;
mod descriptor;
mod idempotency;
mod isolation;
mod migrations;
mod query;
mod render;
#[cfg(test)]
mod tests;

pub use audit::{AUDIT_TABLE_DDL, primary_key_from_snapshot, snapshot_model};
pub use idempotency::{SqlxIdempotencyStore, expiry_from};
pub use isolation::{run_in_isolated_tx, run_in_isolated_tx_with_retries};
pub use migrations::{
    MIGRATIONS_TABLE_DDL, Migration, MigrationState, MigrationStatus, apply_pending,
    ensure_migrations_table, status,
};

pub use cratestack_policy::{PolicyExpr, PolicyLiteral, ReadPolicy, ReadPredicate};
pub use cratestack_sql::{
    CreateDefault, CreateDefaultType, CreateModelInput, FieldRef, Filter, FilterExpr,
    IntoSqlValue, ModelColumn, ModelDescriptor, OrderClause, RelationFilter, RelationQuantifier,
    SortDirection, SqlColumnValue, SqlValue, UpdateModelInput, UpsertModelInput,
};
pub use delegate::{
    ModelDelegate, ScopedCreateRecord, ScopedDeleteRecord, ScopedFindMany, ScopedFindUnique,
    ScopedModelDelegate, ScopedUpdateRecord, ScopedUpdateRecordSet, ScopedUpsertRecord,
};
pub use descriptor::SqlxRuntime;
pub use query::{
    CreateRecord, DeleteRecord, FindMany, FindUnique, UpdateRecord, UpdateRecordSet, UpsertRecord,
    create_record_with_executor, update_record_with_executor,
};