diesel/query_builder/insert_statement/

insert_with_default_for_sqlite.rs

use super::{BatchInsert, InsertStatement};
use crate::insertable::{
    CanInsertInSingleQuery, ColumnInsertValue, DefaultableColumnInsertValue, InsertValues,
};
use crate::prelude::*;
use crate::query_builder::debug_query::DebugBinds;
use crate::query_builder::returning::ReturningClause;
use crate::query_builder::upsert::on_conflict_clause::OnConflictValues;
use crate::query_builder::{
    AstPass, DebugQuery, QueryBuilder, QueryFragment, QueryId, ValuesClause,
};
use crate::query_dsl::LoadQuery;
use crate::query_dsl::methods::ExecuteDsl;
use crate::sqlite::{Sqlite, SqliteQueryBuilder};
use alloc::string::{String, ToString};
use alloc::vec::Vec;
use core::fmt::{self, Debug, Display};

pub trait DebugQueryHelper<ContainsDefaultableValue> {
    fn fmt_debug(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result;
    fn fmt_display(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result;
}

impl<T, V, QId, Op, Ret, const STATIC_QUERY_ID: bool> DebugQueryHelper<Yes>
    for DebugQuery<
        '_,
        InsertStatement<T, BatchInsert<Vec<ValuesClause<V, T>>, T, QId, STATIC_QUERY_ID>, Op, Ret>,
        Sqlite,
    >
where
    V: QueryFragment<Sqlite>,
    T: Copy + QuerySource,
    Op: Copy,
    Ret: Copy,
    for<'b> InsertStatement<T, &'b ValuesClause<V, T>, Op, Ret>: QueryFragment<Sqlite>,
{
    fn fmt_debug(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
        let mut statements = alloc::vec![String::from("BEGIN")];
        for record in self.query.records.values.iter() {
            let stmt = InsertStatement::new(
                self.query.target,
                record,
                self.query.operator,
                self.query.returning,
            );
            statements.push(crate::debug_query(&stmt).to_string());
        }
        statements.push("COMMIT".into());

        f.debug_struct("Query")
            .field("sql", &statements)
            .field("binds", &[] as &[i32; 0])
            .finish()
    }

    fn fmt_display(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
        writeln!(f, "BEGIN;")?;
        for record in self.query.records.values.iter() {
            let stmt = InsertStatement::new(
                self.query.target,
                record,
                self.query.operator,
                self.query.returning,
            );
            writeln!(f, "{}", crate::debug_query(&stmt))?;
        }
        writeln!(f, "COMMIT;")?;
        Ok(())
    }
}

impl<'a, T, V, QId, Op, const STATIC_QUERY_ID: bool> DebugQueryHelper<No>
    for DebugQuery<
        'a,
        InsertStatement<T, BatchInsert<Vec<ValuesClause<V, T>>, T, QId, STATIC_QUERY_ID>, Op>,
        Sqlite,
    >
where
    T: Copy + Table,
    Op: Copy + QueryFragment<Sqlite>,
    SqliteBatchInsertWrapper<Vec<ValuesClause<V, T>>, T, QId, STATIC_QUERY_ID>:
        QueryFragment<Sqlite>,
    V: CanInsertInSingleQuery<Sqlite>,
    T::FromClause: QueryFragment<Sqlite>,
{
    fn fmt_debug(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
        self.fmt_helper(f, crate::query_builder::debug_query::debug)
    }

    fn fmt_display(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
        self.fmt_helper(f, crate::query_builder::debug_query::display)
    }
}

#[allow(unsafe_code)] // cast to transparent wrapper type
impl<'a, T, V, QId, Op, const STATIC_QUERY_ID: bool>
    DebugQuery<
        'a,
        InsertStatement<T, BatchInsert<Vec<ValuesClause<V, T>>, T, QId, STATIC_QUERY_ID>, Op>,
        Sqlite,
    >
where
    T: Copy + Table,
    Op: Copy + QueryFragment<Sqlite>,
    SqliteBatchInsertWrapper<Vec<ValuesClause<V, T>>, T, QId, STATIC_QUERY_ID>:
        QueryFragment<Sqlite>,
    V: CanInsertInSingleQuery<Sqlite>,
    T::FromClause: QueryFragment<Sqlite>,
{
    fn fmt_helper(
        &self,
        f: &mut fmt::Formatter<'_>,
        formatter: fn(String, &DebugBinds<'_>, &mut fmt::Formatter<'_>) -> fmt::Result,
    ) -> fmt::Result {
        // explicit destruct to make sure we use all  the fields
        let InsertStatement {
            operator,
            target: _,
            records,
            returning,
            into_clause,
        } = self.query;
        let records = unsafe {
            // SAFETY:
            // * SqliteBatchInsertWrapper is `#[repr(transparent)]` so this cast
            // is allowed
            &*(records as *const _
                as *const SqliteBatchInsertWrapper<
                    Vec<ValuesClause<V, T>>,
                    T,
                    QId,
                    STATIC_QUERY_ID,
                >)
        };
        let mut buffer = Vec::new();
        let ast_pass = AstPass::debug_binds(&mut buffer, &Sqlite);
        super::insert_statement::walk_ast_intern::<T, _, _, _, Sqlite>(
            ast_pass,
            records,
            into_clause,
            operator,
            returning,
        )
        .map_err(|_| fmt::Error)?;
        let mut query_builder = SqliteQueryBuilder::default();
        let mut ast_pass_to_sql_options = Default::default();
        let sql_pass = AstPass::to_sql(&mut query_builder, &mut ast_pass_to_sql_options, &Sqlite);
        super::insert_statement::walk_ast_intern::<T, _, _, _, Sqlite>(
            sql_pass,
            records,
            into_clause,
            operator,
            returning,
        )
        .map_err(|_| fmt::Error)?;
        let query = query_builder.finish();
        let debug_binds = crate::query_builder::debug_query::DebugBinds::new(&buffer);
        formatter(query, &debug_binds, f)
    }
}

impl<T, V, QId, Op, O, const STATIC_QUERY_ID: bool> Display
    for DebugQuery<
        '_,
        InsertStatement<T, BatchInsert<Vec<ValuesClause<V, T>>, T, QId, STATIC_QUERY_ID>, Op>,
        Sqlite,
    >
where
    T: QuerySource,
    V: ContainsDefaultableValue<Out = O>,
    Self: DebugQueryHelper<O>,
{
    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
        self.fmt_display(f)
    }
}

impl<T, V, QId, Op, O, const STATIC_QUERY_ID: bool> Debug
    for DebugQuery<
        '_,
        InsertStatement<T, BatchInsert<Vec<ValuesClause<V, T>>, T, QId, STATIC_QUERY_ID>, Op>,
        Sqlite,
    >
where
    T: QuerySource,
    V: ContainsDefaultableValue<Out = O>,
    Self: DebugQueryHelper<O>,
{
    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
        self.fmt_debug(f)
    }
}

