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_mysql { ( $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), Value::SmallUnsigned(v) => query.bind(v), Value::Unsigned(v) => query.bind(v), Value::BigUnsigned(v) => query.bind(v), 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_mysql { () => { mod sea_query_driver_mysql { use sea_query::{Value, Values}; use sqlx::{query::Query, query::QueryAs, MySql, mysql::MySqlArguments}; type SqlxQuery<'a> = Query<'a, MySql, MySqlArguments>; type SqlxQueryAs<'a, T> = QueryAs<'a, MySql, T, MySqlArguments>; pub fn bind_query<'a>(query: SqlxQuery<'a>, params: &'a Values) -> SqlxQuery<'a> { sea_query::bind_params_sqlx_mysql!(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_mysql!(query, params.0) } } } }