Struct InsertQuery 

pub struct InsertQuery { /* private fields */ }

INSERT query builder

Implementations

impl InsertQuery

pub fn new() -> Self

Create an empty INSERT query

pub fn into_table(self, table: &str) -> Self

Set the target table

pub fn value(self, column: &str, value: &str) -> Self

Add a column-value pair (value should be an already-escaped SQL literal)

pub fn values(self, pairs: &[(&str, &str)]) -> Self

Batch add column-value pairs

pub fn on_conflict_do_nothing(self, conflict_cols: &[&str]) -> Self

PostgreSQL/SQLite: ON CONFLICT (cols) DO NOTHING

Ignore insertion on conflict. Applicable to PostgreSQL and SQLite dialects. Under MySQL dialect this setting is ignored (MySQL does not support ON CONFLICT syntax).

Example

use sz_orm_core::DbType;
use sz_orm_query_builder::Query;

let sql = Query::insert()
    .into_table("users")
    .value("id", "1")
    .value("name", "'Alice'")
    .on_conflict_do_nothing(&["id"])
    .build_with_dialect(DbType::PostgreSQL);
// INSERT INTO "users" ("id", "name") VALUES (1, 'Alice') ON CONFLICT ("id") DO NOTHING

pub fn on_conflict_do_update( self, conflict_cols: &[&str], assignments: &[(&str, &str)], ) -> Self

PostgreSQL/SQLite: ON CONFLICT (cols) DO UPDATE SET col = expr, ...

Update specified columns on conflict. assignments is a list of (column, expression) pairs. Expressions may use EXCLUDED.col to reference the to-be-inserted value (PG/SQLite standard).

Example

use sz_orm_core::DbType;
use sz_orm_query_builder::Query;

let sql = Query::insert()
    .into_table("users")
    .value("id", "1")
    .value("name", "'Alice'")
    .value("count", "1")
    .on_conflict_do_update(
        &["id"],
        &[("name", "EXCLUDED.name"), ("count", "users.count + 1")],
    )
    .build_with_dialect(DbType::PostgreSQL);
// INSERT INTO "users" (...) VALUES (...) ON CONFLICT ("id") DO UPDATE SET
//   "name" = EXCLUDED.name, "count" = users.count + 1

pub fn on_duplicate_key_update(self, assignments: &[(&str, &str)]) -> Self

MySQL: ON DUPLICATE KEY UPDATE col = expr, ...

Update specified columns on primary/unique key conflict. assignments is a list of (column, expression) pairs. Expressions may use VALUES(col) to reference the to-be-inserted value (MySQL syntax).

Example

use sz_orm_core::DbType;
use sz_orm_query_builder::Query;

let sql = Query::insert()
    .into_table("users")
    .value("id", "1")
    .value("name", "'Alice'")
    .value("count", "1")
    .on_duplicate_key_update(&[("name", "VALUES(name)"), ("count", "count + 1")])
    .build_with_dialect(DbType::MySQL);
// INSERT INTO `users` (`id`, `name`, `count`) VALUES (1, 'Alice', 1)
//   ON DUPLICATE KEY UPDATE `name` = VALUES(name), `count` = count + 1

pub fn replace(self) -> Self

MySQL: use REPLACE INTO instead of INSERT INTO

On primary/unique key conflict, delete the old row first then insert the new row. Applicable to MySQL/MariaDB/TiDB dialects.

pub fn returning(self, columns: &[&str]) -> Self

Set the RETURNING clause (supported by PostgreSQL/SQLite 3.35+)

Returns the values of specified columns after INSERT, commonly used to obtain auto-increment primary keys or default values. MySQL does not support RETURNING; it is ignored in build() (MySQL style) and only rendered for PostgreSQL/SQLite dialects in build_with_dialect().

Example

use sz_orm_core::DbType;
use sz_orm_query_builder::Query;

let sql = Query::insert()
    .into_table("users")
    .value("name", "'Alice'")
    .returning(&["id", "created_at"])
    .build_with_dialect(DbType::PostgreSQL);
// INSERT INTO "users" ("name") VALUES ('Alice') RETURNING "id", "created_at"

pub fn returning_all(self) -> Self

Set RETURNING * (return all columns)

pub fn build(self) -> String

Build INSERT SQL (no dialect, hard-coded backticks, MySQL style)

Security (gate 9 fix)

Identifiers are escaped via quote_ident() and wrapped in backticks, preventing malicious identifiers containing ` from breaking out.

Upsert behavior

• Replace: generates REPLACE INTO instead of INSERT INTO
• OnDuplicateKeyUpdate: appends ON DUPLICATE KEY UPDATE clause
• OnConflictDoNothing/OnConflictDoUpdate: skipped (MySQL does not support)

pub fn build_with_dialect(self, db_type: DbType) -> String

Generate SQL for the specified dialect

Upsert dialect compatibility

• MySQL family: supports OnDuplicateKeyUpdate, Replace
• PostgreSQL/SQLite: supports OnConflictDoNothing, OnConflictDoUpdate
• Incompatible combinations skip the upsert clause (no error)

Trait Implementations

impl Clone for InsertQuery

fn clone(&self) -> InsertQuery

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for InsertQuery

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for InsertQuery

fn default() -> InsertQuery

Returns the “default value” for a type.