欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

Couchbase学习

程序员文章站 2022-06-12 14:29:05
介绍 couchbase的关键有两点:延后写入和松散存储。延后写入,顾名思义,couchbase在对数据进行增删时会先体现在内存中,而不会立刻体现在硬盘上,从内存的修改到硬盘的修改这一步骤是由couchbase自动完成,等待执行的硬盘操作会以write queue的形式排队等待执行,也正是通过这个方 ......

介绍

  couchbase的关键有两点:延后写入和松散存储。延后写入,顾名思义,couchbase在对数据进行增删时会先体现在内存中,而不会立刻体现在硬盘上,从内存的修改到硬盘的修改这一步骤是由couchbase自动完成,等待执行的硬盘操作会以write queue的形式排队等待执行,也正是通过这个方法,硬盘的I/O效率在write queue满之前是不会影响couchbase的吞吐效率的,而write queue的长度是可以设置的。松散存储也很好理解,在关系型数据库中,要先建库建表,最后插数据,而在couchbase中bucket就相当于库,没有表的存在,直接就插数据了。关系型数据库依赖表来进行条件查询,couchbase一开始没有具备表功能的结构,所以是无法执行条件查询的,但是通过view则可以手动添加所需要的关系,view的设置是非常复杂的一部分。总之couchbase的一般逻辑是建bucket——>插入数据——>建立View。正是因为关系可以后天建立,才使得不必预先规划数据应具备的关系,随用随建即可。当然,对couchbase而言插入数据其实是插入json格式的文件。couchbase的精髓就在于依赖内存最大化降低硬盘I/O对吞吐量的负面影响。

NuGet 添加

  CouchbaseNetClient

配置文件

  <configSections>
    <sectionGroup name="couchbaseClients">
      <section name="couchbase" type="Couchbase.Configuration.Client.Providers.CouchbaseClientSection, Couchbase"/>
    </sectionGroup>
  </configSections>
  <couchbaseClients>
    <couchbase>
      <servers>
        <add uri="http://localhost:8091"></add>
      </servers>
      <buckets>
        <add name="default" password="" useSsl="false">
          <connectionPool name="custom" maxSize="10" minSize="5" waitTimeout="5000" shutdownTimeout="3000"></connectionPool>
        </add>
      </buckets>
    </couchbase>
  </couchbaseClients>

C#代码例子

ClusterHelper.Initialize();
var cluster = ClusterHelper.Get();
using (var bucket = cluster.OpenBucket("default"))
{
    //创建文档    
    for (int i = 1; i < 10000; i++)
    {
        var testChild = new
        {
            FirstName = "张三",
            Age = i > 100 ? i % 100 : i,
            Gender = i % 2 == 0 ? "女" : "男"
        };

        string strGUID = "document_id_00" + i.ToString();
        var doc = new Document<dynamic>
        {
            Id = strGUID,
            Content = testChild
        };
        //没有数据新增,有数据更新
        bucket.Upsert(doc);
    }
    
    // 根据ID查询数据     
    var resultDoc = bucket.Get<string>("document_id_001");
    //根据View查询数据   组合key    
    List<object> startKey = new List<object>() { "GetNan", 20 };
    List<object> endKey = new List<object>() { "GetNv", 22 };
    var view = bucket.CreateQuery("document_id", "Test").StartKey(startKey).EndKey(endKey);
    var query = await bucket.QueryAsync<dynamic>(view);
    //根据View查询数据   key  
    var view1 = bucket.CreateQuery("document_id", "Test2").StartKey(0).EndKey(100);
    var query1 = await bucket.QueryAsync<dynamic>(view1);
}

Couchbase中View介绍

emit中第一个参数为key,第二个参数是返回值,组合key用[]括起来,doc为自己建的文档,meta默认的,有四个参数id等。简单来说就是emit中就是key,value 

function (doc, meta) {
  emit(doc.age, doc);
  if(doc.gender=="男")
    {
     emit(["GetNan",doc.age],doc);
    }
  if(doc.gender=="女")
    {
     emit(["GetNv",doc.age],doc);
    }
}

emit(["GetNv",doc.age],null);返回值为null的解释

  1. index 會很大
  2. couchbase在forum裡的技術說不要emit doc
  3. 返回index是單線程, 自己寫拿取doc可以拼行
  4. 我们称key-value生成的为primary index,id-key生成的为back index。
  5. 如果用doc的话可能会引发类型为“System.OutOfMemoryException”的异常。

本地Couchbase 4.1文档

  1. 下载java jdk
  2. 配置环境变量
  3. clone https://github.com/couchbase/docs-cb4/
  4. clone https://github.com/couchbaselabs/dita-ot-2.1.1
  5. 打开cmd窗口,进入dita-ot-2.1.1的bin目录,输入“dita -version”命令。如果显示“DITA-OT version 2.1.1”,则表示环境搭建OK。
  6. dita -f html5 -i d:/GitProject/docs-cb4/content/cb-docs.ditamap -o d:/couchbaseDoc/output/
  其中-f表示发布文档保存格式,-i表示待发布的文档的* ditamap 文件,-o 表示发布结果保存路径
  7. 打开d:/couchbaseDoc/output/index.html 即可查看文档

创建indexex  ([`]这不是双引号也不是带引号是数字【1】左边的的)

  1. 常见index
  CREATE INDEX `beer-sample-type-index` ON `beer-sample`(type) USING GSI WITH {"defer_build":true};
  2. 查询是否创建成功
  SELECT * FROM system:indexes WHERE name="beer-sample-type-index";
  3. build index
  BUILD INDEX ON `beer-sample`(`beer-sample-type-index`) USING GSI;
  4. 查询数据
  SELECT * FROM `beer-sample` WHERE type="beer-sample-type-index";