Struct UpsertRecord 

pub struct UpsertRecord<'a, M: 'static, PK: 'static, I> { /* private fields */ }

Implementations

impl<'a, M: 'static, PK: 'static, I> UpsertRecord<'a, M, PK, I>

where I: UpsertModelInput<M>,

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

Choose the conflict target. Defaults to the model’s primary key; pass ConflictTarget::Columns to upsert on a composite unique key instead. The named columns must form a UNIQUE constraint/index on the target table.

pub fn preview_sql(&self) -> String

Render an approximate SQL preview. The actual upsert wraps a SELECT … FOR UPDATE around the INSERT … ON CONFLICT, but this preview returns only the conflict-bearing statement.

pub async fn run(self, ctx: &CoolContext) -> Result<M, CoolError>

where for<'r> M: Send + Unpin + FromRow<'r, PgRow> + Serialize, PK: Send + Type<Postgres> + for<'q> Encode<'q, Postgres>,

pub async fn run_in_tx<'tx>( self, tx: &mut Transaction<'tx, Postgres>, ctx: &CoolContext, ) -> Result<M, CoolError>

where for<'r> M: Send + Unpin + FromRow<'r, PgRow> + Serialize, PK: Send + Type<Postgres> + for<'q> Encode<'q, Postgres>,

Like Self::run but participates in a caller-supplied transaction. The conflict probe runs against tx, so the row lock is held until the caller commits. The event outbox is not drained here.

Trait Implementations

impl<'a, M: Clone + 'static, PK: Clone + 'static, I: Clone> Clone for UpsertRecord<'a, M, PK, I>

fn clone(&self) -> UpsertRecord<'a, M, PK, I>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<'a, M: Debug + 'static, PK: Debug + 'static, I: Debug> Debug for UpsertRecord<'a, M, PK, I>

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

Formats the value using the given formatter.