如何在Java中无需声明实体类字段向DynamoDB添加数据？

问题背景 #

现有Java代码通过固定实体类Person操作DynamoDB，无法利用NoSQL无固定schema的核心优势，需要修改代码以支持存入任意额外字段（如StreetAddress、Car、phoneNumber等）。

修改方案 #

我们可以放弃固定实体类的绑定，直接使用AWS DynamoDB的低级API处理灵活键值对数据，以下是具体修改后的代码：

1. 保留原DynamoDbConfig配置

原配置类无需改动，继续使用即可：

@RequiredArgsConstructor
@Configuration
public class DynamoDbConfig {

    @Bean
    public DynamoDBMapperConfig dynamoDBMapperConfig() {
        return DynamoDBMapperConfig.DEFAULT;
    }

    @Bean
    public DynamoDBMapper mapper() {
        return new DynamoDBMapper(amazonDynamoDBConfig());
    }

    @Bean
    public AmazonDynamoDB amazonDynamoDBConfig() {
        return AmazonDynamoDBClientBuilder.standard()
                .withEndpointConfiguration(new AwsClientBuilder.EndpointConfiguration("dynamodb.us-west-2.amazonaws.com", "us-west-2"))
                .withCredentials(new AWSStaticCredentialsProvider(new BasicAWSCredentials("TestExample", "ExampleExample")))
                .build();
    }
}

2. 废弃原Person实体类

不再依赖固定实体类，直接处理灵活的键值对数据。

3. 修改Controller

接收任意JSON格式的请求体，用Map<String, Object>承载所有字段：

@RestController
@RequestMapping("/api")
@CrossOrigin
public class PersonController {
    private PersonRepository repository;

    @Autowired
    public PersonController(PersonRepository repository) {
        this.repository = repository;
    }

    @PostMapping("/savePerson")
    public Map<String, Object> savePerson(@RequestBody Map<String, Object> personData) {
        return repository.addPerson(personData);
    }
}

4. 修改Repository

使用AmazonDynamoDB客户端的低级API，将Map转换为DynamoDB的Item并写入：

@Repository
public class PersonRepository {
    private final AmazonDynamoDB amazonDynamoDB;
    private static final String TABLE_NAME = "person";

    @Autowired
    public PersonRepository(AmazonDynamoDB amazonDynamoDB) {
        this.amazonDynamoDB = amazonDynamoDB;
    }

    public Map<String, Object> addPerson(Map<String, Object> personData) {
        // 自动生成personId作为哈希键（如果请求中未提供）
        if (!personData.containsKey("personId")) {
            personData.put("personId", UUID.randomUUID().toString());
        }

        // 将Map转换为DynamoDB Item并写入
        Item item = Item.fromMap(personData);
        PutItemRequest request = new PutItemRequest(TABLE_NAME, item.asMap());
        amazonDynamoDB.putItem(request);

        return personData;
    }
}

测试验证 #

使用Postman提交包含任意字段的JSON请求，例如：

{
    "name": "John Doe",
    "age": 30,
    "email": "john@example.com",
    "streetAddress": "123 Main St",
    "car": {
        "brand": "Toyota",
        "model": "Camry"
    },
    "phoneNumber": "555-1234"
}

提交后，所有字段（包括未在原实体类中定义的字段）都会存入DynamoDB的person表中。

替代方案：保留实体类并支持额外字段 #

如果不想完全废弃原Person实体类，可以添加一个用于存储额外字段的Map，通过@DynamoDBJson注解实现自动序列化：

@Data
@AllArgsConstructor
@NoArgsConstructor
@DynamoDBTable(tableName="person")
public class Person implements Serializable {
    @DynamoDBHashKey(attributeName = "personId")
    @DynamoDBAutoGeneratedKey
    private String personId;

    @DynamoDBAttribute
    private String name;

    @DynamoDBAttribute
    private int age;

    @DynamoDBAttribute
    private String email;

    // 存储任意额外字段
    @DynamoDBJson
    private Map<String, Object> additionalFields = new HashMap<>();
}

此时Postman需将额外字段嵌套在additionalFields中提交，这种方式保留了原实体结构，但灵活性不如第一种方案。

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