distributed 4.8.0

CQRS/ES framework for Rust using Plain Old Rust Structs — append-only events, replay, snapshots, outbox, service bus, and pluggable infrastructure
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

//! Selection set -> single SQL statement per root field (dialect-portable JSON tree).
//!
//! # v1 join / PK assumptions
//!
//! Relationship SQL:
//! - **HasMany**: FK lives on the child -> `child.fk = parent.pk`
//!   (`foreign_key` lists child columns in parent-PK order)
//! - **BelongsTo**: FK lives on the parent -> `child.pk = parent.fk`
//!   (`foreign_key` lists parent columns in target-PK order)
//! - **ManyToMany**: through-table holds the full primary key of each end
//!   (same-named columns, or `foreign_key` / `target_foreign_key` listing
//!   through columns in PK order). Join helpers AND those equalities.
//!
//! Join equality is centralized in [`join_predicate_direct`] /
//! [`join_predicate_m2m_pairs`].
//! Dialect SQL fragments live on [`DialectOps`].
#![allow(clippy::only_used_in_recursion, clippy::too_many_arguments)]

mod binds;
mod dialect;
mod evidence;
mod filter;
mod projection;
mod relationship;

pub use binds::BindValue;
#[allow(unused_imports)]
pub use dialect::{DialectOps, SqlDialect};
#[allow(unused_imports)]
pub use projection::{
    compile_list_sql_for_test, compile_query, compile_root, selection_from_field, QueryPlan,
    RootKind, SelectionNode, SqlPlan,
};

#[allow(unused_imports)]
pub(crate) use dialect::{join_predicate_direct, join_predicate_m2m_pairs};
#[allow(unused_imports)]
pub(crate) use evidence::{ExtractedQueryEvidence, QueryRecordEvidence, QueryResponsePathSegment};
pub(crate) use projection::cell_row_matches;