#[allow(missing_debug_implementations, missing_copy_implementations)]
pub struct Yes;

impl Default for Yes {
    fn default() -> Self {
        Yes
    }
}

#[allow(missing_debug_implementations, missing_copy_implementations)]
pub struct No;

impl Default for No {
    fn default() -> Self {
        No
    }
}

pub trait Any<Rhs> {
    type Out: Any<Yes> + Any<No>;
}

impl Any<No> for No {
    type Out = No;
}

impl Any<Yes> for No {
    type Out = Yes;
}

impl Any<No> for Yes {
    type Out = Yes;
}

impl Any<Yes> for Yes {
    type Out = Yes;
}

pub trait ContainsDefaultableValue {
    type Out: Any<Yes> + Any<No>;
}

impl<C, B> ContainsDefaultableValue for ColumnInsertValue<C, B> {
    type Out = No;
}

impl<I> ContainsDefaultableValue for DefaultableColumnInsertValue<I> {
    type Out = Yes;
}

impl<I, const SIZE: usize> ContainsDefaultableValue for [I; SIZE]
where
    I: ContainsDefaultableValue,
{
    type Out = I::Out;
}

impl<I, T> ContainsDefaultableValue for ValuesClause<I, T>
where
    I: ContainsDefaultableValue,
{
    type Out = I::Out;
}

