5

プロパティを持つクラスに注釈を付ける必要がありSet<UUID>ます。スカラーのマーシャリングUUIDは問題なく、注釈を使用し@DynamoDBMarshallingてコンバーターを指定でき、すべてが機能します。

で同じコンバーターを使用しようとすると、Set<UUID>「DynamoDBMappingException: Expected SS in value」が表示されます。を期待するカスタム コンバーターを作成しようとしましたSet<UUID>が、同じ問題が解決しません。

セットをカスタムマーシャリングすることは可能ですか?

@DynamoDBTable(tableName="djones-test")
public class UUIDRecommendation {
    private UUID id;
    private Set<UUID> recommendations;

    @DynamoDBHashKey
    @DynamoDBMarshalling(marshallerClass=UuidConverter.class)
    public UUID getId() {
        return id;
    }

    public void setId(UUID id) {
        this.id = id;
    }

    //Neither this nor UuidConverter.class work here    
    @DynamoDBMarshalling(marshallerClass=SetUuidConverter.class)
    public Set<UUID> getRecommendations() {
        return recommendations;
    }

    public void setRecommendations(Set<UUID> recommendations) {
        this.recommendations = recommendations;
    }
}

スタック トレースは次のとおりです。

com.amazonaws.services.dynamodb.datamodeling.DynamoDBMappingException: Expected SS in value {SS: [1a841b97-ab9d-4425-a2c0-f9a81bebf0b4, 1a841b97-ab9d-4425-a2c0-f9a81bebf0b4, 1a841b97-ab9d-4425-a2c0-f9a81bebf0b4], } when invoking public void com.company.model.UUIDRecommendation.setRecommendations(java.util.Set)
    at com.amazonaws.services.dynamodb.datamodeling.SUnmarshaller.typeCheck(SUnmarshaller.java:26)
    at com.amazonaws.services.dynamodb.datamodeling.DynamoDBMapper.setValue(DynamoDBMapper.java:329)
    at com.amazonaws.services.dynamodb.datamodeling.DynamoDBMapper.marshallIntoObject(DynamoDBMapper.java:302)
    at com.amazonaws.services.dynamodb.datamodeling.DynamoDBMapper.load(DynamoDBMapper.java:253)
    at com.amazonaws.services.dynamodb.datamodeling.DynamoDBMapper.load(DynamoDBMapper.java:196)
    at com.mendeley.service.data.DynamoRecommendedItemsDataServiceTest.testObjectMapper(DynamoRecommendedItemsDataServiceTest.java:65)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
    at java.lang.reflect.Method.invoke(Method.java:597)
    at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:45)
    at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:15)
    at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:42)
    at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:20)
    at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:28)
    at org.springframework.test.context.junit4.statements.RunBeforeTestMethodCallbacks.evaluate(RunBeforeTestMethodCallbacks.java:74)
    at org.springframework.test.context.junit4.statements.RunAfterTestMethodCallbacks.evaluate(RunAfterTestMethodCallbacks.java:83)
    at org.springframework.test.context.junit4.statements.SpringRepeat.evaluate(SpringRepeat.java:72)
    at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.runChild(SpringJUnit4ClassRunner.java:231)
    at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:47)
    at org.junit.runners.ParentRunner$3.run(ParentRunner.java:231)
    at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:60)
    at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:229)
    at org.junit.runners.ParentRunner.access$000(ParentRunner.java:50)
    at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:222)
    at org.springframework.test.context.junit4.statements.RunBeforeTestClassCallbacks.evaluate(RunBeforeTestClassCallbacks.java:61)
    at org.springframework.test.context.junit4.statements.RunAfterTestClassCallbacks.evaluate(RunAfterTestClassCallbacks.java:71)
    at org.junit.runners.ParentRunner.run(ParentRunner.java:300)
    at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.run(SpringJUnit4ClassRunner.java:174)
    at org.eclipse.jdt.internal.junit4.runner.JUnit4TestReference.run(JUnit4TestReference.java:50)
    at org.eclipse.jdt.internal.junit.runner.TestExecution.run(TestExecution.java:38)
    at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:467)
    at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:683)
    at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run(RemoteTestRunner.java:390)
    at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main(RemoteTestRunner.java:197)
4

3 に答える 3

4

これを試して。ゲッター/セッター内でマーシャル/アンマーシャルを処理します。Set<String>JSONを格納するために同様の手法を使用しますがSet<CustomObject>、コード内で としてアクセスします。ゲッター/セッターはそのままにして、代わりに便利なメソッドを使用します。

変更されたバージョンは次のとおりです。

