Struct UpsertOperation 

pub struct UpsertOperation<E: QueryEngine, M: Model> { /* private fields */ }

An upsert (insert or update) operation.

Example

let user = client
    .user()
    .upsert()
    .r#where(user::email::equals("test@example.com"))
    .create(user::Create { email: "test@example.com".into(), name: Some("Test".into()) })
    .update(user::Update { name: Some("Updated".into()), ..Default::default() })
    .exec()
    .await?;

Implementations

impl<E: QueryEngine, M: Model> UpsertOperation<E, M>

pub fn new(engine: E) -> Self

Create a new Upsert operation.

pub fn where(self, filter: impl Into<Filter>) -> Self

Add a filter condition (identifies the record to upsert).

pub fn on_conflict( self, columns: impl IntoIterator<Item = impl Into<String>>, ) -> Self

Set the columns to check for conflict.

pub fn create( self, values: impl IntoIterator<Item = (impl Into<String>, impl Into<FilterValue>)>, ) -> Self

Set the create data.

pub fn create_set( self, column: impl Into<String>, value: impl Into<FilterValue>, ) -> Self

Set a single create column.

pub fn update( self, values: impl IntoIterator<Item = (impl Into<String>, impl Into<FilterValue>)>, ) -> Self

Set the update data.

pub fn update_set( self, column: impl Into<String>, value: impl Into<FilterValue>, ) -> Self

Set a single update column.

pub fn select(self, select: impl Into<Select>) -> Self

Select specific fields to return.

pub fn build_sql(&self) -> (String, Vec<FilterValue>)

Build the SQL query.

pub async fn exec(self) -> QueryResult<M>

where M: Send + 'static,

Execute the upsert and return the record.