impl<T> ContainsDefaultableValue for &T
where
    T: ContainsDefaultableValue,
{
    type Out = T::Out;
}

impl<V, T, QId, C, Op, O, const STATIC_QUERY_ID: bool> ExecuteDsl<C, Sqlite>
    for InsertStatement<T, BatchInsert<Vec<ValuesClause<V, T>>, T, QId, STATIC_QUERY_ID>, Op>
where
    T: QuerySource,
    C: Connection<Backend = Sqlite>,
    V: ContainsDefaultableValue<Out = O>,
    O: Default,
    (O, Self): ExecuteDsl<C, Sqlite>,
{
    fn execute(query: Self, conn: &mut C) -> QueryResult<usize> {
        <(O, Self) as ExecuteDsl<C, Sqlite>>::execute((O::default(), query), conn)
    }
}

impl<V, T, QId, C, Op, O, Target, ConflictOpt, const STATIC_QUERY_ID: bool> ExecuteDsl<C, Sqlite>
    for InsertStatement<
        T,
        OnConflictValues<
            BatchInsert<Vec<ValuesClause<V, T>>, T, QId, STATIC_QUERY_ID>,
            Target,
            ConflictOpt,
        >,
        Op,
    >
where
    T: QuerySource,
    C: Connection<Backend = Sqlite>,
    V: ContainsDefaultableValue<Out = O>,
    O: Default,
    (O, Self): ExecuteDsl<C, Sqlite>,
{
    fn execute(query: Self, conn: &mut C) -> QueryResult<usize> {
        <(O, Self) as ExecuteDsl<C, Sqlite>>::execute((O::default(), query), conn)
    }
}

impl<V, T, QId, C, Op, const STATIC_QUERY_ID: bool> ExecuteDsl<C, Sqlite>
    for (
        Yes,
        InsertStatement<T, BatchInsert<Vec<ValuesClause<V, T>>, T, QId, STATIC_QUERY_ID>, Op>,
    )
where
    C: Connection<Backend = Sqlite>,
    T: Table + Copy + QueryId + 'static,
    T::FromClause: QueryFragment<Sqlite>,
    Op: Copy + QueryId + QueryFragment<Sqlite>,
    V: InsertValues<Sqlite, T> + CanInsertInSingleQuery<Sqlite> + QueryId,
{
    fn execute((Yes, query): Self, conn: &mut C) -> QueryResult<usize> {
        conn.transaction(|conn| {
            let mut result = 0;
            for record in &query.records.values {
                let stmt =
                    InsertStatement::new(query.target, record, query.operator, query.returning);
                result += stmt.execute(conn)?;
            }
            Ok(result)
        })
    }
}

impl<'query, V, T, QId, Op, O, U, B, const STATIC_QUERY_ID: bool>
    LoadQuery<'query, SqliteConnection, U, B>
    for InsertStatement<T, BatchInsert<Vec<ValuesClause<V, T>>, T, QId, STATIC_QUERY_ID>, Op>
where
    T: QuerySource,
    V: ContainsDefaultableValue<Out = O>,
    O: Default,
    (O, Self): LoadQuery<'query, SqliteConnection, U, B>,
{
    type RowIter<'conn> = <(O, Self) as LoadQuery<'query, SqliteConnection, U, B>>::RowIter<'conn>;

    fn internal_load(self, conn: &mut SqliteConnection) -> QueryResult<Self::RowIter<'_>> {
        <(O, Self) as LoadQuery<'query, SqliteConnection, U, B>>::internal_load(
            (O::default(), self),
            conn,
        )
    }
}

