use crate::prelude::*;
use drizzle_core::expr::Excluded;
use drizzle_core::{Placeholder, SQL, SQLColumnInfo, SQLParam, TypedPlaceholder};
use super::SQLiteValue;
use super::insert::ValueWrapper;
#[derive(Debug, Clone, Default)]
#[allow(clippy::large_enum_variant)]
pub enum SQLiteUpdateValue<'a, V: SQLParam, T> {
#[default]
Skip,
Null,
Value(ValueWrapper<'a, V, T>),
}
impl<V: SQLParam, T> SQLiteUpdateValue<'_, V, T> {
pub const fn is_skip(&self) -> bool {
matches!(self, Self::Skip)
}
}
impl<'a, T, U> From<T> for SQLiteUpdateValue<'a, SQLiteValue<'a>, U>
where
T: TryInto<SQLiteValue<'a>> + TryInto<U>,
U: TryInto<SQLiteValue<'a>>,
{
fn from(value: T) -> Self {
let sql = TryInto::<U>::try_into(value)
.map(|v| v.try_into().unwrap_or_default())
.map_or_else(
|_| SQL::from(SQLiteValue::Null),
|v: SQLiteValue<'a>| SQL::from(v),
);
SQLiteUpdateValue::Value(ValueWrapper::<SQLiteValue<'a>, T>::new(sql))
}
}
impl<'a, T> From<Placeholder> for SQLiteUpdateValue<'a, SQLiteValue<'a>, T> {
fn from(placeholder: Placeholder) -> Self {
use drizzle_core::{Param, SQLChunk};
let chunk = SQLChunk::Param(Param {
placeholder,
value: None,
});
SQLiteUpdateValue::Value(ValueWrapper::<SQLiteValue<'a>, T>::new(
core::iter::once(chunk).collect(),
))
}
}
impl<'a, M: drizzle_core::types::DataType, N: drizzle_core::expr::Nullability, T>
From<TypedPlaceholder<M, N>> for SQLiteUpdateValue<'a, SQLiteValue<'a>, T>
{
fn from(typed: TypedPlaceholder<M, N>) -> Self {
Placeholder::from(typed).into()
}
}
impl<'a, C, T> From<Excluded<C>> for SQLiteUpdateValue<'a, SQLiteValue<'a>, T>
where
C: SQLColumnInfo,
{
fn from(excluded: Excluded<C>) -> Self {
use drizzle_core::ToSQL;
let sql = excluded.to_sql();
SQLiteUpdateValue::Value(ValueWrapper::<SQLiteValue<'a>, T>::new(sql))
}
}
impl<'a, const N: usize> From<[u8; N]> for SQLiteUpdateValue<'a, SQLiteValue<'a>, Vec<u8>> {
fn from(value: [u8; N]) -> Self {
let sqlite_value = SQLiteValue::Blob(crate::prelude::Cow::Owned(value.to_vec()));
let sql = SQL::param(sqlite_value);
SQLiteUpdateValue::Value(ValueWrapper::<SQLiteValue<'a>, Vec<u8>>::new(sql))
}
}