@DynamoDBTable(tableName="djones-test")
public class UUIDRecommendation {
    private String id;
    // custom object representation in JVM
    private Set<UUID> recommendations;

    private static final JsonMarshaller<UUID> UUID_MARSHALLER = new JsonMarshaller<UUID>();

    @DynamoDBHashKey(attributeName="id")
    public String getId() {
        return id;
    }
    public void setId(String id) {
        this.id = id;
    }

    // Set<String> holding JSON in DynamoDB
    @DynamoDBAttribute(attributeName="recommendations")
    public Set<String> getRecommendations() {
        if (recommendations != null) {
            Set<String> jsonSet = new HashSet<String>(recommendations.size());
            for (UUID recommendation : recommendations) {
                String json = UUID_MARSHALLER.marshall(recommendation);
                jsonSet.add(json);
            }
            return jsonSet;
        } else {
            return null;
        }
    }
    public void setRecommendations(Set<String> jsonSet) {
        if (jsonSet != null) {
            recommendations = new HashSet<UUID>(jsonSet.size());
            for (String json : jsonSet) {
                UUID recommendation = UUID_MARSHALLER.unmarshall(UUID.class, json);
                recommendations.add(recommendation);
            }
        }
    }

    // convenience methods
    @DynamoDBIgnore
    public UUID convenienceMethod(UUID recommendation) {
        return null;
    }

    // custom object
    public class UUID {

    }
}
于 2013-03-23T10:26:22.610 に答える
2

ああ、親愛なる-セットの顧客マーシャラーは不可能のようです。AWS SDKは、単一の文字列値（SUnmarshaller（））のみを処理するようにハードコーディングされています。

AWS SDK 1.3.13のDynamoDBReflector、185行目：

if ( isCustomMarshaller(getter) ) {
    unmarshaller = new SUnmarshaller() {

        @Override
        public Object unmarshall(AttributeValue value) {
            return getCustomMarshalledValue(toReturn, getter, value);
        }
    };
}

アップデート

まったく不潔なハックとして、クラス全体をコピー/貼り付けすることで機能するものをまとめました:(これが、プライベート静的最終ユーティリティサービスが悪く、依存性注入が良い理由です。

これは機能するので、インスタンスまたはUuidConverterインスタンスを返すゲッターに1つのカスタマーコンバーター（私の場合）を使用できます。UUID Set<UUID>

getCustomMarshalledValueSetというメソッドを追加しました。このメソッドは、value.getSS（）によって返されるリストを反復処理し、それぞれのカスタムマーシャラーを呼び出し、その結果をSetに追加して返します。

    @SuppressWarnings({ "rawtypes", "unchecked" })
    private <T> T getCustomMarshalledValueSet(T toReturn, Method getter, AttributeValue value) {
    DynamoDBMarshalling annotation = getter.getAnnotation(DynamoDBMarshalling.class);
    Class<? extends DynamoDBMarshaller<? extends Object>> marshallerClass = annotation.marshallerClass();

    DynamoDBMarshaller marshaller;
    try {
        marshaller = marshallerClass.newInstance();
    } catch (InstantiationException e) {
        throw new DynamoDBMappingException("Couldn't instantiate marshaller of class " + marshallerClass, e);
    } catch (IllegalAccessException e) {
        throw new DynamoDBMappingException("Couldn't instantiate marshaller of class " + marshallerClass, e);
    }

    Set<T> set = new HashSet<T>();

    for (String part : value.getSS()) {
        set.add((T) marshaller.unmarshall(getter.getReturnType(), part));
    }

    return (T) set;
}

さらに、getArgumentUnmarshallerが変更され、使用するアンマーシャラーのタイプを決定する条件の前にisCollectionチェックが行われるようになり、カスタムマーシャラーブロックが正しいソートを選択するように変更されました。

            if (isCustomMarshaller(getter)) {
                if (isCollection) {
                    unmarshaller = new SSUnmarshaller() {

                        @Override
                        public Object unmarshall(AttributeValue value) {
                            return getCustomMarshalledValueSet(toReturn, getter, value);
                        }
                    };
                } else {
                    unmarshaller = new SUnmarshaller() {

                        @Override
                        public Object unmarshall(AttributeValue value) {
                            return getCustomMarshalledValue(toReturn, getter, value);
                        }
                    };
                }

            }
于 2012-08-31T15:04:54.733 に答える
1

このプル リクエストを参照してください。 aribtrary オブジェクトのセットのシリアル化/逆シリアル化を処理する DynamoDBReflector の修正バージョンを添付しました。私はしばらくの間それを使用してきましたが、それはうまく機能します。

于 2013-05-28T16:42:35.930 に答える