impl<'query, V, T, QId, Op, Ret, O, U, B, const STATIC_QUERY_ID: bool>
    LoadQuery<'query, SqliteConnection, U, B>
    for InsertStatement<
        T,
        BatchInsert<Vec<ValuesClause<V, T>>, T, QId, STATIC_QUERY_ID>,
        Op,
        ReturningClause<Ret>,
    >
where
    T: QuerySource,
    V: ContainsDefaultableValue<Out = O>,
    O: Default,
    (O, Self): LoadQuery<'query, SqliteConnection, U, B>,
{
    type RowIter<'conn> = <(O, Self) as LoadQuery<'query, SqliteConnection, U, B>>::RowIter<'conn>;

    fn internal_load(self, conn: &mut SqliteConnection) -> QueryResult<Self::RowIter<'_>> {
        <(O, Self) as LoadQuery<'query, SqliteConnection, U, B>>::internal_load(
            (O::default(), self),
            conn,
        )
    }
}

impl<'query, V, T, QId, Op, O, U, B, Target, ConflictOpt, const STATIC_QUERY_ID: bool>
    LoadQuery<'query, SqliteConnection, U, B>
    for InsertStatement<
        T,
        OnConflictValues<
            BatchInsert<Vec<ValuesClause<V, T>>, T, QId, STATIC_QUERY_ID>,
            Target,
            ConflictOpt,
        >,
        Op,
    >
where
    T: QuerySource,
    V: ContainsDefaultableValue<Out = O>,
    O: Default,
    (O, Self): LoadQuery<'query, SqliteConnection, U, B>,
{
    type RowIter<'conn> = <(O, Self) as LoadQuery<'query, SqliteConnection, U, B>>::RowIter<'conn>;

    fn internal_load(self, conn: &mut SqliteConnection) -> QueryResult<Self::RowIter<'_>> {
        <(O, Self) as LoadQuery<'query, SqliteConnection, U, B>>::internal_load(
            (O::default(), self),
            conn,
        )
    }
}

impl<'query, V, T, QId, Op, Ret, O, U, B, Target, ConflictOpt, const STATIC_QUERY_ID: bool>
    LoadQuery<'query, SqliteConnection, U, B>
    for InsertStatement<
        T,
        OnConflictValues<
            BatchInsert<Vec<ValuesClause<V, T>>, T, QId, STATIC_QUERY_ID>,
            Target,
            ConflictOpt,
        >,
        Op,
        ReturningClause<Ret>,
    >
where
    T: QuerySource,
    V: ContainsDefaultableValue<Out = O>,
    O: Default,
    (O, Self): LoadQuery<'query, SqliteConnection, U, B>,
{
    type RowIter<'conn> = <(O, Self) as LoadQuery<'query, SqliteConnection, U, B>>::RowIter<'conn>;

    fn internal_load(self, conn: &mut SqliteConnection) -> QueryResult<Self::RowIter<'_>> {
        <(O, Self) as LoadQuery<'query, SqliteConnection, U, B>>::internal_load(
            (O::default(), self),
            conn,
        )
    }
}

impl<V, T, QId, Op, O, const STATIC_QUERY_ID: bool> RunQueryDsl<SqliteConnection>
    for (
        O,
        InsertStatement<T, BatchInsert<Vec<ValuesClause<V, T>>, T, QId, STATIC_QUERY_ID>, Op>,
    )
where
    T: QuerySource,
    V: ContainsDefaultableValue<Out = O>,
    O: Default,
    InsertStatement<T, BatchInsert<Vec<ValuesClause<V, T>>, T, QId, STATIC_QUERY_ID>, Op>:
        RunQueryDsl<SqliteConnection>,
{
}

impl<V, T, QId, Op, Ret, O, const STATIC_QUERY_ID: bool> RunQueryDsl<SqliteConnection>
    for (
        O,
        InsertStatement<
            T,
            BatchInsert<Vec<ValuesClause<V, T>>, T, QId, STATIC_QUERY_ID>,
            Op,
            ReturningClause<Ret>,
        >,
    )
