mongodb c driver使用经验

Posted 2023-06-08 天道酬勤

连接数据库

获取mongoc_cursor_t* cursor

循环获取数据，存入bson_t

const bson_t *doc = nullptr;
while (mongoc_cursor_next(cursor, &doc))

获取迭代器

上面只是获取了对应的文本，需要设置成迭代器才能使用

bson_iter_t iter;
if (bson_iter_init(&iter, doc))

bson_iter_init的作用就是把doc(bson_t)的内容转成iter(bson_iter_t)

查询key是否存在

if (bson_iter_find(&iter, "xxx"))

查询的时候需要注意，一是必须按照存在mongo数据库中的顺序，如果顺序颠倒，后续会查询失败，也就是说当前索引不能回退，比如abc，如果你先查b是可以的，再查a就会报错，如果不查a，继续查c也是可以的；二是如果bson_iter_find返回了false，不管是查询顺序颠倒，还是查询了不存在的key，iter都会失效，无法再使用，需要重新初始化。

版权声明：本文版权归作者所有，如需转载，请标明出处

关于MongoDB API的两个小经验

一、前言

MongoDB也是项目的备选平台，需要用Java和C/C++进行操作。别的不多说，几个关键要求：

1 Collection的列有int, long和BinData(也即二进制数组)类型；

2 Java和C程序写入的数据可以互相读取。

 

二、Java实现BinData读

Java工程里引入mongo-java-driver.jar依赖即可，示例代码很多，这里就不贴了。

别的Column都简单，仅仅在读取BinData时有些麻烦，因为MongoDB的Java API没有直接提供getBinary之类的接口。

解决办法是：引入org.bson.types.Binary类，再转换一下即可：

     Binary binary = (Binary) doc.get("Data");
     obj.setData((byte[]) binary.getData());

顺便说一下，写BinData直接用doc.append()即可，无须担心。

另外，C/C++ API使用的是mongo-c-driver，其中对BinData都有专门的接口，也比较简单。

 

三 、C/C++程序的读取顺序

测试过程中曾出现一个奇怪的问题，就是C/C++程序写入的数据，Java程序可以正取读取，反之则不行。

折腾半天后找到原因：Java API中读取用的是doc.getXxxx(String )方法，与顺序无关。

MongoCursor<Document> cursor = collection.find(docFilter).iterator();

        while (cursor.hasNext())
        {
            Document doc = cursor.next();
            //读取顺序无所谓
            int col2 = doc.getInteger("COL2").intValue();
            long col3 = doc.getLong("COL3").longValue();
            int col1 = doc.getInteger("COL1").intValue();
            ...
        }

 

而在C/C++ API中，读取用的是bson_iter_find(bson_iter_t*, const char*)和bson_iter_xxxx(bson_iter_t*)函数的组合，这里顺序很重要，必须与写入时保持一致（写入顺序和存储顺序也是一致的）。

 mongoc_cursor_t cursor = mongoc_collection_find_with_opts(collection, query, NULL, NULL);

   while (mongoc_cursor_next(cursor, &doc))
  {

    int col1, col2;

    long col3;

    bson_iter_t iter;

    bson_iter_init (&iter, doc);

    //必须与写入时顺序一致

    if (bson_iter_find(&iter, "COL1")) 

      col1 = bson_iter_int32(&iter);

    if (bson_iter_find(&iter, "COL3")) 

      col3 = bson_iter_int64(&iter);

     if (bson_iter_find(&iter, "COL2")) 

      col2 = bson_iter_int32(&iter);

     ...

  }

假设写入数据的顺序是COL1, COL2, COL3，则上段代码中只能获得col1和col2的值，而col3将被跳过。

项目中，将Java程序和C/C++程序的写入顺序都调整一致，再在C/C++程序中按相同顺序读取，问题解决。