bool auto_connect = true;

double so_timeout = 3;

string host = "127.0.0.1";

string port = "27017";

string errmsg = "";

DBClientConnection pConn = new DBClientConnection(auto_connect, 0, so_timeout);

pConn->connect(host+":"+port, errmsg);

string db = "shool";

string collection = "student";

Query condition = QUERY("age"<<20);

int limit = 10;

int offset = 5;

BSONObj columns = BSON("uid"<<1<<"name"<<1);

auto_ptr cursor;

cursor = pConn->query(db+"."+collection, condition, limit, offset, columns, 0, 0);

int uid=0;

string name="";

while(cursor->more())

{

    BSONObj p = cursor->next();

    uid = p["uid"].Int();

    name = p["name"].String();

    count << uid << " " << name << endl;

}

BSONObj insert = BSON("uid"<<10001<<"name"<<"skean1017");

pConn->insert(db+"."+collection, insert, 0);

Query query = QUERY("name"<<"skean1017");

pConn->remove(db+"."+collection, query, true);

Query query = QUERY("uid"<<10001);

BSONObj obj = BSON("$set"<update(db+"."+collection, query, obj, false, false);

Try{

     //写代码。。。。。。

}

catch( mongo::DBException& e ) {

        printf("MONGO Exception(set): %s\n", e.what());

return -1;

    }

catch (std::exception& e) {

printf("MONGO Exception(set): %s\n", e.what());

return -1;

}

catch (...){

       printf(“MONGO Exception\n”);

return -1

}

#include <iostream>

#include "mongo/client/dbclient.h"

using namespace std;

using namespace mongo;

int main(int argc, char const *argv[])

{

     string error;

     /*  初始化对象，

         第一参数：连接数据库超时是否重新连接

           第二参数：默认为0

           第个参数：设定超时的时间

     */

     DBClientConnection conn(false, 0, 3);

     // 连接数据库

     if (!conn.connect("127.0.0.1:27017", error))

     {

           cout << "connect mongo err\n" << error << endl;

     }

#if 0

     /*   第一种方式

     *    插入数据

           第一个参数：数据库名.集合名

     */

     BSONObjBuilder b;

     b.append("_id", 1);

     b.append("name", "test7");

     BSONObj obj = b.obj();

     conn.insert("test1.test", obj);

     /*

           第二种方式

     */

     BSONObj obj;

     obj = BSON("_id" << 2 << "name" << "test8");

     conn.insert("test1.test", obj);

#endif

     /*

           第三种方式

     */

     Query inobj("{_id:3, name:'test9', data:{age:6,sex:man}}");

     conn.insert("test1.test", inobj.obj);

     return 0;

}

#include <iostream>

#include "mongo/client/dbclient.h"

using namespace std;

using namespace mongo;

int main(int argc, char const *argv[])

{

     string error;

     // 初始化

     DBClientConnection conn(false, 0, 3);

     // 连接数据库

     if (!conn.connect("127.0.0.1:27017", error))

     {

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

     }

     /*

           @function:查询

           @param1：数据库名.集合名

           @param2：查询条件

           @return : auto_ptr<DBClientCursor>

     */

     auto_ptr<DBClientCursor> cursor = conn.query("test1.test", Query(""));

     while (cursor->more())//为真next才有信息返回

     {

           // 返回一条文档

           BSONObj obj = cursor->next();

           //cout << obj << endl;

           // 去掉 .0

           //cout << obj.getIntField("_id") << endl;

           //cout << obj["_id"] << endl;

           // 只有字段

           // cout << obj.getField("_id") << endl;

           if (obj.hasElement("data"))

           {

                // 返回data文档的信息

                BSONObj sobj = obj.getObjectField("data");

                cout << sobj << endl;

                cout << sobj.getIntField("age") << endl;

                cout << sobj.getStringField("name") << endl;

           }

     }

     return 0;

}

#include <iostream>

#include "mongo/client/dbclient.h"

using namespace std;

using namespace mongo;

int main(int argc, char const *argv[])

{

     string error;

     DBClientConnection conn(false, 0, 3);

     if (!conn.connect("127.0.0.1:27017", error))

     {

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

           return -1;

     }

     // 修改的字段数据

     Query updobj("{$set:{name:'test9'}}");

     /*

           @func: 更新

           @param2: 要修改的字段

           @param3: 修改的数据

     */

     conn.update("test1.test", Query("{_id:7}"), updobj.obj, false, false);

     return 0;

}

#include <iostream>

#include "mongo/client/dbclient.h"

using namespace std;

using namespace mongo;

int main(int argc, char const *argv[])

{

     string error;

     DBClientConnection conn(false, 0, 3);

     if (!conn.connect("127.0.0.1:27017", error))

     {

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

           return -1;

     }

     /*

           @func: remove

           @param1: 数据库名.集合名

           @param2: 删除的条件

           @param3: 是否删除匹配多条

     */

     conn.remove("test1.test", Query("{name:'test30'}"), false);

     return 0;

}