where
    T: QuerySource,
    V: ContainsDefaultableValue<Out = O>,
    O: Default,
    InsertStatement<
        T,
        BatchInsert<Vec<ValuesClause<V, T>>, T, QId, STATIC_QUERY_ID>,
        Op,
        ReturningClause<Ret>,
    >: RunQueryDsl<SqliteConnection>,
{
}

impl<V, T, QId, Op, O, Target, ConflictOpt, const STATIC_QUERY_ID: bool>
    RunQueryDsl<SqliteConnection>
    for (
        O,
        InsertStatement<
            T,
            OnConflictValues<
                BatchInsert<Vec<ValuesClause<V, T>>, T, QId, STATIC_QUERY_ID>,
                Target,
                ConflictOpt,
            >,
            Op,
        >,
    )
where
    T: QuerySource,
    V: ContainsDefaultableValue<Out = O>,
    O: Default,
    InsertStatement<
        T,
        OnConflictValues<
            BatchInsert<Vec<ValuesClause<V, T>>, T, QId, STATIC_QUERY_ID>,
            Target,
            ConflictOpt,
        >,
        Op,
    >: RunQueryDsl<SqliteConnection>,
{
}

impl<V, T, QId, Op, Ret, O, Target, ConflictOpt, const STATIC_QUERY_ID: bool>
    RunQueryDsl<SqliteConnection>
    for (
        O,
        InsertStatement<
            T,
            OnConflictValues<
                BatchInsert<Vec<ValuesClause<V, T>>, T, QId, STATIC_QUERY_ID>,
                Target,
                ConflictOpt,
            >,
            Op,
            ReturningClause<Ret>,
        >,
    )
where
    T: QuerySource,
    V: ContainsDefaultableValue<Out = O>,
    O: Default,
    InsertStatement<
        T,
        OnConflictValues<
            BatchInsert<Vec<ValuesClause<V, T>>, T, QId, STATIC_QUERY_ID>,
            Target,
            ConflictOpt,
        >,
        Op,
        ReturningClause<Ret>,
    >: RunQueryDsl<SqliteConnection>,
{
}

#[diagnostic::do_not_recommend]
impl<'query, V, T, QId, Op, Ret, U, B, const STATIC_QUERY_ID: bool>
    LoadQuery<'query, SqliteConnection, U, B>
    for (
        Yes,
        InsertStatement<T, BatchInsert<Vec<ValuesClause<V, T>>, T, QId, STATIC_QUERY_ID>, Op, Ret>,
    )
where
    T: Table + Copy + QueryId + 'static,
    Op: Copy + QueryId + QueryFragment<Sqlite>,
    Ret: Copy,
    InsertStatement<T, ValuesClause<V, T>, Op, Ret>: LoadQuery<'query, SqliteConnection, U, B>,
    Self: RunQueryDsl<SqliteConnection>,
{
    type RowIter<'conn> = alloc::vec::IntoIter<QueryResult<U>>;

    fn internal_load(self, conn: &mut SqliteConnection) -> QueryResult<Self::RowIter<'_>> {
        let (Yes, query) = self;

        conn.transaction(|conn| {
            let mut results = Vec::with_capacity(query.records.values.len());

            for record in query.records.values {
                let stmt =
                    InsertStatement::new(query.target, record, query.operator, query.returning);

                let result = stmt
                    .internal_load(conn)?
                    .next()
                    .ok_or(crate::result::Error::NotFound)?;

                match &result {
                    Ok(_) | Err(crate::result::Error::DeserializationError(_)) => {
                        results.push(result)
                    }
                    Err(_) => {
                        result?;
                    }
                };
            }

            Ok(results.into_iter())
        })
    }
}

#[diagnostic::do_not_recommend]
impl<'query, V, T, QId, Op, Ret, U, B, Target, ConflictOpt, const STATIC_QUERY_ID: bool>
    LoadQuery<'query, SqliteConnection, U, B>
    for (
        Yes,
        InsertStatement<
            T,
            OnConflictValues<
                BatchInsert<Vec<ValuesClause<V, T>>, T, QId, STATIC_QUERY_ID>,
                Target,
                ConflictOpt,
            >,
            Op,
            Ret,
        >,
    )
