使用Spring-data-couchbase将Couchbase文档转换为POJO

Question

我需要读取couchbase文档并将其转换为一个简单的pojo类对象。从docs中，我知道我需要定义一些自定义转换器来将文档转换为POJO对象，因为它有一个org.apache.commons.json.JSONObject类型的(非原语)字段，如下所示

@Document
public class MyClass{

    @Id
    private String id;

    @Field
    private JSONObject someJsonObj;
//getters and setters

}

下面是这个的存储库

@Repository
@N1qlPrimaryIndexed
public interface MyClassRepository extends CouchbaseRepository<MyClass, String>{}

在保存对象时，下面的代码运行良好，

     MyClass myclass = new MyClass();
     myclass.setId(someKey);
    myclass.setSomeJsonObj(jsonObject);
    myclassRepository.save(myclass);

并将文档保存为couchbase中的以下格式

someKey {jsonObject}

现在，在检索过程中，我使用了一个自定义的读取转换器，如下所示

@ReadingConverter
    public static enum CouchbaseDocumentToMyClassConverter implements Converter<CouchbaseDocument,MyClass> {
        INSTANCE;
        @Override
        public MyClass convert(CouchbaseDocument source) {
            System.out.println(source.getPayload()); //this is returning lot of unwanted data like id, exp and payload for every nested json Object 
            //logic to instantiate MyClass obj 
            return new MyClass();
            }
        }

如果我尝试将对象直接映射到MyClass对象，而不是在转换中映射到CouchbaseDocument，那么我得到的是org.springframework.data.mapping.MappingException: Couldn't find PersistentEntity for type java.lang.Object!。下面是完整的堆栈跟踪

2019-04-25 15:01:36.584 ERROR [{}] 33024 --- [http-nio-8080-exec-1] o.a.c.c.C.[.[.[.[dispatcherServlet]      : Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Request processing failed; nested exception is org.springframework.data.mapping.MappingException: Couldn't find PersistentEntity for type java.lang.Object!] with root cause
rx.exceptions.OnErrorThrowable$OnNextValue: OnError while emitting onNext value: com.couchbase.client.java.document.RawJsonDocument.class
    at rx.exceptions.OnErrorThrowable.addValueAsLastCause(OnErrorThrowable.java:118) ~[rxjava-1.3.8.jar:1.3.8]
    at rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:73) ~[rxjava-1.3.8.jar:1.3.8]
    at rx.internal.util.ScalarSynchronousObservable$WeakSingleProducer.request(ScalarSynchronousObservable.java:276) ~[rxjava-1.3.8.jar:1.3.8]
    at rx.Subscriber.setProducer(Subscriber.java:211) ~[rxjava-1.3.8.jar:1.3.8]
    at rx.internal.operators.OnSubscribeMap$MapSubscriber.setProducer(OnSubscribeMap.java:102) ~[rxjava-1.3.8.jar:1.3.8]
    at rx.internal.util.ScalarSynchronousObservable$JustOnSubscribe.call(ScalarSynchronousObservable.java:138) ~[rxjava-1.3.8.jar:1.3.8]
    at rx.internal.util.ScalarSynchronousObservable$JustOnSubscribe.call(ScalarSynchronousObservable.java:129) ~[rxjava-1.3.8.jar:1.3.8]
    at rx.Observable.unsafeSubscribe(Observable.java:10327) ~[rxjava-1.3.8.jar:1.3.8]
    at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48) ~[rxjava-1.3.8.jar:1.3.8]
    at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33) ~[rxjava-1.3.8.jar:1.3.8]

有人能提供一些关于如何解决这个问题的见解吗？在检索期间，我直接希望将couchbase文档映射到我的POJO类对象。

Answer 1

如果您使用的是Spring Data，则不需要编写任何自定义转换器，存储库本身可以返回一个POJO：

@Document
@Data
@AllArgsConstructor
public class Area extends BasicEntity {

    @NotNull
    @Id
    private String id;

    @NotNull
    private String name;

    private String description;

    private String parentAreaId;

}

然后，在您的存储库中：

@N1qlPrimaryIndexed
public interface AreaRepository extends CouchbaseRepository<Area, String> {

    List<Area> findByParentAreaId(String parentAreaId);
}

只有当您存储的对象不是POJO时，才能定义自定义转换器，比如JODA或Java 8与日期相关的类。