1、初始化mongoc
非線程安全，只需調(diào)用一次
mongoc_init();
2、設(shè)置日志回調(diào)
static void log_handler (mongoc_log_level_t log_level,
const char* log_domain, const char* message, void* user_data)
{
cout << "[mongo][" << log_domain << "]" << message;
}
mongoc_log_set_handler (log_handler, NULL);
3、連接mongodb
const char *uristr = "mongodb://127.0.0.1/";
mongoc_client_t* m_pClient = mongoc_client_new(uristr);
4、獲取collection
mongoc_collection_t * m_pCollection = mongoc_client_get_collection(m_pClient, "test_db", "test_collection");
5、打印bson調(diào)試
MongoDB使用了BSON這種結(jié)構(gòu)來存儲數(shù)據(jù)和網(wǎng)絡(luò)數(shù)據(jù)交換。 mongoc提供了方法將bson格式轉(zhuǎn)化為json， 可以用于打印調(diào)試 。
char* str = bson_as_json(doc, NULL);
fprintf(stdout, "%s\n", str);
6、插入記錄
bson_error_t error;
bson_t *doc = bson_new();
BSON_APPEND_INT64(doc, "id", 1);
BSON_APPEND_INT64(doc, "field1", 0);
string msg = "test message";
BSON_APPEND_BINARY(doc, "field2", BSON_SUBTYPE_BINARY, (const uint8_t*)(msg.c_str()), (uint32_t)(msg.size()));
bool r = mongoc_collection_insert(m_pCollection, MONGOC_INSERT_NONE, doc, NULL, &error);
if (!r)
{
cout << "Insert Failure:" << error.message;
}
bson_destroy(doc);
7、更新記錄
bson_error_t error;
bson_t *doc = bson_new();
bson_t child;
bson_append_document_begin(doc, "$set", -1, &child);
BSON_APPEND_INT64(&child, "field1", 22);
bson_append_document_end(doc, &child);
bson_t query;
bson_init(&query);
BSON_APPEND_INT64(&query, "id", 1);
bool r = mongoc_collection_update(m_pCollection,
MONGOC_UPDATE_NONE,
&query,
doc,
NULL,
&error);
if (!r)
{
cout << "Update Failure: " << error.message;
}
bson_destroy(&query);
bson_destroy(doc);
8、刪除記錄
bson_error_t error;
bson_t query;
bson_init(&query);
BSON_APPEND_INT64(&query, "id", 1);
bool r = mongoc_collection_delete(m_pCollection,
MONGOC_DELETE_NONE,
&query,
NULL,
&error);
if (!r)
{
cout << "Delete Failure: " << error.message;
ret = ERR_MONGODB_FAILED;
}
bson_destroy(&query);
posted on 2014-09-26 17:03
merlinfang 閱讀(8465)
評論(0) 編輯 收藏 引用 所屬分類:
mongodb