where
    T: Table + Copy + QueryId + 'static,
    T::FromClause: Copy,
    Op: Copy,
    Ret: Copy,
    Target: Copy,
    ConflictOpt: Copy,
    InsertStatement<T, OnConflictValues<ValuesClause<V, T>, Target, ConflictOpt>, Op, Ret>:
        LoadQuery<'query, SqliteConnection, U, B>,
    Self: RunQueryDsl<SqliteConnection>,
{
    type RowIter<'conn> = alloc::vec::IntoIter<QueryResult<U>>;

    fn internal_load(self, conn: &mut SqliteConnection) -> QueryResult<Self::RowIter<'_>> {
        let (Yes, query) = self;

        conn.transaction(|conn| {
            let mut results = Vec::with_capacity(query.records.values.values.len());

            for record in query.records.values.values {
                let stmt = InsertStatement {
                    operator: query.operator,
                    target: query.target,
                    records: OnConflictValues {
                        values: record,
                        target: query.records.target,
                        action: query.records.action,
                        where_clause: query.records.where_clause,
                    },
                    returning: query.returning,
                    into_clause: query.into_clause,
                };

                let result = stmt
                    .internal_load(conn)?
                    .next()
                    .ok_or(crate::result::Error::NotFound)?;

                match &result {
                    Ok(_) | Err(crate::result::Error::DeserializationError(_)) => {
                        results.push(result)
                    }
                    Err(_) => {
                        result?;
                    }
                };
            }

            Ok(results.into_iter())
        })
    }
}

#[allow(missing_debug_implementations, missing_copy_implementations)]
#[repr(transparent)]
pub struct SqliteBatchInsertWrapper<V, T, QId, const STATIC_QUERY_ID: bool>(
    BatchInsert<V, T, QId, STATIC_QUERY_ID>,
);

impl<V, T, QId, const STATIC_QUERY_ID: bool> crate::query_builder::returning::InsertStmtKind
    for SqliteBatchInsertWrapper<V, T, QId, STATIC_QUERY_ID>
{
    type StmtKind = crate::query_builder::returning::InsertStmtWithoutOnConflictDoUpdate;
}

impl<V, Tab, QId, const STATIC_QUERY_ID: bool> QueryFragment<Sqlite>
    for SqliteBatchInsertWrapper<Vec<ValuesClause<V, Tab>>, Tab, QId, STATIC_QUERY_ID>
where
    ValuesClause<V, Tab>: QueryFragment<Sqlite>,
    V: QueryFragment<Sqlite>,
{
    fn walk_ast<'b>(&'b self, mut out: AstPass<'_, 'b, Sqlite>) -> QueryResult<()> {
        if !STATIC_QUERY_ID {
            out.unsafe_to_cache_prepared();
        }

        let mut values = self.0.values.iter();
        if let Some(value) = values.next() {
            value.walk_ast(out.reborrow())?;
        }
        for value in values {
            out.push_sql(", (");
            value.values.walk_ast(out.reborrow())?;
            out.push_sql(")");
        }
        Ok(())
    }
}

#[allow(missing_copy_implementations, missing_debug_implementations)]
#[repr(transparent)]
pub struct SqliteCanInsertInSingleQueryHelper<T: ?Sized>(T);

impl<V, T, QId, const STATIC_QUERY_ID: bool> CanInsertInSingleQuery<Sqlite>
    for SqliteBatchInsertWrapper<Vec<ValuesClause<V, T>>, T, QId, STATIC_QUERY_ID>
where
    // We constrain that here on an internal helper type
    // to make sure that this does not accidentally leak
    // so that none does really implement normal batch
    // insert for inserts with default values here
    SqliteCanInsertInSingleQueryHelper<V>: CanInsertInSingleQuery<Sqlite>,
{
    fn rows_to_insert(&self) -> Option<usize> {
        Some(self.0.values.len())
    }
}

