mongo-c-driver MongoDB使用笔记

转自：mongo-c-driver MongoDB使用笔记_May的专栏-CSDN博客
 

最近一个项目，使用了MongoDB，c 语言调用 mongo-c-driver 函数实现数据库的操作，网上资料较少，自己摸索总结了一些方法，做个记录。

一、查询

1、函数 mongoc_collection_find_with_opts 和  mongoc_collection_find 

     如果只有查询条件，没有输出条件，这两个函数都可使用；如果有输出条件，则使用mongoc_collection_find_with_opts，结合关键字：projection

例子：

query = BCON_NEW("AfileID", FileID);
bson_init(&child3);
BSON_APPEND_DOCUMENT_BEGIN(&child3, "projection", &child);
BSON_APPEND_INT32(&child, "_id", 0);
BSON_APPEND_INT32(&child, "username", 0);
bson_append_document_end(&child3, &child);
cursor = mongoc_collection_find_with_opts(collection_file, query, &child3, NULL);
    其中，_id是MongoDB自动添加的id字段， BSON_APPEND_INT32(&child, "_id", 0);中的0，表示不输出。

2、比较

1）不等于：not eq：

                        bson_append_document_begin(&child2, "username", -1, &child3);
                        bson_append_document_begin(&child3, "$not", -1, &child4);
                        BSON_APPEND_UTF8(&child4, "$eq", m_username);
                        bson_append_document_end(&child3, &child4);
                        bson_append_document_end(&child2, &child3)；
2）包含：regex （任意位置开始匹配）

                        bson_append_document_begin(&child2, "userpart", -1, &child3);
                        BSON_APPEND_UTF8(&child3, "$regex", sstr2.c_str());
                        bson_append_document_end(&child2, &child3);
                regex  ^  （从头开始匹配）

            allpath = "^" + sdirold + "\/";                 
            bson_init(&child2);
            BSON_APPEND_DOCUMENT_BEGIN(&child2, "where", &child);
            BSON_APPEND_UTF8(&child, "$regex", allpath.c_str());
            bson_append_document_end(&child2, &child);
3）并且：and

                        bson_append_array_begin(&query, "$and", -1, &child);
 
                        bson_append_document_begin(&child, "0", -1, &child2);
                        bson_append_document_begin(&child2, "userpart", -1, &child3);
                        BSON_APPEND_UTF8(&child3, "$regex", sstr2.c_str());
                        bson_append_document_end(&child2, &child3);
                        bson_append_document_end(&child, &child2);
 
                        bson_append_document_begin(&child, "1", -1, &child2);
                        bson_append_document_begin(&child2, "username", -1, &child3);
                        bson_append_document_begin(&child3, "$not", -1, &child4);
                        BSON_APPEND_UTF8(&child4, "$eq", m_username);
                        bson_append_document_end(&child3, &child4);
                        bson_append_document_end(&child2, &child3);
                        bson_append_document_end(&child, &child2);
                        bson_append_array_end(&query, &child);
4）或：or

                bson_append_array_begin(&query, "$or", -1, &child);
                bson_append_document_begin(&child, "0", -1, &child2);
                BSON_APPEND_UTF8(&child2, "username", m_username);
                bson_append_document_end(&child, &child2);
                bson_append_document_begin(&child, "1", -1, &child2);
                BSON_APPEND_UTF8(&child2, "shareuser", m_username);
                bson_append_document_end(&child, &child2);
                bson_append_array_end(&query, &child);
5）(>) 大于 - $gt           (<) 小于 - $lt          (>=) 大于等于 - $gte        (<= ) 小于等于 - $lte

        bson_append_document_begin(&child2, "date_time", -1, &child3);
        BSON_APPEND_DATE_TIME(&child3, "$gte", mktime(&p1) * 1000);
        bson_append_document_end(&child2, &child3);
二、更新

1、mongoc_collection_update (mongoc_collection_t *collection,
                          mongoc_update_flags_t flags,
                          const bson_t *selector,
                          const bson_t *update,
                          const mongoc_write_concern_t *write_concern,
                          bson_error_t *error);

其中，flags参数有三种选择：

typedef enum {
   MONGOC_UPDATE_NONE = 0,                            //默认，只修改第一条匹配上的记录
   MONGOC_UPDATE_UPSERT = 1 << 0,              //找到匹配的记录就修改，找不到就追加一条记录
   MONGOC_UPDATE_MULTI_UPDATE = 1 << 1,   //批量更新所有匹配上的记录
} mongoc_update_flags_t;

