标签: couchbase-java-api

我有一个代码调用couchbase获取一些行如下:

val gotValues: Observable[JsonDocument] = Observable.from(rowKeys).flatMap(id =>
      couchbaseBucket.async().get(id))

如果我有1,2,3,4,5,6作为输入行键,并且DB中只存在1,2,3行,那么observable只会收到1,2,3的通知.

然而,我的要求是我返回一个1,2,3 true(存在于db中)和4,5,6 with false(在DB中不存在)的映射.我设法用scala observable做到了,但是我使用中间地图数据结构来返回包含所有id的总地图.下面是一个模拟我的问题的示例代码..

object Main extends App {
  import rx.lang.scala.Observable

  val idsToFetch = Seq(1,2,3,4,5,6)

  println(isInDBOrNot()) // {1=true, 2=true, 3=true, 4=false, 5=false, 6=false}

  private def isInDBOrNot(): ConcurrentHashMap[Int, Boolean] = {
    val inAndNotInDB = new java.util.concurrent.ConcurrentHashMap[Int, Boolean]
    // - How can I avoid the additional data structure?
    // - In this case a map, so that the function will return
    //   a map with all numbers and for each if exist …

我目前正在iOS和Android应用程序中使用couchbase-lite来同步来自运行CouchDB的数据库中的文件.

我经常删除不再需要的文件,我希望从移动应用程序中删除相同的文件,但任何拉动复制只会提取更新或新文件,并且不会触发移动应用程序上的删除.

有没有办法从移动应用程序中删除不再在服务器数据库上的文件而不对移动应用程序进行完全清除,然后重新同步整个数据库？

我正在对文档数据存储进行POC,因此我选择了MongoDB和CouchBase进行评估.

环境详情如下

机器:Centos 6.7,2核心CPU,CPU MHz:2494.078,RAM:7 GB(6 GB免费)

具有默认配置的MongoDB db版本v3.2.0

CouchBase版本:4.1.0-5005企业版(集群RAM:3GB,桶RAM:1GB)

文件大小:326 B.

以下是POC的结果

+--------------+---------------------------------------------+--------------+--------------+--------------+--------------+--------------+-------------+-------------+
|  Operation   | insert (in 10 batch each bacth is of 100K ) | select query | select query | select query | select query | select query | range query | range query |
+--------------+---------------------------------------------+--------------+--------------+--------------+--------------+--------------+-------------+-------------+
| Record Count | 1000K                                       | 0            | 100          | 33k          | 140k         | 334k         | 114k        | 460k        |
| Mongo        | 99 sec                                      | 568ms        | 792ms …

我对 couchbase 查询计划的工作方式理解有问题。我将 SpringData 与 Couchbase 4.1 结合使用，并提供 Couchbase 存储库的自定义实现。在我的 Couchbase 存储库的自定义实现中，我有以下方法：

String queryAsString = "SELECT MyDatabase.*, META().id as _ID, META().cas as _CAS FROM MyDatabase WHERE segmentId = $id AND _class = $class ORDER BY executionTime DESC LIMIT 1";
JsonObject params = JsonObject.create()
        .put(CLASS_VARIABLE, MyClass.class.getCanonicalName())
        .put(ID_VARIABLE, segmentId);

N1qlQuery query = N1qlQuery.parameterized(queryAsString, params);
List<MyClass> resultList = couchbaseTemplate.findByN1QL(query, SegmentMembers.class);
return resultList.isEmpty() ? null : resultList.get(0);

结果，Spring Data 生成以下 json 对象，表示对 Couchbase 的查询：

{
    "$class":"path/MyClass",
    "statement":"SELECT MyDatabase.*, META().id as _ID, META().cas as _CAS …

我们有一个包含客户数据的 Couchbase 商店。

• 每个客户在这个存储桶中只有一个文档。
• 每日交易将导致更新此客户数据。

示例文档。让我们专注于purchase_product_ids数组。

{
  "customer_id" : 1000
  "purchased_product_ids" : [1, 2, 3, 4, 5 ] 
      # in reality this is a big array - hundreds of elements
  ... 
  ... many other elements ...
  ...
} 

Existing purchased_product_ids : 
    [1, 2, 3, 4, 5]

products purchased today : 
    [1, 2, 3, 6]  // 6 is a new entry, others existing already

Expected result after the update: 
    [1, 2, 3, 4, 5, 6]

我使用Subdocument API来避免服务器和客户端之间的大量数据传输。 …

我正在使用 Couchbase java 客户端 SDK 2.7.9 并且在尝试运行自动集成测试时遇到问题。在这样的测试中，我们通常使用随机端口来在同一个 Jenkins slave 上运行相同的东西（例如使用 docker）。

但是，对于客户端，我们可以指定许多自定义端口，但不能指定 8092、8093、8094 和 8095。

流行的 TestContainers 模块也提到这些端口必须在它们的 Couchbase 模块中保持静态：https ://www.testcontainers.org/modules/databases/couchbase/ 1

显然，也可以在服务器级别更改这些端口。

例子：

Docker-compose.yml

version: '3.0'
services:
  rapid_test_cb:
    build:
      context: ""
      dockerfile: cb.docker
    ports:
      - "8091"
      - "8092"
      - "8093"
      - "11210"

docker 镜像是“couchbase:community-5.1.1”

内部端口是上面写的端口，但外部它们是随机的。在客户端级别，您可以设置 bootstrapHttpDirectPort 和 bootstrapCarrierDirectPort，但显然 8092 和 8093 端口是从服务器端获取的（谁不知道分配给他的是哪个端口）。

我想问您是否可以在客户端级别更改这些端口，如果不能，请认真考虑添加该功能。

我正在尝试将数值添加到参数化中AnalyticsQuery，但在查询运行时不断收到错误。创建查询的 java 如下所示：

  private ParameterizedAnalyticsQuery aggregateQuery(String userId, Long from, Long to) {
    return AnalyticsQuery.parameterized(
        "select d.field1,"
            + " d.field2"
            + " from data d"
            + " where d.userId = $userId"
            + " and d.timestamp between $from and $to",
        JsonObject.create()
            .put("userId", userId)
            .put("from", from)
            .put("to", to)
    );
  }

运行查询时返回以下错误：

<< Encountered \"from\" at column 213. ","code":24000}]

如果我将查询更改为以下内容，那么它将起作用并返回行：

    return AnalyticsQuery.parameterized(
        "select d.field1,"
            + " d.field2"
            + " from data d"
            + " where d.userId = $userId"
            + " and d.timestamp …

我需要使用map函数ex创建一个视图：

function(doc, meta) {
  if(doc.docType == "testDoc")
    emit(meta.id, doc)
}

我必须使用沙发床Java客户端2.1创建此视图。文档中找不到任何东西，谢谢

是否可以使用Couchbases Java Client 2.2.2以编程方式创建和发布二级索引？我希望能够创建和发布运行Couchbase 4.1的自定义二级索引。我知道这可以与Couchbase Views一起使用，但是我找不到相同的索引。

我有一个用例,其中有三个文档,我想以事务方式更新它们,即如果其中任何一个失败,那么其他文档也不应该在数据库中更新.我正在寻找一个选项但在JavaSDK中找不到.那么我有什么方法可以在事务上执行此操作.我使用CAS值来处理并发.请给我一个同时处理此操作的方法.

Couchbase版本:4.0 Java SDK:2.1.6

任何帮助表示赞赏.