diesel 2.4.0

use crate::backend::Backend;
use crate::deserialize::{self, FromSql, FromSqlRef, Queryable};
#[cfg(feature = "std")]
use crate::query_builder::bind_collector::RawBytesBindCollector;
use crate::serialize::{self, Output, ToSql};
use crate::sql_types::{
    self, BigInt, Binary, Bool, Double, Float, Integer, SingleValue, SmallInt, Text,
};
use alloc::borrow::Cow;
use alloc::borrow::ToOwned;
use alloc::boxed::Box;
use alloc::fmt;
use alloc::string::String;
use alloc::vec::Vec;

#[allow(dead_code)]
mod foreign_impls {
    use super::*;
    use crate::deserialize::FromSqlRow;

    #[derive(AsExpression, FromSqlRow)]
    #[diesel(foreign_derive)]
    #[diesel(sql_type = Bool)]
    struct BoolProxy(bool);

    #[derive(FromSqlRow)]
    #[cfg_attr(
        any(feature = "mysql_backend", feature = "mariadb_backend"),
        derive(AsExpression)
    )]
    #[diesel(foreign_derive)]
    #[cfg_attr(any(feature = "mysql_backend", feature = "mariadb_backend"), diesel(sql_type = crate::sql_types::TinyInt))]
    struct I8Proxy(i8);

    #[derive(AsExpression, FromSqlRow)]
    #[diesel(foreign_derive)]
    #[diesel(sql_type = SmallInt)]
    struct I16Proxy(i16);

    #[derive(AsExpression, FromSqlRow)]
    #[diesel(foreign_derive)]
    #[diesel(sql_type = Integer)]
    struct I32Proxy(i32);

    #[derive(AsExpression, FromSqlRow)]
    #[diesel(foreign_derive)]
    #[diesel(sql_type = BigInt)]
    struct I64Proxy(i64);

    #[derive(FromSqlRow)]
    #[cfg_attr(
        any(
            feature = "mysql_backend",
            feature = "postgres_backend",
            feature = "mariadb_backend"
        ),
        derive(AsExpression)
    )]
    #[diesel(foreign_derive)]
    #[cfg_attr(
        any(feature = "mysql_backend", feature = "mariadb_backend"),
        diesel(sql_type = crate::sql_types::Unsigned<crate::sql_types::TinyInt>)
    )]
    #[cfg_attr(feature = "postgres_backend", diesel(foreign_derive, sql_type = crate::sql_types::CChar))]
    struct U8Proxy(u8);

    #[derive(FromSqlRow)]
    #[cfg_attr(
        any(feature = "mysql_backend", feature = "mariadb_backend"),
        derive(AsExpression)
    )]
    #[diesel(foreign_derive)]
    #[cfg_attr(any(feature = "mysql_backend", feature = "mariadb_backend"), diesel(sql_type = crate::sql_types::Unsigned<SmallInt>))]
    struct U16Proxy(u16);

    #[derive(FromSqlRow)]
    #[cfg_attr(
        any(
            feature = "mysql_backend",
            feature = "mariadb_backend",
            feature = "postgres_backend"
        ),
        derive(AsExpression)
    )]
    #[diesel(foreign_derive)]
    #[cfg_attr(any(feature = "mysql_backend", feature = "mariadb_backend"), diesel(sql_type = crate::sql_types::Unsigned<Integer>))]
    #[cfg_attr(feature = "postgres_backend", diesel(sql_type = crate::sql_types::Oid))]
    struct U32Proxy(u32);

    #[derive(FromSqlRow)]
    #[cfg_attr(
        any(feature = "mysql_backend", feature = "mariadb_backend"),
        derive(AsExpression)
    )]
    #[diesel(foreign_derive)]
    #[cfg_attr(any(feature = "mysql_backend", feature = "mariadb_backend"), diesel(sql_type = crate::sql_types::Unsigned<BigInt>))]
    struct U64Proxy(u64);

    #[derive(AsExpression, FromSqlRow)]
    #[diesel(foreign_derive)]
    #[diesel(sql_type = Float)]
    struct F32Proxy(f32);

    #[derive(AsExpression, FromSqlRow)]
    #[diesel(foreign_derive)]
    #[diesel(sql_type = Double)]
    struct F64Proxy(f64);

    #[derive(AsExpression, FromSqlRow)]
    #[diesel(foreign_derive)]
    #[diesel(sql_type = Text)]
    #[cfg_attr(feature = "__sqlite-shared", diesel(sql_type = crate::sql_types::Date))]
    #[cfg_attr(feature = "__sqlite-shared", diesel(sql_type = crate::sql_types::Time))]
    #[cfg_attr(feature = "__sqlite-shared", diesel(sql_type = crate::sql_types::Timestamp))]
    #[cfg_attr(feature = "postgres_backend", diesel(sql_type = crate::sql_types::Citext))]
    #[cfg_attr(feature = "postgres_backend", diesel(sql_type = crate::pg::sql_types::Bpchar))]
    struct StringProxy(String);

    #[derive(AsExpression)]
    #[diesel(foreign_derive, not_sized)]
    #[diesel(sql_type = Text)]
    #[cfg_attr(feature = "__sqlite-shared", diesel(sql_type = crate::sql_types::Date))]
    #[cfg_attr(feature = "__sqlite-shared", diesel(sql_type = crate::sql_types::Time))]
    #[cfg_attr(feature = "__sqlite-shared", diesel(sql_type = crate::sql_types::Timestamp))]
    #[cfg_attr(feature = "postgres_backend", diesel(sql_type = crate::sql_types::Citext))]
    #[cfg_attr(feature = "postgres_backend", diesel(sql_type = crate::pg::sql_types::Bpchar))]
    struct StrProxy(str);

    #[derive(FromSqlRow)]
    #[diesel(foreign_derive)]
    struct VecProxy<T>(Vec<T>);

    #[derive(AsExpression)]
    #[diesel(foreign_derive)]
    #[diesel(sql_type = Binary)]
    struct BinaryVecProxy(Vec<u8>);

    #[derive(AsExpression)]
    #[diesel(foreign_derive, not_sized)]
    #[diesel(sql_type = Binary)]
    struct BinarySliceProxy([u8]);

    #[derive(AsExpression)]
    #[diesel(foreign_derive)]
    #[diesel(sql_type = Binary)]
    struct BinaryArrayProxy<const N: usize>([u8; N]);
}

