ormer 0.2.8

A minimalist ORM framework that supports SQLite, PostgreSQL, MySQL, and SqlServer
pub mod abstract_layer;
pub mod db_first;
pub mod error;
pub mod hooks;
pub mod migration;
pub mod model;
pub mod query;
pub mod raw_sql;
pub mod sql_trace;
mod time;
pub mod utils;

#[cfg(not(any(
    feature = "sqlite",
    feature = "postgresql",
    feature = "mysql",
    feature = "mssql",
    feature = "duckdb",
    feature = "clickhouse"
)))]
compile_error!(
    "At least one database feature must be enabled: sqlite, postgresql, mysql, mssql, duckdb, or clickhouse"
);

pub use abstract_layer::DbType;
pub use db_first::{
    DbFirstColumn, DbFirstForeignKey, DbFirstIndex, DbFirstIndexColumn, DbFirstTable,
};
pub use migration::{
    MIGRATION_TABLE_NAME, Migration, MigrationDryRun, MigrationDryRunStep,
    MigrationExecutionStatus, MigrationInfo, MigrationPlan, MigrationRunner, MigrationStep,
    TableMigration,
};

// 数据库相关类型 - 当启用任一数据库 feature 时可用
#[cfg(any(
    feature = "sqlite",
    feature = "postgresql",
    feature = "mysql",
    feature = "mssql",
    feature = "duckdb",
    feature = "clickhouse"
))]
pub use abstract_layer::{
    BatchFuture, BatchManyFuture, BatchQueries, BatchQuery, BatchQueryFuture, ConnectionPool,
    CreateTableExecutor, Database, DbExecutor, DeleteExecutor, DerivedTableCollectFuture,
    DerivedTableSelectExecutor, DoubleIncludedCollectFuture, DoubleIncludedSelectExecutor,
    DropTableExecutor, InsertGraphExecutor, InsertOrIgnoreExecutor, InsertPartialExecutor,
    IsolationLevel, MappedCollectFuture, MappedSelectExecutor, ModelCollectWithFuture,
    NestedInclude, PooledConnection, PooledDatabaseScope, PooledRawSelectExecutor,
    RawCollectFuture, RawSelectExecutor, RelationNestedLoader, ReplicatedConnectionPool,
    ReplicatedDatabase, ReplicatedDatabaseBuilder, ReplicatedPoolBuilder, SaveExecutor,
    ScopedDeleteExecutor, ScopedUpdateExecutor, SelectStream, SelectStreamIterator,
    SingleSqlStatement, SqlExecutor, SqlStatement, Transaction, TransactionFuture,
    TransactionInsertOrIgnoreExecutor, TransactionOptions, TransactionRawCollectFuture,
    TransactionRawSelectExecutor, TransactionSaveExecutor, UpdateGraphExecutor,
    WithoutHooksExecutor,
};
pub use error::{ConstraintKind, DatabaseErrorKind, OrmerError, Result};
pub use hooks::{HookContext, HookOperation};
pub use model::{
    ActiveValue, AfterDelete, AfterInsert, AfterUpdate, BeforeDelete, BeforeInsert, BeforeUpdate,
    CompressionAlgorithm, DbValue, Embed, EmbedWhere, FieldType, FieldTypeProvider, FromRowValues,
    FromSingleValue, FromValue, GraphWritable, InsertModel, Insertable, Model, ModelEnum,
    ModelEnumProvider, NoInclude, PrimaryFields, PrimaryKey, Relation, RelationHandle,
    RelationInfo, RelationKind, RelationPathInfo, RelationQuery, RelationSelection, Row,
    TableRoute, TableRouteValue, ThroughInfo, ThroughRelation, TrackableModel, Tracked, Value,
    TableOptions, ViewModel, WritableModel, generate_create_table_sql,
    generate_create_table_sql_with_name,
};
#[cfg(feature = "clickhouse")]
pub use model::{
    generate_clickhouse_create_table_sql, generate_clickhouse_create_table_sql_with_name,
};
pub use ormer_derive::{DbValue, Embed, FieldType, InsertModel, Model, ModelEnum, ViewModel, raw};
pub use query::builder::{
    AgeColumn, CursorPage, DerivedSelect, DerivedTableSelect, DynamicColumn, DynamicColumnSet,
    FilterQuery, GroupByColumns, GroupedSelect, InnerJoinedSelect, IntoArrayValue,
    IntoGroupingSets, IntoJsonPath, IntoJsonScalar, IsInValue, IsInValues, LeftJoinedSelect,
    MapToResult, MappedSelect, MultiTableSelect, NamedFilterQuery, NumericColumn, PageCursor,
    RecursiveColumns, RelatedSelect, RightJoinedSelect, RowValueCompare, Select,
    SelectColumnResult, SetOp, StaticJsonArrayExpr, StaticJsonExpr, StaticJsonUpdate,
    SubqueryParam, UnionSelect, WhereColumn, WhereExpr, WithoutFilterQuery, from_derived,
};
pub use query::expr::{
    CaseMatchBuilder, IntoRowExpr, IntoSqlExpr, IntoTypedExpr, RawExpr, RawExprSegment, RawSqlExpr,
    JsonScalarKind, SqlExpr, TypedExpr, WindowSpecBuilder, case_match, raw, row, value,
    IntervalExpr, NowExpr, TimePart, TimeUnit, days, hours, minutes, now, seconds,
};
pub use query::filter::{FilterExpr, OrderBy, OrderDirection};
pub use query::filter::{FullTextMode, FullTextQuery, FullTextRank};
pub use query::insert::{
    ConflictColumns, InsertAssignment, InsertConflict, InsertConflictAction, InsertConflictTarget,
    InsertValue, IntoInsertAssignment, IntoInsertConflictTarget, IntoInsertDefaultColumn,
};
pub use query::update::{
    UpdateAssignment, UpdateBinaryOp, UpdateExpr, UpdateField, UpdateFields, UpdateValue,
};
pub use raw_sql::{IntoRawSql, RawSql, sql};
pub use sql_trace::{SqlTrace, SqlTraceBuilder, SqlTraceEvent, global_sql_trace};

#[doc(hidden)]
#[macro_export]
macro_rules! ormer_error {
    ($fmt:literal $(, $arg:expr)* $(,)?) => {
        $crate::OrmerError::other(format!($fmt $(, $arg)*))
    };
    ($msg:expr $(,)?) => {
        $crate::OrmerError::other($msg)
    };
}

#[macro_export]
macro_rules! expr {
    (match $obj:ident . $field:ident { $($pat:literal => $value:expr,)* _ => $default:expr $(,)? }) => {{
        let mut builder = $crate::query::expr::case_match($obj.$field);
        $(
            builder = builder.when($pat, $value);
        )*
        builder.otherwise($default)
    }};
    (match ($expr:expr) { $($pat:literal => $value:expr,)* _ => $default:expr $(,)? }) => {{
        let mut builder = $crate::query::expr::case_match($expr);
        $(
            builder = builder.when($pat, $value);
        )*
        builder.otherwise($default)
    }};
}