C#开发基础

本文档将介绍如何使用 CSharp 驱动接口编写使用 SequoiaDB 数据库的程序,包括 SequoiaDB 数据库 CSharp 驱动的简单示例,详细的使用规范可参照官方的 CSharp API 文档。

命名空间

在使用 CSharp 驱动的相关 API 之前,你必须在源代码中添加如下的 using 申明:

  1. using SequoiaDB;
  2. using SequoiaDB.Bson;

数据操作

  • 连接数据库和身份验证

    若数据库没有创建用户,则可以匿名连接到数据库:

    1. string addr = "127.0.0.1:11810";
    2. Sequoiadb sdb = new Sequoiadb(addr);
    3. try
    4. {
    5. sdb.Connect();
    6. }
    7. catch (BaseException e)
    8. {
    9. Console.WriteLine("ErrorCode:{0}, ErrorType:{1}", e.ErrorCode, e.ErrorType);
    10. Console.WriteLine(e.Message);
    11. }
    12. catch (System.Exception e)
    13. {
    14. Console.WriteLine(e.StackTrace);
    15. }

    否则,连接的时候必须指定用户名和密码:

    1. string addr = "127.0.0.1:11810";
    2. Sequoiadb sdb = new Sequoiadb(addr);
    3. try
    4. {
    5. sdb.Connect("testusr", "testpwd");
    6. }
    7. catch (BaseException e)
    8. {
    9. Console.WriteLine("ErrorCode:{0}, ErrorType:{1}", e.ErrorCode, e.ErrorType);
    10. Console.WriteLine(e.Message);
    11. }
    12. catch (System.Exception e)
    13. {
    14. Console.WriteLine(e.StackTrace);
    15. }

    这里给出了异常信息的 try 和 catch 块,下面的所有操作都会抛出同样的异常信息,因此不再给出相关的 try 和 catch 块。

  • 断开与数据库连接

    1. // do not forget to disconnect from sdb
    2. sdb.Disconnect();
  • 得到或创建集合空间和集合

    根据名字,得到对应的 CollectionSpace,如果不存在,则创建:

    1. // get if the CollectionSpace exists, otherwise create
    2. string csName = "TestCS";
    3. CollectionSpace cs = null;
    4. if (sdb.IsCollectionSpaceExist(csName))
    5. {
    6. cs = sdb.GetCollectionSpace(csName);
    7. }
    8. else
    9. {
    10. cs = sdb.CreateCollectionSpace(csName);
    11. // or sdb.CreateCollectionSpace(csName, pageSize), need to specify the pageSize
    12. }

    根据名字,得到对应的 Collection,如果不存在,则创建:

    1. // get if the Collection exists, otherwise create
    2. string clName = "TestCL";
    3. DBCollection dbc = null;
    4. if (cs.IsCollectionExist(clName))
    5. {
    6. dbc = cs.GetCollection(clName);
    7. }
    8. else
    9. {
    10. dbc = cs.CreateCollection(clName);
    11. //or cs.CreateCollection(clName, options), create collection with some options
    12. }
  • 对 Collection 进行插入操作

    创建需要插入的数据 BsonDocument 并插入:

    1. BsonDocument insertor = new BsonDocument();
    2. string date = DateTime.Now.ToString();
    3. insertor.Add("operation", "Insert");
    4. insertor.Add("date", date);
    5. dbc.Insert(insertor);

    当然,BsonDocument 中还可以嵌套 BsonDocument 对象;而且你还可以直接 new 一个完整的 BsonDocument,而不需要通过 Add 方法:

    1. BsonDocumentinsertor = new BsonDocument
    2. {
    3. {"FirstName","John"},
    4. {"LastName","Smith"},
    5. {"Age",50},
    6. {"id",i},
    7. {"Address",
    8. new BsonDocument
    9. {
    10. {"StreetAddress","212ndStreet"},
    11. {"City","NewYork"},
    12. {"State","NY"},
    13. {"PostalCode","10021"}
    14. }
    15. },
    16. {"PhoneNumber",
    17. new BsonDocument
    18. {
    19. {"Type","Home"},
    20. {"Number","212555-1234"}
    21. }
    22. }
    23. };

    插入多条数据:

    1. //bulkinsert
    2. List< BsonDocument > insertor=new List < BsonDocument > ();
    3. for(int i=0;i<10;i++)
    4. {
    5. BsonDocument obj=new BsonDocument();
    6. obj.Add("operation","BulkInsert");
    7. obj.Add("date",DateTime.Now.ToString());
    8. insertor.Add(obj);
    9. }
    10. dbc.BulkInsert(insertor,0);
  • 索引的相关操作

    创建索引:

    1. //createindexkey,indexonattribute'Id'byASC(1)/DESC(-1)
    2. BsonDocument key = new BsonDocument();
    3. key.Add("id", 1);
    4. string name = "index name";
    5. bool isUnique = true;
    6. bool isEnforced = true;
    7. dbc.CreateIndex(name, key, isUnique, isEnforced);

    删除索引:

    1. string name = "index name";
    2. dbc.DropIndex(name);
  • 查询操作

    进行查询操作,需要使用游标对查询结果进行遍历,而且可以先得到当前 Collection 的索引,如果不为空,可作为制定访问计划(hint)用于查询:

    1. DBCursor icursor = dbc.GetIndex(name);
    2. BsonDocument index = icursor.Current();

    构建相应的 BsonDocument 对象用于查询,包括:查询匹配规则(matcher,包含相应的查询条件),域选择(selector),排序规则(orderBy,增序或降序),制定访问计划(hint),跳过记录个数(0),返回记录个数(-1:返回所有数据)。查询后,得到对应的 Cursor,用于遍历查询得到的结果:

    1. BsonDocument matcher = new BsonDocument();
    2. BsonDocument conditon = new BsonDocument();
    3. conditon.Add("$gte", 0);
    4. conditon.Add("$lte", 9);
    5. matcher.Add("id", conditon);
    6. BsonDocument selector = new BsonDocument();
    7. selector.Add("id", null);
    8. selector.Add("Age", null);
    9. BsonDocument orderBy = new BsonDocument();
    10. orderBy.Add("id", -1);
    11. BsonDocument hint = null;
    12. if (index != null)
    13. hint = index;
    14. else
    15. hint = new BsonDocument();
    16. DBCursor cursor = dbc.Query(matcher, selector, orderBy, hint, 0, -1);

    使用 DBCursor 游标进行遍历:

    1. while (cursor.Next() != null)
    2. Console.WriteLine(cursor.Current());
  • 删除操作

    构建相应的 BsonDocument 对象,用于设置删除的条件:

    1. //createthedeletecondition
    2. BsonDocument drop = new BsonDocument();
    3. drop.Add("Last Name", "Smith");
    4. coll.Delete(drop);
  • 更新操作

    构建相应的 BsonDocument 对象,用于设置更新条件,你还可以创建 DBQuery 对象封装所有的查询或更新规则:

    1. DBQuery query = new DBQuery();
    2. BsonDocument updater = new BsonDocument();
    3. BsonDocument matcher = new BsonDocument();
    4. BsonDocument modifier = new BsonDocument();
    5. updater.Add("Age", 25);
    6. modifier.Add("$set", updater);
    7. matcher.Add("First Name", "John");
    8. query.Matcher = matcher;
    9. query.Modifier = modifier;
    10. dbc.Update(query);

    更新操作,如果没有满足 matcher 的条件,则插入此记录:

    1. dbc.Upsert(query);