zoukankan      html  css  js  c++  java
  • 关于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++程序中按相同顺序读取,问题解决。

  • 相关阅读:
    Java接口
    【精】搭建redis cluster集群,JedisCluster带密码访问【解决当中各种坑】!
    java操作redis集群配置[可配置密码]和工具类(比较好用)
    关于Jedis是否线程安全的测试
    RedisDesktopManager如何使用命令行?
    多线程按行读取文件【我】
    根据开始字符串和结束字符串截取文件生成另一个文件(日志处理)【我】
    Redis操作List工具类封装,Java Redis List命令封装
    缓存数据库-redis数据类型和操作(list)
    Redis需要多少内存预留-内存占用多少才安全
  • 原文地址:https://www.cnblogs.com/wggj/p/7169429.html
Copyright © 2011-2022 走看看