Struct Upsert 

pub struct Upsert {
    pub table: String,
    pub columns: Vec<String>,
    pub values: Vec<String>,
    pub conflict_target: Option<ConflictTarget>,
    pub conflict_action: ConflictAction,
    pub where_clause: Option<String>,
    pub returning: Option<Vec<String>>,
}

An upsert operation (INSERT with conflict handling).

Fields

table: String

Table name.

columns: Vec<String>

Columns to insert.

values: Vec<String>

Values to insert (expressions or placeholders).

conflict_target: Option<ConflictTarget>

Conflict target specification.

conflict_action: ConflictAction

Action to take on conflict.

where_clause: Option<String>

WHERE clause for conflict update (PostgreSQL).

returning: Option<Vec<String>>

RETURNING clause (PostgreSQL).

Implementations

impl Upsert

pub fn new(table: impl Into<String>) -> Self

Create a new upsert for the given table.

pub fn builder(table: impl Into<String>) -> UpsertBuilder

Create an upsert builder.

pub fn columns<I, S>(self, cols: I) -> Self

where I: IntoIterator<Item = S>, S: Into<String>,

Set the columns to insert.

pub fn values<I, S>(self, vals: I) -> Self

where I: IntoIterator<Item = S>, S: Into<String>,

Set the values to insert.

pub fn on_conflict(self, target: ConflictTarget) -> Self

Set the conflict target.

pub fn do_nothing(self) -> Self

Set conflict action to DO NOTHING.

pub fn do_update<I, S>(self, cols: I) -> Self

where I: IntoIterator<Item = S>, S: Into<String>,

Set conflict action to DO UPDATE for specified columns (using EXCLUDED).

pub fn do_update_set(self, assignments: Vec<Assignment>) -> Self

Set conflict action to DO UPDATE with specific assignments.

pub fn where_clause(self, condition: impl Into<String>) -> Self

Add a WHERE clause for the update (PostgreSQL).

pub fn returning<I, S>(self, cols: I) -> Self

where I: IntoIterator<Item = S>, S: Into<String>,

Add RETURNING clause (PostgreSQL).

pub fn to_postgres_sql(&self) -> String

Generate PostgreSQL INSERT … ON CONFLICT SQL.

pub fn to_mysql_sql(&self) -> String

Generate MySQL INSERT … ON DUPLICATE KEY UPDATE SQL.

pub fn to_sqlite_sql(&self) -> String

Generate SQLite INSERT … ON CONFLICT SQL.

pub fn to_mssql_sql(&self) -> String

Generate MSSQL MERGE statement.

pub fn to_sql(&self, db_type: DatabaseType) -> String

Generate SQL for the specified database type.

Trait Implementations

impl Clone for Upsert

fn clone(&self) -> Upsert

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Upsert

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Upsert

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for Upsert

fn eq(&self, other: &Upsert) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for Upsert

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for Upsert