aws.DynamoDB.CreateTable(ctx, driver.TableConfig{
    Name:         "users",
    PartitionKey: "userId",
    SortKey:      "email",
})

tables, _ := aws.DynamoDB.ListTables(ctx)

// Put
aws.DynamoDB.PutItem(ctx, "users", map[string]any{
    "userId": "u-001", "email": "alice@example.com", "name": "Alice", "age": 30,
})

// Get
item, _ := aws.DynamoDB.GetItem(ctx, "users", map[string]any{
    "userId": "u-001", "email": "alice@example.com",
})

// Delete
aws.DynamoDB.DeleteItem(ctx, "users", map[string]any{
    "userId": "u-001", "email": "alice@example.com",
})

// Batch operations
aws.DynamoDB.BatchPutItems(ctx, "users", []map[string]any{item1, item2, item3})
items, _ := aws.DynamoDB.BatchGetItems(ctx, "users", []map[string]any{key1, key2})

// Query by key condition
result, _ := aws.DynamoDB.Query(ctx, driver.QueryInput{
    Table: "users",
    KeyCondition: driver.KeyCondition{
        PartitionKey: "userId", PartitionVal: "u-001",
        SortOp: "BEGINS_WITH", SortVal: "a",
    },
    Limit: 10,
})

// Scan with filters
result, _ = aws.DynamoDB.Scan(ctx, driver.ScanInput{
    Table: "users",
    Filters: []driver.ScanFilter{
        {Field: "age", Op: ">", Value: 25},
    },
})

aws.DynamoDB.UpdateTTL(ctx, "sessions", driver.TTLConfig{
    Enabled:       true,
    AttributeName: "expiresAt",
})

aws.DynamoDB.UpdateStreamConfig(ctx, "users", driver.StreamConfig{
    Enabled:  true,
    ViewType: "NEW_AND_OLD_IMAGES",
})

// After mutations, read the stream
iter, _ := aws.DynamoDB.GetStreamRecords(ctx, "users", 100, "")
for _, record := range iter.Records {
    fmt.Println(record.EventType) // "INSERT", "MODIFY", or "REMOVE"
}

aws.DynamoDB.TransactWriteItems(ctx, "users",
    []map[string]any{newItem1, newItem2}, // puts
    []map[string]any{deleteKey1},         // deletes
)