cratestack_sqlx/
lib.rs

1/// Compatibility shim that exposes a `sqlx`-shaped API by re-exporting from
2/// `sqlx-core` + `sqlx-postgres` directly.
3///
4/// **Why this shim exists:** depending on the `sqlx` umbrella crate transitively
5/// pulls `sqlx-sqlite` into the resolve graph (Cargo's resolver materialises the
6/// optional dep even when no feature activates it), which pins `libsqlite3-sys
7/// ^0.30.1` and conflicts with `rusqlite 0.39`'s `libsqlite3-sys ^0.37` via the
8/// `links = "sqlite3"` rule. Going direct to the split crates side-steps the
9/// leak entirely. Downstream users keep writing `cratestack::sqlx::X` paths;
10/// macro emissions stay unchanged.
11///
12/// **SemVer caveat:** `sqlx-core` documents itself as "not meant for general use"
13/// without SemVer guarantees. The surface re-exported here is the narrow subset
14/// the umbrella `sqlx` crate exposes, which is stable in practice across `0.8.x`.
15/// If `sqlx-core` breaks at a `0.8` patch, this shim adapts in one place.
16pub mod sqlx {
17    pub use sqlx_core::Either;
18    pub use sqlx_core::acquire::Acquire;
19    pub use sqlx_core::arguments::{Arguments, IntoArguments};
20    pub use sqlx_core::column::{Column, ColumnIndex};
21    pub use sqlx_core::connection::{ConnectOptions, Connection};
22    pub use sqlx_core::database::{self, Database};
23    pub use sqlx_core::describe::Describe;
24    pub use sqlx_core::executor::{Execute, Executor};
25    pub use sqlx_core::from_row::FromRow;
26    pub use sqlx_core::pool::{self, Pool};
27    pub use sqlx_core::query::{query, query_with};
28    pub use sqlx_core::query_as::{query_as, query_as_with};
29    pub use sqlx_core::query_builder::{self, QueryBuilder};
30    pub use sqlx_core::query_scalar::{query_scalar, query_scalar_with};
31    pub use sqlx_core::raw_sql::{RawSql, raw_sql};
32    pub use sqlx_core::row::Row;
33    pub use sqlx_core::statement::Statement;
34    pub use sqlx_core::transaction::{Transaction, TransactionManager};
35    pub use sqlx_core::type_info::TypeInfo;
36    pub use sqlx_core::value::{Value, ValueRef};
37
38    pub use sqlx_core::error::{self, Error, Result};
39
40    #[cfg(feature = "decimal-rust-decimal")]
41    pub use sqlx_core::migrate;
42    #[cfg(not(feature = "decimal-rust-decimal"))]
43    pub use sqlx_core::migrate;
44
45    pub use sqlx_postgres::{
46        self as postgres, PgConnection, PgExecutor, PgPool, PgTransaction, Postgres,
47    };
48
49    pub mod types {
50        pub use sqlx_core::types::*;
51    }
52
53    pub mod encode {
54        pub use sqlx_core::encode::{Encode, IsNull};
55    }
56    pub use self::encode::Encode;
57
58    pub mod decode {
59        pub use sqlx_core::decode::Decode;
60    }
61    pub use self::decode::Decode;
62
63    pub use sqlx_core::types::Type;
64}
65
66mod audit;
67mod delegate;
68mod descriptor;
69mod error;
70mod idempotency;
71mod isolation;
72mod json;
73mod migrations;
74mod partial_row;
75mod query;
76mod render;
77#[cfg(test)]
78mod tests_coalesce;
79#[cfg(test)]
80mod tests_create_defaults;
81#[cfg(test)]
82mod tests_descriptor;
83#[cfg(test)]
84mod tests_field_filter;
85#[cfg(test)]
86mod tests_filter_logic;
87#[cfg(test)]
88mod tests_geography;
89#[cfg(test)]
90mod tests_json;
91#[cfg(test)]
92mod tests_nested_relation_policy;
93#[cfg(test)]
94mod tests_optional;
95#[cfg(test)]
96mod tests_pgvector;
97#[cfg(test)]
98mod tests_policy_precedence_bug;
99#[cfg(test)]
100mod tests_read_policy_field_predicates;
101#[cfg(test)]
102mod tests_read_policy_predicates;
103#[cfg(test)]
104mod tests_relation;
105#[cfg(test)]
106mod tests_system_principal_policy;
107#[cfg(test)]
108mod tests_update;
109#[cfg(test)]
110mod tests_update_many;
111mod transaction;
112
113pub use partial_row::FromPartialPgRow;
114
115pub use json::Json;
116/// Re-exported so generated code (and the facade crates) can reach
117/// `::cratestack::pgvector::Vector` without depending on the
118/// `pgvector` crate directly — mirrors how `sqlx` above is re-exposed
119/// as a shim rather than depended on separately by every consumer.
120#[cfg(feature = "pgvector")]
121pub use pgvector;
122
123pub use audit::{
124    AUDIT_TABLE_DDL, RunInTxOutcome, dispatch_audit_sink, primary_key_from_snapshot, snapshot_model,
125};
126pub use error::cratestack_error_from_sqlx;
127pub use idempotency::{SqlxIdempotencyStore, expiry_from};
128pub use isolation::{run_in_isolated_tx, run_in_isolated_tx_with_retries};
129pub use migrations::{
130    MIGRATIONS_TABLE_DDL, Migration, MigrationState, MigrationStatus, apply_pending,
131    ensure_migrations_table, status,
132};
133pub use transaction::Tx;
134
135pub use cratestack_policy::{PolicyExpr, PolicyLiteral, ReadPolicy, ReadPredicate};
136pub use cratestack_sql::{
137    CoalesceExpr, CoalesceFilter, ConflictTarget, CreateDefault, CreateDefaultType,
138    CreateModelInput, FieldRef, Filter, FilterExpr, FilterOp, IntoColumnName, IntoSqlValue,
139    JsonFilter, JsonTextPath, ModelColumn, ModelDescriptor, ModelPrimaryKey, NullOrder,
140    OrderClause, Orderable, Projection, RelationFilter, RelationHop, RelationInclude,
141    RelationQuantifier, SortDirection, SpatialFilter, SpatialPoint, SqlColumnValue, SqlValue,
142    Unorderable, UpdateModelInput, UpsertModelInput, VectorDistanceExpr, VectorDistanceFilter,
143    VectorMetric, coalesce, is_orderable, order_value_sql, point, wrap_filter,
144};
145pub use delegate::{
146    ModelDelegate, ScopedAggregate, ScopedAggregateColumn, ScopedAggregateCount, ScopedBatchCreate,
147    ScopedBatchDelete, ScopedBatchGet, ScopedBatchUpdate, ScopedBatchUpsert, ScopedCreateRecord,
148    ScopedDeleteMany, ScopedDeleteRecord, ScopedFindMany, ScopedFindManyWith, ScopedFindUnique,
149    ScopedModelDelegate, ScopedProjectedFindMany, ScopedProjectedFindUnique, ScopedUpdateMany,
150    ScopedUpdateManySet, ScopedUpdateRecord, ScopedUpdateRecordSet, ScopedUpsertRecord,
151    ScopedUpsertRecordDoNothing, ViewDelegate, ViewDelegateNoUnique,
152};
153pub use descriptor::{SqlxRuntime, enqueue_event_outbox, ensure_event_outbox_table};
154pub use query::{
155    Aggregate, AggregateColumn, AggregateCount, BatchCreate, BatchDelete, BatchGet, BatchUpdate,
156    BatchUpdateItem, BatchUpsert, CreateRecord, DeleteMany, DeleteRecord, FindMany, FindManyWith,
157    FindUnique, ProjectedFindMany, ProjectedFindUnique, UpdateMany, UpdateManySet, UpdateRecord,
158    UpdateRecordSet, UpsertOutcome, UpsertRecord, UpsertRecordDoNothing,
159    create_record_with_executor, update_record_with_executor,
160};
cratestack_sqlx/lib.rs

cratestack_sqlx/
lib.rs
