cratestack-sqlx 0.3.7

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
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130

/// 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 partial_row;
mod query;
mod render;
#[cfg(test)]
mod tests_coalesce;
#[cfg(test)]
mod tests_descriptor;
#[cfg(test)]
mod tests_field_filter;
#[cfg(test)]
mod tests_filter_logic;
#[cfg(test)]
mod tests_geography;
#[cfg(test)]
mod tests_json;
#[cfg(test)]
mod tests_nested_relation_policy;
#[cfg(test)]
mod tests_optional;
#[cfg(test)]
mod tests_relation;
#[cfg(test)]
mod tests_update;
#[cfg(test)]
mod tests_update_many;

pub use partial_row::FromPartialPgRow;

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::{
    CoalesceExpr, CoalesceFilter, ConflictTarget, CreateDefault, CreateDefaultType,
    CreateModelInput, FieldRef, Filter, FilterExpr, FilterOp, IntoColumnName, IntoSqlValue,
    JsonFilter, JsonTextPath, ModelColumn, ModelDescriptor, ModelPrimaryKey, NullOrder,
    OrderClause, Projection, RelationFilter, RelationInclude, RelationQuantifier, SortDirection,
    SpatialFilter, SpatialPoint, SqlColumnValue, SqlValue, UpdateModelInput, UpsertModelInput,
    coalesce, point,
};
pub use delegate::{
    ModelDelegate, ScopedAggregate, ScopedAggregateColumn, ScopedAggregateCount, ScopedBatchCreate,
    ScopedBatchDelete, ScopedBatchGet, ScopedBatchUpdate, ScopedBatchUpsert, ScopedCreateRecord,
    ScopedDeleteMany, ScopedDeleteRecord, ScopedFindMany, ScopedFindManyWith, ScopedFindUnique,
    ScopedModelDelegate, ScopedProjectedFindMany, ScopedProjectedFindUnique, ScopedUpdateMany,
    ScopedUpdateManySet, ScopedUpdateRecord, ScopedUpdateRecordSet, ScopedUpsertRecord,
};
pub use descriptor::SqlxRuntime;
pub use query::{
    Aggregate, AggregateColumn, AggregateCount, BatchCreate, BatchDelete, BatchGet, BatchUpdate,
    BatchUpdateItem, BatchUpsert, CreateRecord, DeleteMany, DeleteRecord, FindMany, FindManyWith,
    FindUnique, ProjectedFindMany, ProjectedFindUnique, UpdateMany, UpdateManySet, UpdateRecord,
    UpdateRecordSet, UpsertRecord, create_record_with_executor, update_record_with_executor,
};