Struct TransactPutRequest 

pub struct TransactPutRequest<TD: TableDefinition, T = (), C: ConditionState = NoCondition> { /* private fields */ }

Builder for a Put operation inside a DynamoDB transaction.

Constructed via DynamoDBItemTransactOp::transact_put. Optionally add a condition that must hold for the put to succeed, via .condition(), .exists(), or .not_exists(). DynamoDB accepts a single condition expression per operation, so this can only be called once.

Call .build() to produce a TransactWriteItem that can be passed to the SDK’s transact_write_items() builder.

Examples

Atomically create an enrollment and increment the user’s enrollment count:

use dynamodb_facade::{DynamoDBItemTransactOp, KeyId, Update};

let enrollment = sample_enrollment();

client
    .transact_write_items()
    .transact_items(enrollment.transact_put().not_exists().build())
    .transact_items(
        User::transact_update_by_id(
            KeyId::pk("user-1"),
            Update::init_increment("enrollment_count", 0, 1),
        )
        .exists()
        .build(),
    )
    .send()
    .await?;

Implementations

impl<TD: TableDefinition, T, C: ConditionState> TransactPutRequest<TD, T, C>

pub fn new(item: Item<TD>) -> Self

Creates a new TransactPutRequest from a raw Item.

Prefer DynamoDBItemTransactOp::transact_put for typed construction.

Examples

use dynamodb_facade::{TransactPutRequest, DynamoDBItemTransactOp, KeyId, Update};

// Create a user from a raw Item and atomically initialize an enrollment
let user_item = sample_user_item();
let enrollment = sample_enrollment();
client
    .transact_write_items()
    .transact_items(
        TransactPutRequest::<PlatformTable>::new(user_item).build(),
    )
    .transact_items(enrollment.transact_put().not_exists().build())
    .send()
    .await?;

pub fn into_inner(self) -> PutBuilder

Consumes the builder and returns the underlying SDK PutBuilder.

Use this escape hatch when you need to set options not exposed by this facade.

pub fn build(self) -> TransactWriteItem

Finalizes the builder and returns a TransactWriteItem.

The returned value can be passed directly to the SDK’s transact_write_items().transact_items(...) call.

Examples

use dynamodb_facade::{DynamoDBItemTransactOp, KeyId, Update};

let enrollment = sample_enrollment();

// Atomically create an enrollment and increment the user's counter
client
    .transact_write_items()
    .transact_items(enrollment.transact_put().not_exists().build())
    .transact_items(
        User::transact_update_by_id(
            KeyId::pk("user-1"),
            Update::init_increment("enrollment_count", 0, 1),
        )
        .exists()
        .build(),
    )
    .send()
    .await?;

impl<TD: TableDefinition, T> TransactPutRequest<TD, T, NoCondition>

pub fn condition( self, condition: Condition<'_>, ) -> TransactPutRequest<TD, T, AlreadyHasCondition>

Adds a condition expression that must be satisfied for the put to succeed.

DynamoDB accepts a single condition expression per operation, so this method can only be called once. If the condition fails, the entire transaction is cancelled with TransactionCanceledException.

Examples

use dynamodb_facade::{DynamoDBItemOp, DynamoDBItemTransactOp, Condition};

let transact_item = sample_enrollment()
    .transact_put()
    .condition(
        Enrollment::not_exists() |
        Condition::not_exists("completed_at")
    )
    .build();

impl<TD: TableDefinition, T: DynamoDBItem<TD>> TransactPutRequest<TD, T, NoCondition>

pub fn exists(self) -> TransactPutRequest<TD, T, AlreadyHasCondition>

Adds an attribute_exists(<PK>) condition.

Examples

use dynamodb_facade::DynamoDBItemTransactOp;

let transact_item = sample_enrollment().transact_put().exists().build();

pub fn not_exists(self) -> TransactPutRequest<TD, T, AlreadyHasCondition>

Adds an attribute_not_exists(<PK>) condition.

Use this to implement create-only semantics within a transaction.

Examples

use dynamodb_facade::DynamoDBItemTransactOp;

let transact_item = sample_enrollment().transact_put().not_exists().build();