impl<T> CanInsertInSingleQuery<Sqlite> for SqliteCanInsertInSingleQueryHelper<T>
where
    T: CanInsertInSingleQuery<Sqlite>,
{
    fn rows_to_insert(&self) -> Option<usize> {
        self.0.rows_to_insert()
    }
}

impl<V, T, QId, const STATIC_QUERY_ID: bool> QueryId
    for SqliteBatchInsertWrapper<V, T, QId, STATIC_QUERY_ID>
where
    BatchInsert<V, T, QId, STATIC_QUERY_ID>: QueryId,
{
    type QueryId = <BatchInsert<V, T, QId, STATIC_QUERY_ID> as QueryId>::QueryId;

    const HAS_STATIC_QUERY_ID: bool =
        <BatchInsert<V, T, QId, STATIC_QUERY_ID> as QueryId>::HAS_STATIC_QUERY_ID;
}

impl<V, T, QId, C, Op, const STATIC_QUERY_ID: bool> ExecuteDsl<C, Sqlite>
    for (
        No,
        InsertStatement<T, BatchInsert<V, T, QId, STATIC_QUERY_ID>, Op>,
    )
where
    C: Connection<Backend = Sqlite>,
    T: Table + QueryId + 'static,
    T::FromClause: QueryFragment<Sqlite>,
    Op: QueryFragment<Sqlite> + QueryId,
    SqliteBatchInsertWrapper<V, T, QId, STATIC_QUERY_ID>:
        QueryFragment<Sqlite> + QueryId + CanInsertInSingleQuery<Sqlite>,
{
    fn execute((No, query): Self, conn: &mut C) -> QueryResult<usize> {
        let query = InsertStatement {
            records: SqliteBatchInsertWrapper(query.records),
            operator: query.operator,
            target: query.target,
            returning: query.returning,
            into_clause: query.into_clause,
        };
        query.execute(conn)
    }
}

impl<V, T, QId, C, Op, Target, ConflictOpt, const STATIC_QUERY_ID: bool> ExecuteDsl<C, Sqlite>
    for (
        No,
        InsertStatement<
            T,
            OnConflictValues<BatchInsert<V, T, QId, STATIC_QUERY_ID>, Target, ConflictOpt>,
            Op,
        >,
    )
where
    C: Connection<Backend = Sqlite>,
    T: Table + QueryId + 'static,
    T::FromClause: QueryFragment<Sqlite>,
    Op: QueryFragment<Sqlite> + QueryId,
    OnConflictValues<SqliteBatchInsertWrapper<V, T, QId, STATIC_QUERY_ID>, Target, ConflictOpt>:
        QueryFragment<Sqlite> + CanInsertInSingleQuery<Sqlite> + QueryId,
{
    fn execute((No, query): Self, conn: &mut C) -> QueryResult<usize> {
        let query = InsertStatement {
            operator: query.operator,
            target: query.target,
            records: OnConflictValues {
                values: SqliteBatchInsertWrapper(query.records.values),
                target: query.records.target,
                action: query.records.action,
                where_clause: query.records.where_clause,
            },
            returning: query.returning,
            into_clause: query.into_clause,
        };
        query.execute(conn)
    }
}

#[diagnostic::do_not_recommend]
impl<'query, V, T, QId, Op, Ret, U, B, const STATIC_QUERY_ID: bool>
    LoadQuery<'query, SqliteConnection, U, B>
    for (
        No,
        InsertStatement<T, BatchInsert<V, T, QId, STATIC_QUERY_ID>, Op, Ret>,
    )
where
    T: Table + QueryId + 'static,
    InsertStatement<T, SqliteBatchInsertWrapper<V, T, QId, STATIC_QUERY_ID>, Op, Ret>:
        LoadQuery<'query, SqliteConnection, U, B>,
    Self: RunQueryDsl<SqliteConnection>,
{
    type RowIter<'conn> = <InsertStatement<
        T,
        SqliteBatchInsertWrapper<V, T, QId, STATIC_QUERY_ID>,
        Op,
        Ret,
    > as LoadQuery<'query, SqliteConnection, U, B>>::RowIter<'conn>;

    fn internal_load(self, conn: &mut SqliteConnection) -> QueryResult<Self::RowIter<'_>> {
        let (No, query) = self;

        let query = InsertStatement {
            records: SqliteBatchInsertWrapper(query.records),
            operator: query.operator,
            target: query.target,
            returning: query.returning,
            into_clause: query.into_clause,
        };

        query.internal_load(conn)
    }
}