#[diagnostic::do_not_recommend]
impl<ST, DB> FromSql<ST, DB> for String
where
    DB: Backend,
    for<'a> &'a str: FromSqlRef<'a, ST, DB>,
{
    fn from_sql(mut bytes: DB::RawValue<'_>) -> deserialize::Result<Self> {
        <&str as FromSqlRef<'_, ST, DB>>::from_sql(&mut bytes).map(|v| v.to_owned())
    }
}

#[cfg(feature = "std")]
impl<DB> ToSql<sql_types::Text, DB> for str
where
    for<'a> DB: Backend<BindCollector<'a> = RawBytesBindCollector<DB>>,
{
    fn to_sql<'b>(&'b self, out: &mut Output<'b, '_, DB>) -> serialize::Result {
        use alloc::boxed::Box;
        use std::io::Write;

        out.write_all(self.as_bytes())
            .map(|_| crate::serialize::IsNull::No)
            .map_err(|e| Box::new(e) as Box<dyn core::error::Error + Send + Sync>)
    }
}

impl<DB> ToSql<sql_types::Text, DB> for String
where
    DB: Backend,
    str: ToSql<sql_types::Text, DB>,
{
    fn to_sql<'b>(&'b self, out: &mut Output<'b, '_, DB>) -> serialize::Result {
        (self as &str).to_sql(out)
    }
}

impl<ST, DB> FromSql<ST, DB> for Vec<u8>
where
    DB: Backend,
    for<'a> &'a [u8]: FromSqlRef<'a, ST, DB>,
{
    fn from_sql(mut bytes: DB::RawValue<'_>) -> deserialize::Result<Self> {
        <&[u8] as FromSqlRef<'_, ST, DB>>::from_sql(&mut bytes).map(|v| v.to_owned())
    }
}

impl<DB> ToSql<sql_types::Binary, DB> for Vec<u8>
where
    DB: Backend,
    [u8]: ToSql<sql_types::Binary, DB>,
{
    fn to_sql<'b>(&'b self, out: &mut Output<'b, '_, DB>) -> serialize::Result {
        (self as &[u8]).to_sql(out)
    }
}

impl<DB, const N: usize> ToSql<sql_types::Binary, DB> for [u8; N]
where
    DB: Backend,
    [u8]: ToSql<sql_types::Binary, DB>,
{
    fn to_sql<'b>(&'b self, out: &mut Output<'b, '_, DB>) -> serialize::Result {
        self.as_slice().to_sql(out)
    }
}

