时间戳

首页 > 解决方案 > 如何返回 N1qlQueryResult 作为 Couchbase 数据库的 REST API 的响应？

java - 如何返回 N1qlQueryResult 作为 Couchbase 数据库的 REST API 的响应？

问题描述

我想返回N1qlQueryResult作为我的REST API. 下面是代码： 

@RequestMapping(value = "/test", method = RequestMethod.GET)
public @ResponseBody ResponseEntity<?> get() {
    List<N1qlQueryRow> result = null;
    try {
        Cluster cluster = CouchbaseCluster.create("localhost");
        Bucket bucket = cluster.openBucket("myBucket", "xyz");
        bucket.bucketManager().createN1qlPrimaryIndex(true, false);
        N1qlQueryResult queryResult = bucket.query(N1qlQuery.simple("select * FROM myBucket"));
        queryResult.forEach(System.out::println);
        result = queryResult.allRows();
    } catch (final Exception exception) {
        exception.printStackTrace();
    }
    return ResponseEntity.ok(result); 
}

我收到错误消息：

无法写入内容：没有为类 com.couchbase.client.java.query.DefaultN1qlQueryRow 找到序列化程序，也没有发现用于创建 BeanSerializer 的属性（为避免异常，请禁用 SerializationFeature.FAIL_ON_EMPTY_BEANS）（通过参考链：java.util.ArrayList[0 ]); 嵌套异常是 com.fasterxml.jackson.databind.JsonMappingException: No serializer found for class com.couchbase.client.java.query.DefaultN1qlQueryRow 并且没有发现用于创建 BeanSerializer 的属性（为避免异常，禁用 SerializationFeature.FAIL_ON_EMPTY_BEANS）（通过引用链: java.util.ArrayList[0])

解决办法是什么？我想将响应返回为JSON.

标签： javajsonspringnosqlcouchbase

解决方案

ObjectMapper默认情况下，当 bean 为empty. 我们可以像下面这样禁用它：

ObjectMapper mapper = new ObjectMapper();
mapper.disable(SerializationFeature.FAIL_ON_EMPTY_BEANS);

但在您的情况下，它不能解决问题，因为结果无论如何都是空的。返回type不代表POJO自身的 -s 并不是一个好主意。N1qlQueryResult并且默认情况下DefaultAsyncN1qlQueryRow没有经典getters并且Jackson不识别类似的方法。value()我建议Map<String, Object>手动创建和构建所需的输出并包含所需的属性：

Map<String, Object> n1QlResult = new HashMap<>();
n1QlResult.put("status", result.status());
// other ...
n1QlResult.put("rows", result.allRows()
        .stream()
        .map(i -> i.value().toMap())
        .collect(Collectors.toList()));

最后返回：

return ResponseEntity.ok(n1QlResult);

当然，当你有很多这样的方法时，你可以编写将这些对象转换为的通用层，Map或者编写自定义序列化器并按容器配置ObjectMapper用户。Spring

编辑
如果您只想返回行返回：

result.allRows()
        .stream()
        .map(i -> i.value().toMap())
        .collect(Collectors.toList())

推荐阅读