[笔记]MongoDB 二(Linux下MongoDB API C++编程)

一、连接类

　　DBClientConnection，派生自DBClientBase。DBClientBase类是实现query, update, insert, remove等功能。

　　构造函数：DBClientConnection(bool _autoReconnect=false, DBClientReplicaSet* cp=0, double so_timeout=0)

　　　　_autoReconect是否自动重连，默认false

　　　　cp不需要关心，默认值

　　　　so_timeout超时时间，单位是秒

　　连接函数：bool connect(const char *hostname, string &errmsg)

　　　　hostname 主机，127.0.0.1,127.0.0.1：5555

　　　　errmsg 错误信息，传出

二、删除文档

　　void remove(const string &ns, Query q, bool justOne=0)

　　　　ns 库名.集合名

　　　　q 是一个查询条件。Query是一个类，利用构造函数Query(const char *json);构造。

　　　　justOne 是否删除一条，默认false

三、新增文档

　　void insert(const string &ns, BSONObj obj, int flag=0)

　　　　ns 库名.集合名

　　　　BSONObj obj：

　　　　　　1、通过BSONObjBuilder构造

 //通过BSONObjBuilder.obj()生成BSONObj

 //第一种形式

 BSONObjBuilder b1;

 //{id:1,name:'haha'}

 b1.append("id",);

 b1.append("name","haha");

 /*

 BSONObj obj() {

             bool own = owned();

             massert( 10335 , "builder does not own memory", own );

             doneFast();

             BSONObj::Holder* h = (BSONObj::Holder*)_b.buf();

             decouple(); // sets _b.buf() to NULL

             return BSONObj(h);

         }

 */

 DBClientConnection.insert("dbName.collectionName",b1.obj());

 //第二种形式

 BSONObjBuilder b2;

 //{id:2,name:'hehe'}

 /*

     template<class T>

     BSONObjBuilder& operator<<( T value );

 */

 b2<<"id"<<<<"name"<<"hehe";

 //余下同上

 //第三种形式

 /*

 #define BSON(x) (( mongo::BSONObjBuilder(64) << x ).obj())

 */

 //{id:3,name:'hahe'}

 BSONObjBuilder b3=BSON("id"<<<<"name"<<hahe");

　　　　　　2、通过Query构造

 //{id:4,name:'heha'}

 Query ins("{id:4,name:'heha'}");

 /*

 class Query {

     public:

         BSONObj obj;

         Query() : obj(BSONObj()) { }

         Query(const BSONObj& b) : obj(b) { }

         Query(const string &json);

         Query(const char * json);

 */

 insert("dbName.collectionName",ins.obj);

四、修改文档

　　void update(const string &ns, Query query, BSONObj obj, bool upsert = false, bool multi = false);

　　ns 库名.集合名

　　query 查询的条件

　　obj 更新的内容

　　upsert 如果条件不成立是否新增

　　multi 是否更新多条

 //查询条件

 Query query("{id:1}");

 //更新内容

 Query bobj("{name:'hehe'}");

 update("dbName.collectionName",query,bobj.obj);

五、查询文档

　　virtual auto_prt<DBClientCursor> query(const string &ns, Query query=Query(), int nToReturn =0, int nToSkip=0, const BSONObj *fieldsToReturn=0, int queryOptions=0, int batchSize=0)

　　auto_prt<DBClientCursor> 智能指针，自动释放<>内部的内存数据

　　　　DBClientCursor类，存放查询结果。more()判断调用next是否安全。next()返回BSONObj对象

　　　　　　DBClientCursor部分源码：

/** Queries return a cursor object */

    class DBClientCursor : public DBClientCursorInterface {

    public:

        /** If true, safe to call next().  Requests more from server if necessary. */

        bool more();

        /** If true, there is more in our local buffers to be fetched via next(). Returns

            false when a getMore request back to server would be required.  You can use this

            if you want to exhaust whatever data has been fetched to the client already but

            then perhaps stop.

        */

        int objsLeftInBatch() const { _assertIfNull(); return _putBack.size() + batch.nReturned - batch.pos; }

        bool moreInCurrentBatch() { return objsLeftInBatch() > ; }

        /** next

           @return next object in the result cursor.

           on an error at the remote server, you will get back:

             { $err: <string> }

           if you do not want to handle that yourself, call nextSafe().

        */

        BSONObj next();

　　　　ns，query 同前

　　　　nToReturn 返回记录数

　　　　nToSkip 跳过记录数

　　　　fieldsTOReturn 要返回的字段

DBClientConnection conn(false,,);

std::string errmsg;

if (!conn.connect("localhost:27018", errmsg))

{

    cout << "connect to mongo err" << endl;

    return -;

}

auto_ptr<DBClientCursor> cursor = conn.query("dbName.collectionName", Query("{}"));

　　　　读取查询结果：

　　　　　　BSONObj重载了<<

　　　　　　　　部分源码：

inline std::ostream& operator<<( std::ostream &s, const BSONObj &o ) {

        return s << o.toString();

    }

inline std::string BSONObj::toString( bool isArray, bool full ) const {

        if ( isEmpty() ) return "{}";

        StringBuilder s;

        toString(s, isArray, full);

        return s.str();

    }

inline void BSONObj::toString( StringBuilder& s,  bool isArray, bool full, int depth ) const {

        if ( isEmpty() ) {

            s << "{}";

            return;

        }

        s << ( isArray ? "[ " : "{ " );

        BSONObjIterator i(*this);

        bool first = true;

        while (  ) {

            massert(  ,  "Object does not end with EOO", i.moreWithEOO() );

            BSONElement e = i.next( true );

            massert(  ,  "Invalid element size", e.size() >  );

            massert(  ,  "Element too large", e.size() < (  <<  ) );

            int offset = (int) (e.rawdata() - this->objdata());

            massert(  ,  "Element extends past end of object",

                     e.size() + offset <= this->objsize() );

            e.validate();

            bool end = ( e.size() + offset == this->objsize() );

            if ( e.eoo() ) {

                massert(  ,  "EOO Before end of object", end );

                break;

            }

            if ( first )

                first = false;

            else

                s << ", ";

            e.toString( s, !isArray, full, depth );

        }

        s << ( isArray ? " ]" : " }" );

    }

　　　　　　读取指定字段内容

　　　　　　　　BSONObj::getField(const StringData& name)

　　　　　　　　源码：

inline BSONElement BSONObj::getField(const StringData& name) const {

    BSONObjIterator i(*this);

    while ( i.more() ) {

        BSONElement e = i.next();

        if ( strcmp(e.fieldName(), name.data()) ==  )

            return e;

    }

    return BSONElement();

}

　　　　　　　　BSONElement部分源码：

class BSONElement {

public:

    /** These functions, which start with a capital letter, throw a UserException if the

        element is not of the required type. Example:

        std::string foo = obj["foo"].String(); // std::exception if not a std::string type or DNE

    */

    std::string String()        const { return chk(mongo::String).valuestr(); }

    Date_t Date()               const { return chk(mongo::Date).date(); }

    double Number()             const { return chk(isNumber()).number(); }

    double Double()             const { return chk(NumberDouble)._numberDouble(); }

    long long Long()            const { return chk(NumberLong)._numberLong(); }

    int Int()                   const { return chk(NumberInt)._numberInt(); }

    bool Bool()                 const { return chk(mongo::Bool).boolean(); }

    std::vector<BSONElement> Array() const; // see implementation for detailed comments

    mongo::OID OID()            const { return chk(jstOID).__oid(); }

    void Null()                 const { chk(isNull()); } // throw UserException if not null

    void OK()                   const { chk(ok()); }     // throw UserException if element DNE

　　　　　　　　读取的字段不存在，程序会出现异常，需要调用hasField(char*)或者hasElement(char*)判断是否有该元素

　　　　　　　示例

while (cursor->more())

{//判断是否有下一条

    mongo::BSONObj obj = cursor->next();//取下一条记录，为BSONObj格式

    //cout << obj << endl;

    //解析数据

    cout << "id:" << obj.getField("id").Number() << ",name:" << obj.getField("name").String();

    if (obj.hasElement("age"))

        {//是否存在该元素

        cout << ",age:" << obj.getField("age").Number();

    }

    cout << endl;

}

巴特西

[笔记]MongoDB 二(Linux下MongoDB API C++编程)

最新文章

热门文章