#[cfg(feature = "std")]
impl<DB> ToSql<sql_types::Binary, DB> for [u8]
where
    for<'a> DB: Backend<BindCollector<'a> = RawBytesBindCollector<DB>>,
{
    fn to_sql<'b>(&'b self, out: &mut Output<'b, '_, DB>) -> serialize::Result {
        use alloc::boxed::Box;
        use std::io::Write;

        out.write_all(self)
            .map(|_| crate::serialize::IsNull::No)
            .map_err(|e| Box::new(e) as Box<dyn core::error::Error + Send + Sync>)
    }
}

impl<'a, T: ?Sized, ST, DB> ToSql<ST, DB> for Cow<'a, T>
where
    T: 'a + ToOwned + ToSql<ST, DB>,
    DB: Backend,
    Self: fmt::Debug,
{
    fn to_sql<'b>(&'b self, out: &mut Output<'b, '_, DB>) -> serialize::Result {
        ToSql::<ST, DB>::to_sql(&**self, out)
    }
}

impl<'a, T: ?Sized, ST, DB> FromSql<ST, DB> for Cow<'a, T>
where
    T: 'a + ToOwned,
    DB: Backend,
    T::Owned: FromSql<ST, DB>,
{
    fn from_sql(bytes: DB::RawValue<'_>) -> deserialize::Result<Self> {
        T::Owned::from_sql(bytes).map(Cow::Owned)
    }
}

impl<'a, T: ?Sized, ST, DB> Queryable<ST, DB> for Cow<'a, T>
where
    T: 'a + ToOwned,
    ST: SingleValue,
    DB: Backend,
    Self: FromSql<ST, DB>,
{
    type Row = Self;

    fn build(row: Self::Row) -> deserialize::Result<Self> {
        Ok(row)
    }
}

use crate::expression::bound::Bound;
use crate::expression::{AsExpression, Expression, TypedExpressionType};
use sql_types::SqlType;

impl<'a, T: ?Sized, ST> AsExpression<ST> for Cow<'a, T>
where
    T: 'a + ToOwned,
    Bound<ST, Cow<'a, T>>: Expression<SqlType = ST>,
    ST: SqlType + TypedExpressionType,
{
    type Expression = Bound<ST, Self>;

    fn as_expression(self) -> Self::Expression {
        Bound::new(self)
    }
}

impl<'a, 'b, T: ?Sized, ST> AsExpression<ST> for &'b Cow<'a, T>
where
    T: 'a + ToOwned,
    Bound<ST, &'b T>: Expression<SqlType = ST>,
    ST: SqlType + TypedExpressionType,
{
    type Expression = Bound<ST, &'b T>;

    fn as_expression(self) -> Self::Expression {
        Bound::new(&**self)
    }
}

impl<T: ?Sized, ST, DB> ToSql<ST, DB> for Box<T>
where
    T: ToSql<ST, DB>,
    DB: Backend,
    Self: fmt::Debug,
{
    fn to_sql<'b>(&'b self, out: &mut Output<'b, '_, DB>) -> serialize::Result {
        ToSql::<ST, DB>::to_sql(&**self, out)
    }
}

impl<T, ST, DB> FromSql<ST, DB> for Box<T>
where
    DB: Backend,
    T: FromSql<ST, DB>,
{
    fn from_sql(bytes: DB::RawValue<'_>) -> deserialize::Result<Self> {
        T::from_sql(bytes).map(Box::from)
    }
}

impl<T: ?Sized, ST, DB> Queryable<ST, DB> for Box<T>
where
    ST: SingleValue,
    DB: Backend,
    Self: FromSql<ST, DB>,
{
    type Row = Self;

    fn build(row: Self::Row) -> deserialize::Result<Self> {
        Ok(row)
    }
}

impl<T: ?Sized, ST, DB> ToSql<ST, DB> for alloc::rc::Rc<T>
where
    T: ToSql<ST, DB>,
    DB: Backend,
    Self: fmt::Debug,
{
    fn to_sql<'b>(&'b self, out: &mut Output<'b, '_, DB>) -> serialize::Result {
        ToSql::<ST, DB>::to_sql(&**self, out)
    }
}

impl<T, ST, DB> FromSql<ST, DB> for alloc::rc::Rc<T>
where
    DB: Backend,
    T: FromSql<ST, DB>,
{
    fn from_sql(bytes: DB::RawValue<'_>) -> deserialize::Result<Self> {
        T::from_sql(bytes).map(alloc::rc::Rc::from)
    }
}

