如何使用Java DynamoDBMapper类保存任意结构的文档

问题描述

我正在使用Amazon的DynamoDBMapper Java类将数据保存到DynamoDB表中。 该代码需要以多种不同的方式处理结构化的数据，因此我想避免编写特定于结构的代码。 因此，我将代码存储为Java中的JSON对象-基本上是美化的HashMaps。

我想将这些JSON对象存储为到DynamoDB中。

DynamoDBMapper API的工作方式实质上是：编写一个Java类（通常是POJO），然后添加一些注释，然后将该类的对象传递到DynamoDBMapper中，以便它随后可以将具有Java结构的项目放入数据库中。类。 这对我正在做的事情的许多方面都很好，但是我不想让这些类包含任意结构的JSON文档。 ，并且您可以看到，它不允许文档的结构是任意的。

我意识到我可以使用Dynamo的putItem（）将JSON作为字符串传递到Item对象中-我只是想看看在改变方法之前DynamoDBMapper是否可以实现我想做的事情。

这是我如何在DynamoDB中存储任意Map对象的答案。 这对于存档未打包到异物的REST API响应非常有用。 我个人使用它来从PayPal Payment API存档REST响应。 我不在乎它们在REST API或POJO / bean的结构中使用了什么变量。 我只想确保保存所有内容。

@DynamoDBTable(tableName = "PaymentResponse")
@JsonIgnoreProperties(ignoreUnknown = true)
@JsonTypeInfo(use = JsonTypeInfo.Id.NAME, include = JsonTypeInfo.As.PROPERTY)
@JsonSubTypes({
    @JsonSubTypes.Type(value = PayPalPaymentResponse.class, name = "PayPalPaymentResponse"),
    @JsonSubTypes.Type(value = BatchPayPalPaymentResponse.class, name = "BatchPayPalPaymentResponse")}
    )
public abstract class PaymentResponse {

    // store any arbitrary REST resrponse data in map form so we don't have to worry about the 
    // structure or the actual response itself
    protected Map<String, String> paymentResponseData = Maps.newHashMap();

    public PaymentResponse(PaymentResponseType paymentResponseType) {
        this.paymentResponseType = paymentResponseType;
    }

    public Map<String, String> getPaymentResponseData() { return paymentResponseData; }

    public void setPaymentResponseData(Map<String, String> paymentResponseData) { this.paymentResponseData = paymentResponseData; }

    @Override
    public String toString() {
        return Arrays.toString(paymentResponseData.entrySet().toArray());
    }
}

public class ConverterUtils {

      public static BatchPayPalPaymentResponse getBatchPayPalPaymentResponse(PayoutBatch payoutBatch) throws IOException {
        //read in the PayoutBatch response data and convert it first to a JSON string and then convert the
        //JSON string into a Map<String, String>
        Map<String, String> responseData = objectMapper.readValue(objectMapper.writeValueAsString(payoutBatch), new TypeReference<Map<String, String>>() {});
        BatchPayPalPaymentResponse batchPayPalPaymentResponse = new BatchPayPalPaymentResponse(responseData);
        return batchPayPalPaymentResponse;
    }

    public static PayPalPaymentResponse getSinglePayPalPaymentResponse(PayoutItemDetails payoutItemDetails) throws IOException {
        //read in the paypal PayoutItemDetails response data and convert it first to a JSON string and then convert the
        //JSON string into a Map<String, String>
        Map<String, String> responseData = objectMapper.readValue(objectMapper.writeValueAsString(payoutItemDetails), new TypeReference<Map<String, String>>() {});
        PayPalPaymentResponse payPalPaymentResponse = new PayPalPaymentResponse(responseData);
        return payPalPaymentResponse;

    }
}

public class BatchPayPalPaymentResponse extends PaymentResponse {
    public BatchPayPalPaymentResponse(Map<String, String> responseData) {
        super(responseData);
    }
    ....
    ....
    ....
}

public class PayPalPaymentResponse extends PaymentResponse {
    public PayPalPaymentResponse(Map<String, String> responseData) {
        super(responseData);
    }
    ....
    ....
    ....
}

现在，您只需调用mapper.save(instanceOfPaymentResponse) 。 请注意，我的代码还包括如何使用Jackson解析器来选择和选择PaymentResponse编组的PaymentResponse子类。 那是因为我使用DynamoDBTypeConverter将类编入字符串，然后再将其放入数据库。

最后，为了完整性，我将使用转换器，因此希望这一切都是有意义的。

public class PaymentResponseConverter implements DynamoDBTypeConverter<String, PaymentResponse> {

    private static final ObjectMapper objectMapper = new ObjectMapper();
    static {
        objectMapper.setSerializationInclusion(JsonInclude.Include.NON_NULL);
    }

    @Override
    public String convert(PaymentResponse object) {
        try {
            return objectMapper.writeValueAsString(object);
        } catch (JsonProcessingException e) {
            throw new IllegalArgumentException(String.format("Received invalid instance of PaymentResponse and cannot marshal it to a string (%s)", e.getMessage()));
        }
    }

    @Override
    public PaymentResponse unconvert(String object) {
        try {
            return objectMapper.readValue(object, PaymentResponse.class);
        } catch (IOException e) {
            throw new IllegalArgumentException(String.format("Unable to convert JSON to instance of PaymentResponse. This is a fatal error. (%s)", e.getMessage()));
        }
    }
}

我遇到了同样的问题，自己走了将对象序列化和反序列化为json字符串的路线，然后将它们存储为字符串。 DynamoDB的整个Document概念都是恕我直言，只是一种荣耀的对象序列化程序。 仅当您需要在dynamodb动作（例如，扫描，投影）中访问对象内部的属性时，才使用json文档类型。 如果我们的数据对dynamodb不透明，那么最好使用字符串。