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.40`'s `libsqlite3-sys ^0.38` 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 was stable in practice across `0.8.x`
15/// and is now pinned at `=0.9.0`. That design paid off at the 0.8→0.9 boundary:
16/// upstream's `SqlSafeStr` bound and the `QueryBuilder` lifetime removal landed
17/// as *additions to this list* (`AssertSqlSafe`/`SqlSafeStr`/`SqlStr`) plus
18/// mechanical call-site edits, with no downstream `::cratestack::sqlx::…` path
19/// changing. Treat any future minor the same way: adapt here first.
20pub mod sqlx {
21    pub use sqlx_core::Either;
22    pub use sqlx_core::acquire::Acquire;
23    pub use sqlx_core::arguments::{Arguments, IntoArguments};
24    pub use sqlx_core::column::{Column, ColumnIndex};
25    pub use sqlx_core::connection::{ConnectOptions, Connection};
26    pub use sqlx_core::database::{self, Database};
27    pub use sqlx_core::describe::Describe;
28    pub use sqlx_core::executor::{Execute, Executor};
29    pub use sqlx_core::from_row::FromRow;
30    pub use sqlx_core::pool::{self, Pool};
31    pub use sqlx_core::query::{query, query_with};
32    pub use sqlx_core::query_as::{query_as, query_as_with};
33    pub use sqlx_core::query_builder::{self, QueryBuilder};
34    pub use sqlx_core::query_scalar::{query_scalar, query_scalar_with};
35    pub use sqlx_core::raw_sql::{RawSql, raw_sql};
36    pub use sqlx_core::row::Row;
37    // sqlx 0.9.0 (#3723) narrowed every `query*()`/`raw_sql()` entry point to
38    // `impl SqlSafeStr`, implemented only for `&'static str` and the
39    // `AssertSqlSafe` wrapper. Re-exported here rather than left to
40    // `sqlx_core::sql_str::…` paths so the shim stays the single place that
41    // knows which upstream module these live in — the same reason every other
42    // item above is re-exported by name.
43    pub use sqlx_core::sql_str::{AssertSqlSafe, SqlSafeStr, SqlStr};
44    pub use sqlx_core::statement::Statement;
45    pub use sqlx_core::transaction::{Transaction, TransactionManager};
46    pub use sqlx_core::type_info::TypeInfo;
47    pub use sqlx_core::value::{Value, ValueRef};
48
49    pub use sqlx_core::error::{self, Error, Result};
50
51    #[cfg(feature = "decimal-rust-decimal")]
52    pub use sqlx_core::migrate;
53    #[cfg(not(feature = "decimal-rust-decimal"))]
54    pub use sqlx_core::migrate;
55
56    pub use sqlx_postgres::{
57        self as postgres, PgConnection, PgExecutor, PgPool, PgTransaction, Postgres,
58    };
59
60    pub mod types {
61        pub use sqlx_core::types::*;
62    }
63
64    pub mod encode {
65        pub use sqlx_core::encode::{Encode, IsNull};
66    }
67    pub use self::encode::Encode;
68
69    pub mod decode {
70        pub use sqlx_core::decode::Decode;
71    }
72    pub use self::decode::Decode;
73
74    pub use sqlx_core::types::Type;
75}
76
77mod audit;
78mod delegate;
79mod descriptor;
80mod error;
81mod idempotency;
82mod isolation;
83mod json;
84mod migrations;
85mod partial_row;
86mod query;
87mod render;
88#[cfg(feature = "postgis")]
89mod spatial;
90#[cfg(test)]
91mod tests_coalesce;
92#[cfg(test)]
93mod tests_create_defaults;
94#[cfg(test)]
95mod tests_descriptor;
96#[cfg(test)]
97mod tests_field_filter;
98#[cfg(test)]
99mod tests_filter_logic;
100#[cfg(test)]
101mod tests_geography;
102#[cfg(test)]
103mod tests_json;
104#[cfg(test)]
105mod tests_nested_relation_policy;
106#[cfg(test)]
107mod tests_optional;
108#[cfg(test)]
109mod tests_pgvector;
110#[cfg(test)]
111mod tests_policy_precedence_bug;
112#[cfg(test)]
113mod tests_read_policy_field_predicates;
114#[cfg(test)]
115mod tests_read_policy_predicates;
116#[cfg(test)]
117mod tests_relation;
118#[cfg(test)]
119mod tests_system_principal_policy;
120#[cfg(test)]
121mod tests_update;
122#[cfg(test)]
123mod tests_update_many;
124#[cfg(test)]
125mod tests_upsert_conflict_predicate;
126mod transaction;
127
128pub use partial_row::FromPartialPgRow;
129
130pub use json::Json;
131/// Re-exported so generated code (and the facade crates) can reach
132/// `::cratestack::pgvector::Vector` without depending on the
133/// `pgvector` crate directly — mirrors how `sqlx` above is re-exposed
134/// as a shim rather than depended on separately by every consumer.
135#[cfg(feature = "pgvector")]
136pub use pgvector;
137
138/// Row-decode adapter for PostGIS `geography`/`geometry` columns
139/// (cratestack#842) — re-exported so generated code can name
140/// `::cratestack::Ewkb` without depending on this crate's internals.
141#[cfg(feature = "postgis")]
142pub use spatial::Ewkb;
143
144pub use audit::{
145    AUDIT_TABLE_DDL, RunInTxOutcome, dispatch_audit_sink, primary_key_from_snapshot, snapshot_model,
146};
147pub use error::cratestack_error_from_sqlx;
148pub use idempotency::{SqlxIdempotencyStore, expiry_from};
149pub use isolation::{run_in_isolated_tx, run_in_isolated_tx_with_retries};
150pub use migrations::{
151    MIGRATIONS_TABLE_DDL, Migration, MigrationState, MigrationStatus, apply_pending,
152    ensure_migrations_table, status,
153};
154pub use transaction::Tx;
155
156pub use cratestack_policy::{PolicyExpr, PolicyLiteral, ReadPolicy, ReadPredicate};
157pub use cratestack_sql::{
158    CoalesceExpr, CoalesceFilter, ConflictTarget, CreateDefault, CreateDefaultType,
159    CreateModelInput, FieldRef, Filter, FilterExpr, FilterOp, IntoColumnName, IntoSqlValue,
160    JsonFilter, JsonTextPath, ModelColumn, ModelDescriptor, ModelPrimaryKey, NullOrder,
161    OrderClause, Orderable, Projection, RelationFilter, RelationHop, RelationInclude,
162    RelationQuantifier, SortDirection, SqlColumnValue, SqlValue, Unorderable, UpdateModelInput,
163    UpsertModelInput, VectorDistanceExpr, VectorDistanceFilter, VectorMetric, coalesce,
164    is_orderable, order_value_sql, wrap_filter,
165};
166/// PostGIS query surface (cratestack#842), gated in `cratestack-sql`
167/// and forwarded through this crate's own `postgis` feature.
168#[cfg(feature = "postgis")]
169pub use cratestack_sql::{SpatialDistanceExpr, SpatialFilter, SpatialPoint, point};
170pub use delegate::{
171    ModelDelegate, ScopedAggregate, ScopedAggregateColumn, ScopedAggregateCount, ScopedBatchCreate,
172    ScopedBatchDelete, ScopedBatchGet, ScopedBatchUpdate, ScopedBatchUpsert, ScopedCreateRecord,
173    ScopedDeleteMany, ScopedDeleteRecord, ScopedFindMany, ScopedFindManyWith, ScopedFindUnique,
174    ScopedModelDelegate, ScopedProjectedFindMany, ScopedProjectedFindUnique, ScopedUpdateMany,
175    ScopedUpdateManySet, ScopedUpdateRecord, ScopedUpdateRecordSet, ScopedUpsertRecord,
176    ScopedUpsertRecordDoNothing, ViewDelegate, ViewDelegateNoUnique,
177};
178pub use descriptor::{SqlxRuntime, enqueue_event_outbox, ensure_event_outbox_table};
179pub use query::{
180    Aggregate, AggregateColumn, AggregateCount, BatchCreate, BatchDelete, BatchGet, BatchUpdate,
181    BatchUpdateItem, BatchUpsert, CreateRecord, DeleteMany, DeleteRecord, FindMany, FindManyWith,
182    FindUnique, ProjectedFindMany, ProjectedFindUnique, UpdateMany, UpdateManySet, UpdateRecord,
183    UpdateRecordSet, UpsertOutcome, UpsertRecord, UpsertRecordDoNothing,
184    create_record_with_executor, update_record_with_executor,
185};
cratestack_sqlx/lib.rs

cratestack_sqlx/
lib.rs
