如何在DynamoDB事务中为不同表使用不同AttributeTransformers？

核心限制说明 #

DynamoDBMapper的事务API（比如transactionWrite）确实是全局绑定一个AttributeTransformer的，所有参与事务的表操作都会复用同一个转换器实例，这是当前SDK的设计限制。

更简单的替代方案 #

1. 使用多个DynamoDBMapper实例 #

这是最直接的方案：为每个需要不同转换器的表创建独立的DynamoDBMapper实例，每个实例配置对应的AttributeTransformer。然后在事务构建时，分别用不同的Mapper生成对应的TransactWriteItem，再合并到事务请求中。

示例代码：

// 为表A创建带转换器A的Mapper
DynamoDBMapperConfig configA = DynamoDBMapperConfig.builder()
    .withAttributeTransformer(transformerA)
    .build();
DynamoDBMapper mapperA = new DynamoDBMapper(dynamoDBClient, configA);

// 为表B创建带转换器B的Mapper
DynamoDBMapperConfig configB = DynamoDBMapperConfig.builder()
    .withAttributeTransformer(transformerB)
    .build();
DynamoDBMapper mapperB = new DynamoDBMapper(dynamoDBClient, configB);

// 生成事务项
TransactWriteItem itemA = mapperA.saveTransactWriteItem(entityA);
TransactWriteItem itemB = mapperB.deleteTransactWriteItem(entityB);

// 执行事务
mapperA.transactionWrite(itemA, itemB);

注意：只要事务中的TransactWriteItem已经被正确转换，用哪个Mapper来触发事务执行都可以，因为转换逻辑已经在生成TransactWriteItem时完成了。

2. 基于表名的条件转换器（你的方案优化版） #

如果不想维护多个Mapper实例，可以实现一个路由转换器，根据当前操作的表名来分发到对应的子转换器。

示例代码：

public class TableRoutingAttributeTransformer implements AttributeTransformer {
    private final Map<String, AttributeTransformer> transformerMap;
    private final AttributeTransformer defaultTransformer;

    public TableRoutingAttributeTransformer(Map<String, AttributeTransformer> transformerMap, AttributeTransformer defaultTransformer) {
        this.transformerMap = transformerMap;
        this.defaultTransformer = defaultTransformer;
    }

    @Override
    public Map<String, AttributeValue> transform(Map<String, AttributeValue> attributes, Class<?> clazz, DynamoDBMapperConfig config) {
        // 从实体类注解获取表名
        DynamoDBTable tableAnnotation = clazz.getAnnotation(DynamoDBTable.class);
        String tableName = tableAnnotation != null ? tableAnnotation.tableName() : config.getTableNameOverride().getTableName();
        
        AttributeTransformer transformer = transformerMap.getOrDefault(tableName, defaultTransformer);
        return transformer.transform(attributes, clazz, config);
    }
}

然后全局使用这个路由转换器，把各个表对应的转换器注册进去即可。

方案对比 #

• 多Mapper方案：实现简单，逻辑清晰，适合表数量不多的场景；缺点是需要维护多个Mapper实例。
• 路由转换器方案：无需多实例，适合表数量较多或需要集中管理转换器的场景；缺点是需要自己实现路由逻辑，要处理表名注解、配置覆盖等细节。

内容的提问来源于stack exchange，提问作者Rohit Lakhotia