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,
};
#[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)
}};
}