impl<T: ?Sized, ST, DB> Queryable<ST, DB> for alloc::rc::Rc<T>
where
    ST: SingleValue,
    DB: Backend,
    Self: FromSql<ST, DB>,
{
    type Row = Self;

    fn build(row: Self::Row) -> deserialize::Result<Self> {
        Ok(row)
    }
}

impl<T: ?Sized, ST, DB> ToSql<ST, DB> for alloc::sync::Arc<T>
where
    T: ToSql<ST, DB>,
    DB: Backend,
    Self: fmt::Debug,
{
    fn to_sql<'b>(&'b self, out: &mut Output<'b, '_, DB>) -> serialize::Result {
        ToSql::<ST, DB>::to_sql(&**self, out)
    }
}

impl<T, ST, DB> FromSql<ST, DB> for alloc::sync::Arc<T>
where
    DB: Backend,
    T: FromSql<ST, DB>,
{
    fn from_sql(bytes: DB::RawValue<'_>) -> deserialize::Result<Self> {
        T::from_sql(bytes).map(alloc::sync::Arc::from)
    }
}

impl<T: ?Sized, ST, DB> Queryable<ST, DB> for alloc::sync::Arc<T>
where
    ST: SingleValue,
    DB: Backend,
    Self: FromSql<ST, DB>,
{
    type Row = Self;

    fn build(row: Self::Row) -> deserialize::Result<Self> {
        Ok(row)
    }
}

// `FromSql` for the unsized-inner-type cases (`Box<str>`, `Rc<str>`, `Arc<str>`,
// and the `[u8]` equivalents). The generic `FromSql for Box<T> where T: FromSql`
// blanket above can't cover these because `str`/`[u8]` are `!Sized` and cannot
// implement `FromSql` themselves. Instead we go through `FromSqlRef` for `&str` /
// `&[u8]` and then build the smart pointer with `Box::from` / `Rc::from` / `Arc::from`,
// which all accept `&str` or `&[u8]` and allocate a sized backing buffer.

impl<ST, DB> FromSql<ST, DB> for Box<str>
where
    DB: Backend,
    for<'a> &'a str: FromSqlRef<'a, ST, DB>,
{
    fn from_sql(mut bytes: DB::RawValue<'_>) -> deserialize::Result<Self> {
        <&str as FromSqlRef<'_, ST, DB>>::from_sql(&mut bytes).map(Box::from)
    }
}

impl<ST, DB> FromSql<ST, DB> for alloc::rc::Rc<str>
where
    DB: Backend,
    for<'a> &'a str: FromSqlRef<'a, ST, DB>,
{
    fn from_sql(mut bytes: DB::RawValue<'_>) -> deserialize::Result<Self> {
        <&str as FromSqlRef<'_, ST, DB>>::from_sql(&mut bytes).map(alloc::rc::Rc::from)
    }
}

impl<ST, DB> FromSql<ST, DB> for alloc::sync::Arc<str>
where
    DB: Backend,
    for<'a> &'a str: FromSqlRef<'a, ST, DB>,
{
    fn from_sql(mut bytes: DB::RawValue<'_>) -> deserialize::Result<Self> {
        <&str as FromSqlRef<'_, ST, DB>>::from_sql(&mut bytes).map(alloc::sync::Arc::from)
    }
}

impl<ST, DB> FromSql<ST, DB> for Box<[u8]>
where
    DB: Backend,
    for<'a> &'a [u8]: FromSqlRef<'a, ST, DB>,
{
    fn from_sql(mut bytes: DB::RawValue<'_>) -> deserialize::Result<Self> {
        <&[u8] as FromSqlRef<'_, ST, DB>>::from_sql(&mut bytes).map(Box::from)
    }
}

impl<ST, DB> FromSql<ST, DB> for alloc::rc::Rc<[u8]>
where
    DB: Backend,
    for<'a> &'a [u8]: FromSqlRef<'a, ST, DB>,
{
    fn from_sql(mut bytes: DB::RawValue<'_>) -> deserialize::Result<Self> {
        <&[u8] as FromSqlRef<'_, ST, DB>>::from_sql(&mut bytes).map(alloc::rc::Rc::from)
    }
}

impl<ST, DB> FromSql<ST, DB> for alloc::sync::Arc<[u8]>
where
    DB: Backend,
    for<'a> &'a [u8]: FromSqlRef<'a, ST, DB>,
{
    fn from_sql(mut bytes: DB::RawValue<'_>) -> deserialize::Result<Self> {
        <&[u8] as FromSqlRef<'_, ST, DB>>::from_sql(&mut bytes).map(alloc::sync::Arc::from)
    }
}