问题标签 [couchbase-java-api]

我有一个用例，我想从 Couchbase 更新数据，所以当我查询 couchbase 的数据时，就像：

它在一段时间内为我提供了更新的数据，但随着数据库大小的增加，它并没有为我提供更新和一致的数据。在这里，查询正在扫描索引并相应地提供所需的数据。因此，为了获得一致的数据，我按照couchbase 文档的建议使用了 ScanConsistency.REQUESTPLUS。但是一旦我更改代码并执行以下操作：

它每次都给我一个超时异常，并且永远不会返回结果。您能否解释一下如何在这里实现数据的一致性以及为什么它总是给我超时异常。

堆栈跟踪：

任何帮助表示赞赏。！

我想做的就是做一个 upsert 操作。我有一个 JsonDocument，我有一个 Couchbase 服务器“123.456.789.1011”和一个名为“testbucket”的存储桶。现在，当我使用端口 8091 的 IP 地址打开服务器时，它会要求我输入用户名和密码，说“uname”、“pwd”，输入后它会打开。我的存储桶没有任何密码。

这是我的代码，但问题总是在运行代码时出现错误提示

com.couchbase.client.java.error.InvalidPasswordException：存储桶“testbucket”的密码不匹配。在 com.couchbase.client.java.CouchbaseAsyncCluster$1.call(CouchbaseAsyncCluster.java:156) 在 com.couchbase.client.java.CouchbaseAsyncCluster$1.call(CouchbaseAsyncCluster.java:146) 在 rx.internal.operators.OperatorOnErrorResumeNextViaFunction$1。 onError(OperatorOnErrorResumeNextViaFunction.java:77) 在 rx.internal.operators.OperatorMap$1.onError(OperatorMap.java:49) 在 rx.internal.operators.NotificationLite.accept(NotificationLite.java:147) 在 rx.internal.operators。 OperatorObserveOn$ObserveOnSubscriber.pollQueue(OperatorObserveOn.java:177) 在 rx.internal.operators.OperatorObserveOn$ObserveOnSubscriber.access$000(OperatorObserveOn.java:65) 在 rx.internal.operators.OperatorObserveOn$ObserveOnSubscriber$2。

我是 Couchbase 的新手，我真的不知道该怎么做。我用谷歌搜索了它，但网络上什么都没有。甚至他们的文档也没有给我任何建议。我希望 StackOverflow 上的某个人一定会为我解答。谢谢。

我想将通过 API 1.4.10 保存在沙发库中的文档迁移到 API 2.0.5 提供的新文档，例如 JsonDocument。我发现可以将自定义转码器添加到 Bucket，因此在解码文档时我可以检查标志并决定我应该使用哪个转码器。但在我看来，这不是一个很好的解决方案。还有其他方法可以以适当的方式做到这一点吗？谢谢。

迁移只能在运行时根据用户请求进行，因为文档太多，我们无法在后台一次全部迁移。

我正在创建一个虚拟 JSON 并尝试查询它。我正在使用 JAVA 来做这件事。代码如下：-

在执行上述代码时，我收到以下错误：-

有什么线索可以解决吗？

我将 Couchbase Java SDK 2.2.6 与 Couchbase 服务器 4.1 一起使用。

我使用以下代码查询我的视图

在该fromJsonDocument方法的日志中，我看到行并不总是按行键排序。通常它们是，但有时它们不是。

如果我只是在浏览器 couchbase GUI 中运行此查询，我总是会按预期顺序收到结果。使用异步客户端查询时视图查询结果未排序是错误还是预期？不同客户端的行为是什么，而不是 java？

我正在通过类似于https://github.com/couchbase/couchbase-kafka-connector/blob/master/src/main/java/com/couchbase/kafka/CouchbaseReader.java中的运行函数的 java 代码获取 couchbase 突变。最后我们使用 io 调度程序而不是 toBlocking 订阅。我们得到了 mutation 和 streamEndMessages，但我们从来没有得到 onComplete。因此，代码只是等到被杀死。我们使用 core-io-1.2.6，并使用分支 core-io-1.3.0 的顶部。

以上两个返回的序列号有什么区别？AFAIK 都返回最新的序列号，该序列号可能没有被复制或保存到磁盘。

我知道的差异，

GetAllMutationTokensRequest 仅返回单个节点的值。所以对每个节点调用一次应该相当于GetLastCheckpointRequest。

如果没有变化，GetLastCheckpointRequest 返回 1，GetAllMutationTokensRequest 返回 0。

我们使用 getCurrentState，如https://forums.couchbase.com/t/getallmutationtokensrequest-generates-incomplete-response/8166/2所示。对于已经故障转移和重新平衡了几次的集群，getCurrentState 似乎没有从上次调用返回任何更改，即使有更改也是如此。之前我们使用了 GetAllMutationTokensRequest，它返回了正确的高序列号。我们正在使用 core-io 1.2.8 。

我有一个沙发底桶，里面有很多文件。一段时间后，我看到这些文件正在迅速占用大量存储空间。我现在正在为将要存储的所有新文档设置 TTL。有没有办法为所有现有文档设置 TTL 或根据到期时间删除现有文档？不同的文件根据文件类型有不同的到期时间（从 15 分钟到 1 个月不等）。请您建议我可以使用的方法吗？

当我执行以下命令在 couchbase 服务器中创建存储桶时。

错误输出：

有人能告诉我我的命令有什么问题吗？

我正在尝试在 Couchbase 中插入大型 JSON 文档。我已插入如下文件。

像上面那样插入文档后，我想在获取时检索单个嵌套节点（例如：问题）。

我有以下查询： 1）我可以使用传统方法插入文档吗： String query = "upsert into default(KEY, VALUE) values(jsondoc)"; statement.executeUpdateQuery(查询); 或者我是否需要在每个 JSONObject 中单独插入上述嵌套节点才能正确获取嵌套节点？

2）如何使用 N1QLQueryResult 来获取每个 json 文档作为一行只获取所需的 json 信息