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 40 41 42 43 44 45 46 47 48 49 50 51 52 53
#[macro_export] macro_rules! bind_params_sqlx_postgres { ( $query:expr, $params:expr ) => { { let mut query = $query; for value in $params.iter() { query = match value { Value::Null => query.bind(None::<bool>), Value::Bool(v) => query.bind(v), Value::TinyInt(v) => query.bind(v), Value::SmallInt(v) => query.bind(v), Value::Int(v) => query.bind(v), Value::BigInt(v) => query.bind(v), Value::TinyUnsigned(v) => query.bind(*v as u32), Value::SmallUnsigned(v) => query.bind(*v as u32), Value::Unsigned(v) => query.bind(v), Value::BigUnsigned(v) => query.bind(*v as i64), Value::Float(v) => query.bind(v), Value::Double(v) => query.bind(v), Value::String(v) => query.bind(v.as_str()), Value::Bytes(v) => query.bind(v.as_ref()), #[cfg(feature="sqlx-json")] Value::Json(v) => query.bind(v.as_ref()), #[cfg(feature="sqlx-chrono")] Value::DateTime(v) => query.bind(v.as_ref()), _ => unimplemented!(), }; } query } }; } #[macro_export] macro_rules! sea_query_driver_postgres { () => { mod sea_query_driver_postgres { use sea_query::{Value, Values}; use sqlx::{query::Query, query::QueryAs, Postgres, postgres::PgArguments}; type SqlxQuery<'a> = sqlx::query::Query<'a, Postgres, PgArguments>; type SqlxQueryAs<'a, T> = sqlx::query::QueryAs<'a, Postgres, T, PgArguments>; pub fn bind_query<'a>(query: SqlxQuery<'a>, params: &'a Values) -> SqlxQuery<'a> { sea_query::bind_params_sqlx_postgres!(query, params.0) } pub fn bind_query_as<'a, T>(query: SqlxQueryAs<'a, T>, params: &'a Values) -> SqlxQueryAs<'a, T> { sea_query::bind_params_sqlx_postgres!(query, params.0) } } } }