如何在DynamoDB中插入pojo对象集合

// 导入必要的类和包
import com.amazonaws.services.dynamodbv2.AmazonDynamoDB;
import com.amazonaws.services.dynamodbv2.AmazonDynamoDBClientBuilder;
import com.amazonaws.services.dynamodbv2.document.BatchWriteItemOutcome;
import com.amazonaws.services.dynamodbv2.document.DynamoDB;
import com.amazonaws.services.dynamodbv2.document.TableWriteItems;
import com.amazonaws.services.dynamodbv2.document.spec.BatchWriteItemSpec;
import com.amazonaws.services.dynamodbv2.document.utils.ValueMap;

// 创建DynamoDB客户端
AmazonDynamoDB client = AmazonDynamoDBClientBuilder.standard().build();
DynamoDB dynamoDB = new DynamoDB(client);

// 创建POJO对象集合
List<MyPOJO> pojoList = new ArrayList<>();
pojoList.add(new MyPOJO("id1", "name1", 25));
pojoList.add(new MyPOJO("id2", "name2", 30));
// ...

// 将POJO对象转换为DynamoDB Item
List<Item> itemList = new ArrayList<>();
for (MyPOJO pojo : pojoList) {
    Item item = new Item()
        .withPrimaryKey("id", pojo.getId())
        .withString("name", pojo.getName())
        .withInt("age", pojo.getAge());
    itemList.add(item);
}

// 构建BatchWriteItemSpec对象
TableWriteItems tableWriteItems = new TableWriteItems("YourTableName")
    .withItemsToPut(itemList);
BatchWriteItemSpec batchWriteItemSpec = new BatchWriteItemSpec()
    .withTableWriteItems(tableWriteItems);

// 执行批量写入操作
BatchWriteItemOutcome outcome = dynamoDB.batchWriteItem(batchWriteItemSpec);
System.out.println("插入成功：" + outcome.getBatchWriteItemResult().getItems().size() + "个项目");