#[diagnostic::do_not_recommend]
impl<'query, V, T, QId, Op, Ret, U, B, Target, ConflictOpt, const STATIC_QUERY_ID: bool>
    LoadQuery<'query, SqliteConnection, U, B>
    for (
        No,
        InsertStatement<
            T,
            OnConflictValues<BatchInsert<V, T, QId, STATIC_QUERY_ID>, Target, ConflictOpt>,
            Op,
            Ret,
        >,
    )
where
    T: Table + QueryId + 'static,
    InsertStatement<
        T,
        OnConflictValues<SqliteBatchInsertWrapper<V, T, QId, STATIC_QUERY_ID>, Target, ConflictOpt>,
        Op,
        Ret,
    >: LoadQuery<'query, SqliteConnection, U, B>,
    Self: RunQueryDsl<SqliteConnection>,
{
    type RowIter<'conn> = <InsertStatement<
        T,
        OnConflictValues<SqliteBatchInsertWrapper<V, T, QId, STATIC_QUERY_ID>, Target, ConflictOpt>,
        Op,
        Ret,
    > as LoadQuery<'query, SqliteConnection, U, B>>::RowIter<'conn>;

    fn internal_load(self, conn: &mut SqliteConnection) -> QueryResult<Self::RowIter<'_>> {
        let (No, query) = self;

        let query = InsertStatement {
            operator: query.operator,
            target: query.target,
            records: OnConflictValues {
                values: SqliteBatchInsertWrapper(query.records.values),
                target: query.records.target,
                action: query.records.action,
                where_clause: query.records.where_clause,
            },
            returning: query.returning,
            into_clause: query.into_clause,
        };

        query.internal_load(conn)
    }
}

macro_rules! tuple_impls {
        ($(
            $Tuple:tt {
                $(($idx:tt) -> $T:ident, $ST:ident, $TT:ident,)+
            }
        )+) => {
            $(
                impl_contains_defaultable_value!($($T,)*);
            )*
        }
    }

macro_rules! impl_contains_defaultable_value {
      (
        @build
        start_ts = [$($ST: ident,)*],
        ts = [$T1: ident,],
        bounds = [$($bounds: tt)*],
        out = [$($out: tt)*],
    )=> {
        impl<$($ST,)*> ContainsDefaultableValue for ($($ST,)*)
        where
            $($ST: ContainsDefaultableValue,)*
            $($bounds)*
            $T1::Out: Any<$($out)*>,
        {
            type Out = <$T1::Out as Any<$($out)*>>::Out;
        }

    };
    (
        @build
        start_ts = [$($ST: ident,)*],
        ts = [$T1: ident, $($T: ident,)+],
        bounds = [$($bounds: tt)*],
        out = [$($out: tt)*],
    )=> {
        impl_contains_defaultable_value! {
            @build
            start_ts = [$($ST,)*],
            ts = [$($T,)*],
            bounds = [$($bounds)* $T1::Out: Any<$($out)*>,],
            out = [<$T1::Out as Any<$($out)*>>::Out],
        }
    };
    ($T1: ident, $($T: ident,)+) => {
        impl_contains_defaultable_value! {
            @build
            start_ts = [$T1, $($T,)*],
            ts = [$($T,)*],
            bounds = [],
            out = [$T1::Out],
        }
    };
    ($T1: ident,) => {
        impl<$T1> ContainsDefaultableValue for ($T1,)
        where $T1: ContainsDefaultableValue,
        {
            type Out = <$T1 as ContainsDefaultableValue>::Out;
        }
    }
}

crate::for_each_tuple!(tuple_impls);