2、更新指定字段：set

query = BCON_NEW("AfileID", FileID);
bson_t *docUpDate = bson_new();
docUpDate = BCON_NEW("$set", "{",                
    "filename", newfile.c_str()/*修改值*/,
    "where", newpath.c_str(),    
    "}");
mongoc_collection_update(collection_file, MONGOC_UPDATE_NONE, query, docUpDate, NULL, &error);
三、字段值为数组的操作：

1、数组字段的匹配，可以完全参照非数组字段，只要数组中出现了条件匹配值，则命中。

BSON_APPEND_UTF8(&child2, "shareuser", m_username);
其中，shareuser 字段是数组字段。 

2、数组元素添加 ： addToSet

        bson_init(&query2);
        BSON_APPEND_INT64(&query2, "hash", pichash);
        updatedoc = bson_new();
        bson_append_document_begin(updatedoc, "$addToSet", -1, &child);
        BSON_APPEND_UTF8(&child, "AfileID", FileID);               //AfileID字段值为数组
        bson_append_document_end(updatedoc, &child);
        mongoc_collection_update(collectionp, MONGOC_UPDATE_UPSERT, &query2, updatedoc, NULL, &error);
3、数组元素删除：  pull

      query2 = BCON_NEW("AfileID", out.c_str());
      updatedoc = bson_new();
      bson_append_document_begin(updatedoc, "$pull", -1, &child);
      BSON_APPEND_UTF8(&child, "AfileID", out.c_str());
      bson_append_document_end(updatedoc, &child);
      mongoc_collection_update(collection_k, MONGOC_UPDATE_MULTI_UPDATE, query2, updatedoc, NULL, &error); 
四、ISODate 类型字段的操作

1、插入：ISODate 类型时间，是1900年1月1日0分0秒，到现在的毫秒数（减掉时区），如果想保存到数据库中，则：

    bson_t *insert ;
    time_t timer;
    time(&timer);
    tm tmNow;
    localtime_s(&tmNow, &timer);
    bson_error_t error;
    insert = bson_new();
    BSON_APPEND_DATE_TIME(insert, "date_time", mktime(&tmNow) * 1000);//日期类型field的插入
    BSON_APPEND_INT32(insert, "total", totaluser);
    BSON_APPEND_INT32(insert, "online", totalonline);
    if (!mongoc_collection_insert(collection_on, MONGOC_INSERT_NONE, insert, NULL, &error))
结果如下：

{
    "_id" : ObjectId("5dc0c70ace1c000032002a34"),
    "date_time" : ISODate("2019-11-05T00:49:14.000Z"),
    "total" : 315,
    "online" : 1
}
比现在时间少了8小时。

2、比较：查找 p1-p2 时间段内的数据记录  p1、p2为 tm 类型变量

        bson_init(&query);
        bson_append_array_begin(&query, "$and", -1, &child);
        bson_append_document_begin(&child, "0", -1, &child2);
        bson_append_document_begin(&child2, "date_time", -1, &child3);
        BSON_APPEND_DATE_TIME(&child3, "$gte", mktime(&p1) * 1000);
        bson_append_document_end(&child2, &child3);
        bson_append_document_end(&child, &child2);
        bson_append_document_begin(&child, "1", -1, &child2);
        bson_append_document_begin(&child2, "date_time", -1, &child3);
        BSON_APPEND_DATE_TIME(&child3, "$lte", mktime(&p2) * 1000);
        bson_append_document_end(&child2, &child3);
        bson_append_document_end(&child, &child2);
        bson_append_document_end(&query, &child);
        cursor = mongoc_collection_find(collection_on, MONGOC_QUERY_NONE, 0, 0, 0, &query, NULL, NULL);
3、提取数据库中 ISODate 类型字段：

实际上，数据库中的每条记录，转换成字符串如下所示：

 { "_id" : { "$oid" : "5deef071a6070000910072a4" }, "date_time" : { "$date" : 1575940209000 }, "total" : 315, "online" : 1 }
date_time字段是一个json结构，提取方法如下： 

    value2= value["date_time"];
    maxontime =(time_t)( value2["$date"].asInt64() /1000);
 
————————————————
版权声明：本文为CSDN博主「may」的原创文章，遵循CC 4.0 BY-SA版权协议，转载请附上原文出处链接及本声明。
原文链接：https://blog.csdn.net/sxm0403/article/details/103471910