mongo time setting
发布日期:2021-06-30 22:15:15
浏览次数:2
分类:技术文章
本文共 31016 字,大约阅读时间需要 103 分钟。
前言
修改记录后, 突然扫到时间怎么不对啊.
查了下, 写挫了. 服务器本地时间是米国时间, 因为mongodb中存的时间是(utc+5).// testCTime.cpp : Defines the entry point for the console application.//#include "stdafx.h"#include#include #include #include int main(int argc, char* argv[]){ struct tm birthday; char* pcDispTime = NULL; char szBuf[260] = { '\0'}; int iSize = sizeof(birthday); memset(&birthday, 0, iSize); // 参数2是设置的值, 参数3是size字节数 // 1973-4-1 0:0:0 birthday.tm_year = 1973 - 1900; // base 1900 birthday.tm_mon = 4 - 1; birthday.tm_mday = 1; strftime (szBuf, 260 ,"%Y-%m-%d %H:%M:%S", &birthday); printf("time is %s\n", szBuf); system("pause"); return 0;}
封装了一个函数setTime, 以后不会弄错了
#include#include #include #include #include "MongoDbEx.h"#include "BusinessLogic.h"int testcase_mongoc_example_command_simple(int argc, char* argv[]);int testcase_mongoc_example_document_add(int argc, char* argv[]);int testcase_mongoc_example_document_query_all(int argc, char* argv[]);int testcase_mongoc_example_document_query_special(int argc, char* argv[]);int testcase_mongoc_example_document_modify(int argc, char* argv[]);int main(int argc, char* argv[]){ printf("============================================================\n"); printf(">> testcase v1.0.0.5\n"); printf("============================================================\n"); // testcase_mongoc_example_document_modify(argc, argv); // testcase_mongoc_example_document_query_special(argc, argv); // testcase_mongoc_example_document_query_all(argc, argv); testcase_mongoc_example_document_add(argc, argv); // testcase_mongoc_example_command_simple(argc, argv); printf("============================================================\n"); printf("END\n"); printf("============================================================\n"); return 0;}int testcase_mongoc_example_document_modify(int argc, char* argv[]){ // 先找到记录, 构造要修改的内容, 再调用mongoc_collection_update更新记录 // 再调用查询函数, 看看有没有改成功 mongoc_client_t* client; mongoc_collection_t* collection; mongoc_cursor_t* cursor; const bson_t* doc; bson_t* query; bson_t* modify; bson_t child; bson_error_t error; long lIndex = 0; char szBuf[260] = {'\0'}; mongoc_init(); client = mongoc_client_new( "mongodb://localhost:27017/?appname=find-specific-example"); collection = mongoc_client_get_collection(client, "db_ls", "coll_ls"); // find db record set name : {first:lostspeed3, last:cn} query = bson_new(); bson_append_document_begin(query, "name", -1, &child); BSON_APPEND_UTF8(&child, "first", "lostspeed3"); BSON_APPEND_UTF8(&child, "last", "cn"); bson_append_document_end(query, &child); // make modify content modify = bson_new(); bson_append_document_begin(modify, "name", -1, &child); BSON_APPEND_UTF8(&child, "first", "lostspeed258"); BSON_APPEND_UTF8(&child, "last", "hk"); bson_append_document_end(modify, &child); // query cursor = mongoc_collection_find_with_opts(collection, query, NULL, NULL); // modify lostspeed3.cn to lostspeed258.hk while (mongoc_cursor_next(cursor, &doc)) { sprintf(szBuf, "find [%ld]\0", lIndex++); ShowDocument(szBuf, (bson_t*)doc); if (!mongoc_collection_update(collection, MONGOC_UPDATE_NONE, query, modify, NULL, &error)) { ShowErrMsg("mongoc_collection_update", &error); } else { printf("modify ok\n"); // 查询是否修改成功了, 其实不用查,成功是由mongo保证的 // 如果修改失败了,一定是自己写挫了,或者mongodb中没有这样的记录 // 用mongoManager看看就行了, 看过了, 修改成功 } break; } bson_destroy(modify); bson_destroy(query); mongoc_cursor_destroy(cursor); mongoc_collection_destroy(collection); mongoc_client_destroy(client); mongoc_cleanup();}int testcase_mongoc_example_document_query_special(int argc, char* argv[]){ mongoc_client_t* client; mongoc_collection_t* collection; mongoc_cursor_t* cursor; const bson_t* doc; bson_t* query; bson_t child; long lIndex = 0; char szBuf[260] = {'\0'}; mongoc_init(); client = mongoc_client_new( "mongodb://localhost:27017/?appname=find-specific-example"); collection = mongoc_client_get_collection(client, "db_ls", "coll_ls"); query = bson_new(); // find db record set name : {first:lostspeed3, last:cn} bson_append_document_begin(query, "name", -1, &child); BSON_APPEND_UTF8(&child, "first", "lostspeed3"); BSON_APPEND_UTF8(&child, "last", "cn"); bson_append_document_end(query, &child); cursor = mongoc_collection_find_with_opts(collection, query, NULL, NULL); while (mongoc_cursor_next(cursor, &doc)) { sprintf(szBuf, "find [%ld]\0", lIndex++); ShowDocument(szBuf, (bson_t*)doc); // ok : only find one record /** [find [0]] { "_id" : { "$oid" : "58e351936e955221a1689462" }, "name" : { "first" : "lostspeed3", "last" : "cn" }, "birthday" : { "$date" : 2234350468000 }, "skill" : [ "C", "C++", "MASM", "RE" ], "degrees" : [ { "school" : "zhongnian", "degree" : "graduates" }, { "school" : "cr", "degree" : "graduates" } ] } */ } bson_destroy(query); mongoc_cursor_destroy(cursor); mongoc_collection_destroy(collection); mongoc_client_destroy(client); mongoc_cleanup();}int testcase_mongoc_example_document_query_all(int argc, char* argv[]){ mongoc_client_t* client = NULL; mongoc_collection_t* collection = NULL; mongoc_cursor_t* cursor = NULL; const bson_t* doc = NULL; bson_t* query = NULL; long lIndex = 0; char szBuf[260] = {'\0'}; mongoc_init(); client = mongoc_client_new("mongodb://localhost:27017/?appname=find-example"); collection = mongoc_client_get_collection(client, "db_ls", "coll_ls"); query = bson_new(); cursor = mongoc_collection_find_with_opts(collection, query, NULL, NULL); while (mongoc_cursor_next(cursor, &doc)) { sprintf(szBuf, "%ld\0", lIndex++) ; ShowDocument(szBuf, (bson_t*)doc); } bson_destroy(query); mongoc_cursor_destroy(cursor); mongoc_collection_destroy(collection); mongoc_client_destroy(client); mongoc_cleanup(); return 0;}int testcase_mongoc_example_document_add(int argc, char* argv[]){ bool bRc = false; TAG_PERSON_INFO person; bson_t* document = NULL; mongoc_client_t* client = NULL; mongoc_database_t* database = NULL; mongoc_collection_t* collection = NULL; bson_error_t error; bool retval = false; do { memset(&person, 0, sizeof(person)); // ! 参数2是设置的值, 参数3是size字节数 mongoc_init(); client = mongoc_client_new("mongodb://localhost:27017"); mongoc_client_set_appname(client, "CRUD-Add"); database = mongoc_client_get_database(client, "db_ls"); collection = mongoc_client_get_collection(client, "db_ls", "coll_ls"); // cmd : ping retval = DbOptExec_command_simple(client, "admin", "ping", &error); if (!retval) { ShowErrMsg("ping", &error); break; } // set time ok // [person->birthday] time is 1973-04-01 13:30:50 setTime(&person.birthday, 1973, 4, 1, 13, 30, 50); person.name.first = "lostspeed5"; person.name.last = "cn"; person.skillAry[0] = "C"; person.skillAry[1] = "C++"; person.skillAry[2] = "MASM"; person.skillAry[3] = "RE"; person.skillAry[4] = NULL; // ! person.degreeAry[0].degree = "graduates"; person.degreeAry[0].school = "zhongnian"; person.degreeAry[1].degree = "graduates"; person.degreeAry[1].school = "cr"; person.degreeAry[2].degree = NULL; // ! person.degreeAry[2].school = NULL; // ! document = bson_new(); fill_TAG_PERSON_INFO(document, &person); // use document ... ShowDocument("person", document); /** // 这个ok [person] { "name" : { "first" : "lostspeed", "last" : "cn" }, "birthday" : { "$date" : 1404690916000 } } // 这个ok [person] { "name" : { "first" : "lostspeed", "last" : "cn" }, "birthday" : { "$date" : -1211776988000 }, "skill" : [ "C", "C++", "MASM", "RE" ] } // ok [person] { "name" : { "first" : "lostspeed", "last" : "cn" }, "birthday" : { "$date" : 2234350468000 }, "skill" : [ "C", "C++", "MASM", "RE" ], "degrees" : [ { "school" : "zhongnian", "degree" : "graduates" }, { "school" : "cr", "degree" : "graduates" } ] } // 下面这个格式有问题 // 虽然从json内容看不出来, 但是报错原因为degrees下的复合数据要加标号 // 数组的数据必须加数组下标 [person] { "name" : { "first" : "lostspeed", "last" : "cn" }, "birthday" : { "$date" : 105087610000 }, "skill" : [ "C", "C++", "MASM", "RE" ], "degrees" : [ { "school" : "zhongnian", "degree" : "graduates" }, { "school" : "cr", "degree" : "graduates" } ] } */ bRc = DbOptAddDocument(collection, document, &error); if (bRc) { printf("CURD-add ok\n"); } else { ShowErrMsg("CURD-add", &error); } } while (0); if (NULL != document) { bson_destroy(document); } if (NULL != collection) { mongoc_collection_destroy(collection); } if (NULL != database) { mongoc_database_destroy(database); } if (NULL != client) { mongoc_client_destroy(client); } return 0;}int testcase_mongoc_example_command_simple(int argc, char* argv[]){ mongoc_client_t* client = NULL; mongoc_database_t* database = NULL; mongoc_collection_t* collection = NULL; bson_t* insert = NULL; bson_error_t error; bool retval = false; mongoc_init(); client = mongoc_client_new("mongodb://localhost:27017"); /* * Register the application name so we can track it in the profile logs * on the server. This can also be done from the URI (see other examples). */ mongoc_client_set_appname(client, "connect-example"); database = mongoc_client_get_database(client, "db_name"); collection = mongoc_client_get_collection(client, "db_name", "coll_name"); // cmd : ping retval = DbOptExec_command_simple(client, "admin", "ping", &error); if (!retval) { ShowErrMsg("ping", &error); return EXIT_FAILURE; } /** [ping] { "ok" : 1.0 } */ insert = BCON_NEW("hello", BCON_UTF8("world")); if (!mongoc_collection_insert( collection, MONGOC_INSERT_NONE, insert, NULL, &error)) { ShowErrMsg("mongoc_collection_insert", &error); } // cmd : buildinfo bson_destroy(insert); retval = DbOptExec_command_simple(client, "admin", "buildinfo", &error); if (!retval) { ShowErrMsg("buildinfo", &error); } /** [buildinfo] { "version" : "2.6.10", "gitVersion" : "5901dbfb49d16eaef6f2c2c50fba534d23ac7f6c", "OpenSSLVersion" : "", "sysInfo" : "Linux build18.nj1.10gen.cc 2.6.32-431.3.1.el6.x86_64 #1 SMP Fri Jan 3 21:39:27 UTC 2014 x86_64 BOOST_LIB_VERSION=1_49", "loaderFlags" : "-fPIC -pthread -Wl,-z,now -rdynamic", "compilerFlags" : "-Wnon-virtual-dtor -Woverloaded-virtual -fPIC -fno-strict-aliasing -ggdb -pthread -Wall -Wsign-compare -Wno-unknown-pragmas -Winvalid-pch -pipe -Werror -O3 -Wno-unused-function -Wno-deprecated-declarations -fno-builtin-memcmp", "allocator" : "tcmalloc", "versionArray" : [ 2, 6, 10, 0 ], "javascriptEngine" : "V8", "bits" : 64, "debug" : false, "maxBsonObjectSize" : 16777216, "ok" : 1.0 } */ // cmd : serverStatus retval = DbOptExec_command_simple(client, "admin", "serverStatus", &error); if (!retval) { ShowErrMsg("serverStatus", &error); } /** [serverStatus] { "host" : "debian", "version" : "2.6.10", "process" : "mongod", "pid" : 3243, "uptime" : 21899.0, "uptimeMillis" : 21897854, "uptimeEstimate" : 19920.0, "localTime" : { "$date" : 1491227764737 }, "asserts" : { "regular" : 0, "warning" : 0, "msg" : 0, "user" : 0, "rollovers" : 0 }, "backgroundFlushing" : { "flushes" : 364, "total_ms" : 54, "average_ms" : 0.14835164835164835195, "last_ms" : 0, "last_finished" : { "$date" : 1491227708337 } }, "connections" : { "current" : 1, "available" : 818, "totalCreated" : 9 }, "cursors" : { "note" : "deprecated, use server status metrics", "clientCursors_size" : 0, "totalOpen" : 0, "pinned" : 0, "totalNoTimeout" : 0, "timedOut" : 0 }, "dur" : { "commits" : 29, "journaledMB" : 0.0, "writeToDataFilesMB" : 0.0, "compression" : 0.0, "commitsInWriteLock" : 0, "earlyCommits" : 0, "timeMs" : { "dt" : 3044, "prepLogBuffer" : 0, "writeToJournal" : 0, "writeToDataFiles" : 0, "remapPrivateView" : 0 } }, "extra_info" : { "note" : "fields vary by platform", "heap_usage_bytes" : 62725408, "page_faults" : 98 }, "globalLock" : { "totalTime" : 21897856000, "lockTime" : 5334268, "currentQueue" : { "total" : 0, "readers" : 0, "writers" : 0 }, "activeClients" : { "total" : 0, "readers" : 0, "writers" : 0 } }, "indexCounters" : { "accesses" : 19, "hits" : 19, "misses" : 0, "resets" : 0, "missRatio" : 0.0 }, "locks" : { "." : { "timeLockedMicros" : { "R" : 435761, "W" : 5334268 }, "timeAcquiringMicros" : { "R" : 4899977, "W" : 2994540 } }, "admin" : { "timeLockedMicros" : { "r" : 151982, "w" : 0 }, "timeAcquiringMicros" : { "r" : 369253, "w" : 0 } }, "local" : { "timeLockedMicros" : { "r" : 128739, "w" : 83 }, "timeAcquiringMicros" : { "r" : 54838, "w" : 1 } }, "testdb" : { "timeLockedMicros" : { "r" : 2081468, "w" : 130 }, "timeAcquiringMicros" : { "r" : 19698, "w" : 3 } }, "mongodb" : { "timeLockedMicros" : { "r" : 191151, "w" : 128 }, "timeAcquiringMicros" : { "r" : 30413, "w" : 4 } }, "db_name" : { "timeLockedMicros" : { "r" : 375654, "w" : 908 }, "timeAcquiringMicros" : { "r" : 14419, "w" : 40 } }, "Barca" : { "timeLockedMicros" : { "r" : 158307, "w" : 134 }, "timeAcquiringMicros" : { "r" : 19699, "w" : 3 } }, "dbs" : { "timeLockedMicros" : { "r" : 610389, "w" : 224 }, "timeAcquiringMicros" : { "r" : 17663, "w" : 6 } }, "test1" : { "timeLockedMicros" : { "r" : 829203, "w" : 28 }, "timeAcquiringMicros" : { "r" : 15951, "w" : 2 } }, "yekai" : { "timeLockedMicros" : { "r" : 2065973, "w" : 269 }, "timeAcquiringMicros" : { "r" : 61179, "w" : 4 } }, "tutorial" : { "timeLockedMicros" : { "r" : 1491259, "w" : 157 }, "timeAcquiringMicros" : { "r" : 28555, "w" : 3 } } }, "network" : { "bytesIn" : 5730, "bytesOut" : 13310, "numRequests" : 44 }, "opcounters" : { "insert" : 9, "query" : 3641, "update" : 0, "delete" : 0, "getmore" : 0, "command" : 38 }, "opcountersRepl" : { "insert" : 0, "query" : 0, "update" : 0, "delete" : 0, "getmore" : 0, "command" : 0 }, "recordStats" : { "accessesNotInMemory" : 0, "pageFaultExceptionsThrown" : 0, "Barca" : { "accessesNotInMemory" : 0, "pageFaultExceptionsThrown" : 0 }, "admin" : { "accessesNotInMemory" : 0, "pageFaultExceptionsThrown" : 0 }, "db_name" : { "accessesNotInMemory" : 0, "pageFaultExceptionsThrown" : 0 }, "dbs" : { "accessesNotInMemory" : 0, "pageFaultExceptionsThrown" : 0 }, "local" : { "accessesNotInMemory" : 0, "pageFaultExceptionsThrown" : 0 }, "mongodb" : { "accessesNotInMemory" : 0, "pageFaultExceptionsThrown" : 0 }, "test1" : { "accessesNotInMemory" : 0, "pageFaultExceptionsThrown" : 0 }, "testdb" : { "accessesNotInMemory" : 0, "pageFaultExceptionsThrown" : 0 }, "tutorial" : { "accessesNotInMemory" : 0, "pageFaultExceptionsThrown" : 0 }, "yekai" : { "accessesNotInMemory" : 0, "pageFaultExceptionsThrown" : 0 } }, "writeBacksQueued" : false, "mem" : { "bits" : 64, "resident" : 158, "virtual" : 62683, "supported" : true, "mapped" : 31251, "mappedWithJournal" : 62502 }, "metrics" : { "cursor" : { "timedOut" : 0, "open" : { "noTimeout" : 0, "pinned" : 0, "total" : 0 } }, "document" : { "deleted" : 0, "inserted" : 9, "returned" : 0, "updated" : 0 }, "getLastError" : { "wtime" : { "num" : 0, "totalMillis" : 0 }, "wtimeouts" : 0 }, "operation" : { "fastmod" : 0, "idhack" : 0, "scanAndOrder" : 0 }, "queryExecutor" : { "scanned" : 0, "scannedObjects" : 0 }, "record" : { "moves" : 0 }, "repl" : { "apply" : { "batches" : { "num" : 0, "totalMillis" : 0 }, "ops" : 0 }, "buffer" : { "count" : 0, "maxSizeBytes" : 268435456, "sizeBytes" : 0 }, "network" : { "bytes" : 0, "getmores" : { "num" : 0, "totalMillis" : 0 }, "ops" : 0, "readersCreated" : 0 }, "preload" : { "docs" : { "num" : 0, "totalMillis" : 0 }, "indexes" : { "num" : 0, "totalMillis" : 0 } } }, "storage" : { "freelist" : { "search" : { "bucketExhausted" : 0, "requests" : 8, "scanned" : 16 } } }, "ttl" : { "deletedDocuments" : 0, "passes" : 364 } }, "ok" : 1.0 } */ // cmd : ismaster retval = DbOptExec_command_simple(client, "admin", "ismaster", &error); if (!retval) { ShowErrMsg("ismaster", &error); } /** [ismaster] { "ismaster" : true, "maxBsonObjectSize" : 16777216, "maxMessageSizeBytes" : 48000000, "maxWriteBatchSize" : 1000, "localTime" : { "$date" : 1491230240360 }, "maxWireVersion" : 2, "minWireVersion" : 0, "ok" : 1.0 } */ // cmd : getlasterror retval = DbOptExec_command_simple(client, "admin", "getlasterror", &error); if (!retval) { ShowErrMsg("getlasterror", &error); } /** [getlasterror] { "connectionId" : 11, "n" : 0, "syncMillis" : 0, "writtenTo" : null, "err" : null, "ok" : 1.0 } */ // cmd : foo retval = DbOptExec_command_simple(client, "admin", "foo", &error); if (!retval) { ShowErrMsg("foo", &error); } /** [foo] error : no such cmd: foo */ // cmd : empty // 空命令会报错的 // retval = DbOptExec_command_simple(client, "admin", "{}", &error); // // if (!retval) { // ShowErrMsg("{}", &error); // } // cmd : empty retval = DbOptExec_command_simple(client, "admin", "", &error); if (!retval) { ShowErrMsg("", &error); } /** [] error : no such cmd: */ // cmd : db retval = DbOptExec_command_simple(client, "admin", "db", &error); if (!retval) { ShowErrMsg("db", &error); } /** [db] error : no such cmd: db */ /** MongoDB shell version: 2.6.10 connecting to: test > show dbs Barca 0.078GB admin 0.078GB db_name 0.078GB local 0.078GB mongodb 0.078GB test1 0.078GB testdb 0.078GB tutorial 0.078GB yekai 7.950GB > > use test1 switched to db test1 > show collections system.indexes test1 > */ // cmd : "{'drop': '%s'}" retval = DbOptExec_command_simple(client, "admin", "use", "test1", &error); if (!retval) { ShowErrMsg("use test1", &error); } /** [use test1] error : no such cmd: use */ retval = DbOptExec_command_simple(client, "test1", "drop", "test1", &error); if (!retval) { ShowErrMsg("drop test1", &error); } /** [drop] { "ns" : "test1.test1", "nIndexesWas" : 1, "ok" : 1.0 } */ /** mongo console > use test1 switched to db test1 > show collections system.indexes > */ // cmd : getCmdLineOpts retval = DbOptExec_command_simple(client, "admin", "getCmdLineOpts", &error); if (!retval) { ShowErrMsg("getCmdLineOpts", &error); } /** [getCmdLineOpts] { "argv" : [ "\/usr\/local\/mongodb\/bin\/mongod", "--config", "\/usr\/local\/mongodb\/bin\/mongodb.conf" ], "parsed" : { "config" : "\/usr\/local\/mongodb\/bin\/mongodb.conf", "net" : { "http" : { "enabled" : false }, "port" : 27017 }, "processManagement" : { "fork" : true }, "storage" : { "dbPath" : "\/usr\/local\/mongodb\/db" }, "systemLog" : { "destination" : "file", "path" : "\/usr\/local\/mongodb\/logs\/mongodb.log" } }, "ok" : 1.0 } */ mongoc_collection_destroy(collection); mongoc_database_destroy(database); mongoc_client_destroy(client); mongoc_cleanup(); return 0;}
// BusinessLogic.h: interface for the BusinessLogic class.////////////////////////////////////////////////////////////////////////#if !defined(AFX_BUSINESSLOGIC_H__91436BA7_97DD_495E_A750_A141145804E1__INCLUDED_)#define AFX_BUSINESSLOGIC_H__91436BA7_97DD_495E_A750_A141145804E1__INCLUDED_#include#include #include #ifndef BOOLtypedef bool BOOL;#define TRUE 1#define FALSE 0#endif // #ifndef BOOLtypedef struct _tag_name { const char* first; const char* last;} TAG_NAME;typedef struct _tag_degress { const char* school; const char* degree;} TAG_DEGRESS;typedef struct _tag_person_info { TAG_NAME name; struct tm birthday; const char* skillAry[10]; TAG_DEGRESS degreeAry[10];} TAG_PERSON_INFO;void fill_TAG_PERSON_INFO(bson_t* document, TAG_PERSON_INFO* person);#endif // !defined(AFX_BUSINESSLOGIC_H__91436BA7_97DD_495E_A750_A141145804E1__INCLUDED_)
// @file MongoDbEx.h// @brief MongoDB operation#ifndef __MONGODB_EX__#define __MONGODB_EX__#include#include #include #ifndef BOOLtypedef bool BOOL;#define TRUE 1#define FALSE 0#endif // #ifndef BOOL// db managerBOOL DbOptInit();BOOL DbOptUnInit();mongoc_client_t* DbOptOpenConect(const char* pConnectUrl);void DbOptCloseConect(mongoc_client_t*& pDbConnect);mongoc_database_t* DbOptOpenDb(mongoc_client_t* pDbConnect, const char* pDbName);void DbOptCloseDb(mongoc_database_t*& pDb);mongoc_collection_t* DbOptOpenTbl(mongoc_database_t* pDb, const char* pTblName);void DbOptCloseTbl(mongoc_collection_t*& pTbl);bool DbOptExec_command_simple( mongoc_client_t* pClient, const char* pcDbName, const char* pcCommand, bson_error_t* pError);bool DbOptExec_command_simple( mongoc_client_t* pClient, const char* pcDbName, const char* pcCommand, const char* pcValue, bson_error_t* pError);// db's CRUDbool DbOptAddDocument(mongoc_collection_t*& pTbl, bson_t* document, bson_error_t* error);// data operationvoid ShowErrMsg(const char* pTip, bson_error_t* error);void ShowReply(const char* pTip, bson_t* reply);void ShowDocument(const char* pTip, bson_t* document);bson_t* new_formatv_bson(const char* json, ...);char* single_quotes_to_double(const char* str);void setTime(struct tm* ptm, int year, int month, int day, int hour, int min, int sec);void show_tm(const char* pTip, struct tm* ptm);#endif // #ifndef __MONGODB_EX__
// BusinessLogic.cpp: implementation of the BusinessLogic class.////////////////////////////////////////////////////////////////////////#include "BusinessLogic.h"#include "MongoDbEx.h"void fill_TAG_PERSON_INFO(bson_t* document, TAG_PERSON_INFO* person){ int i = 0; int iArySize = 0; bson_t child; bson_t child2; const char* key = NULL; size_t keylen = 0; char buf[32] = { '\0'}; if ((NULL == document) || (NULL == person)) { return; } bson_append_document_begin(document, "name", -1, &child); BSON_APPEND_UTF8(&child, "first", person->name.first); BSON_APPEND_UTF8(&child, "last", person->name.last); bson_append_document_end(document, &child); show_tm("person->birthday", &person->birthday); BSON_APPEND_DATE_TIME(document, "birthday", mktime(&person->birthday) * 1000); // mongoc的例子上都是x1000 bson_append_array_begin(document, "skill", -1, &child); iArySize = sizeof(person->skillAry) / sizeof(char*); for (i = 0; i < iArySize; i++) { if (NULL == person->skillAry[i]) { break; } keylen = bson_uint32_to_string(i + 1, &key, buf, sizeof buf); bson_append_utf8(&child, key, (int) keylen, person->skillAry[i], -1); } bson_append_array_end(document, &child); bson_append_array_begin(document, "degrees", -1, &child); iArySize = sizeof(person->degreeAry) / sizeof(TAG_DEGRESS); for (i = 0; i < iArySize; i++) { if ((NULL == person->degreeAry[i].degree) || (NULL == person->degreeAry[i].school)) { break; } // 这里必须加标号key, 区分子数据, 否则报错: document to insert contains invalid keys // error: // bson_append_document_begin(&child, "", -1, &child2); // 数组的数据必须加数组下标 keylen = bson_uint32_to_string (i, &key, buf, sizeof buf); bson_append_document_begin(&child, key, keylen, &child2); bson_append_utf8(&child2, "school", -1, person->degreeAry[i].school, -1); bson_append_utf8(&child2, "degree", -1, person->degreeAry[i].degree, -1); bson_append_document_end(&child, &child2); } bson_append_array_end(document, &child);}
// @file MongoDbEx.cpp// @brief ...#include "MongoDbEx.h"BOOL DbOptInit(){ mongoc_init();}BOOL DbOptUnInit(){ mongoc_cleanup();}mongoc_client_t* DbOptOpenConect(const char* pConnectUrl){ mongoc_client_t* pDbClient = NULL; if (NULL != pConnectUrl) { pDbClient = mongoc_client_new(pConnectUrl); } return pDbClient;}void DbOptCloseConect(mongoc_client_t*& pDbConnect){ if (NULL != pDbConnect) { mongoc_client_destroy(pDbConnect); pDbConnect = NULL; }}mongoc_database_t* DbOptOpenDb(mongoc_client_t* pDbConnect, const char* pDbName){ mongoc_database_t* pDb = NULL; if (NULL != pDbConnect) { pDb = mongoc_client_get_database(pDbConnect, pDbName); } return pDb;}void DbOptCloseDb(mongoc_database_t*& pDb){ if (NULL != pDb) { mongoc_database_destroy(pDb); pDb = NULL; }}mongoc_collection_t* DbOptOpenTbl(mongoc_database_t* pDb, const char* pTblName){ mongoc_collection_t* pTbl = NULL; pTbl = mongoc_database_get_collection(pDb, pTblName); return pTbl;}void DbOptCloseTbl(mongoc_collection_t*& pTbl){ if (NULL != pTbl) { mongoc_collection_destroy(pTbl); pTbl = NULL; }}bool DbOptExec_command_simple( mongoc_client_t* pClient, const char* pcDbName, const char* pcCommand, bson_error_t* pError){ bool retval = false; bson_t* command = NULL; bson_t reply; do { command = BCON_NEW(pcCommand, BCON_INT32(1)); // mongoc_client_command_simple 作用: 让mongodb执行一些命令, 返回一些结果 retval = mongoc_client_command_simple(pClient, pcDbName, command, NULL, &reply, pError); if (!retval) { break; } else { ShowReply(pcCommand, &reply); } } while (0); bson_destroy(&reply); bson_destroy(command); return retval;}bool DbOptExec_command_simple( mongoc_client_t* pClient, const char* pcDbName, const char* pcCommand, const char* pcValue, bson_error_t* pError){ bool retval = false; bson_t reply; bson_t* doc = NULL; char* sz_cmd = NULL; do { // mongoc_client_command_simple 作用: 让mongodb执行一些命令, 返回一些结果 sz_cmd = bson_strdup_printf("{'%s': '%s'}", pcCommand, pcValue); doc = new_formatv_bson("%s", sz_cmd); retval = mongoc_client_command_simple(pClient, pcDbName, doc, NULL, &reply, pError); bson_free(sz_cmd); if (!retval) { break; } else { ShowReply(pcCommand, &reply); } } while (0); bson_destroy(&reply); bson_destroy(doc); return retval;}bool DbOptAddDocument(mongoc_collection_t*& pTbl, bson_t* document, bson_error_t* error){ bool bRc = false; do { if ((NULL == pTbl) || (NULL == document) || (NULL == error)) { break; } bRc = mongoc_collection_insert(pTbl, MONGOC_INSERT_NONE, document, NULL, error); } while (0); return bRc;}void ShowErrMsg(const char* pTip, bson_error_t* error){ if (NULL != error) { fprintf(stderr, "[%s] error : %s\n\n", (NULL != pTip) ? pTip : "", error->message); }}void ShowReply(const char* pTip, bson_t* reply){ char* str = NULL; if (NULL != reply) { str = bson_as_json(reply, NULL); if (NULL != str) { printf("[%s] %s\n\n", (NULL != pTip) ? pTip : "", str); bson_free(str); } }}void ShowDocument(const char* pTip, bson_t* document){ char* str = NULL; if (NULL != document) { str = bson_as_json(document, NULL); if (NULL != str) { printf("[%s] %s\n\n", (NULL != pTip) ? pTip : "", str); bson_free(str); } }}bson_t* new_formatv_bson(const char* json, ...){ va_list args; bson_error_t error; char* formatted; char* double_quoted; bson_t* doc; if (json) { va_start(args, json); formatted = bson_strdupv_printf(json, args); va_end(args); double_quoted = single_quotes_to_double(formatted); doc = bson_new_from_json((const uint8_t*) double_quoted, -1, &error); if (!doc) { fprintf(stderr, "%s\n", error.message); abort(); } bson_free(formatted); bson_free(double_quoted); } else { doc = bson_new(); } return doc;}char* single_quotes_to_double(const char* str){ char* result = bson_strdup(str); char* p; for (p = result; *p; p++) { if (*p == '\'') { *p = '"'; } } return result;}void show_tm(const char* pTip, struct tm* ptm){ char* pcDispTime = NULL; char szBuf[260] = { '\0'}; if (NULL != ptm) { strftime (szBuf, 260 ,"%Y-%m-%d %H:%M:%S", ptm); printf("[%s] time is %s\n", (NULL != pTip) ? pTip : "", szBuf); }}void setTime(struct tm* ptm, int year, int month, int day, int hour, int min, int sec){ // 将要设置的原始时间, 换成本地时间, 向数据库存的是本地时间 // 到了mongo DB中存的是中国时间(utc+8) // 如果从数据库取回设置的时间后, 要-5才是本地时间(或者用difftime算localtime和gmtime的差,得出utc+x) time_t _time_t1; struct tm* ptmUtc = NULL; struct tm* ptmLocal = NULL; if (NULL != ptm) { // 设置的是 1973-04-01 13:30:50 // 存的时间是本地时间1973-04-01 13:30:50 // mongoc db 存的是 1973-04-01T23:30:50Z, (utc + 5), 说明服务器本地时间是米国时间? // 米国时间utc+5 // 中国时间是utc+8 // 服务器的本地时间是米国时间 memset(ptm, 0, sizeof(struct tm)); // ! 参数2是设置的值, 参数3是size字节数 ptm->tm_year = year - 1900; // base 1900 ptm->tm_mon = month - 1; // base 0 ptm->tm_mday = day; // base 1 ptm->tm_hour = hour; // base 0 ptm->tm_min = min; // base 0 ptm->tm_sec = sec; // base 0 show_tm("org time", ptm); _time_t1 = mktime(ptm); ptmLocal = localtime(&_time_t1); show_tm("local time", ptmLocal); ptmUtc = gmtime(&_time_t1); // mongoc db 存的是 1973-04-01T23:30:50Z show_tm("utc time", ptmUtc); memcpy(ptm, ptmLocal, sizeof(struct tm)); /** [org time] time is 1973-04-01 13:30:50 [local time] time is 1973-04-01 13:30:50 [utc time] time is 1973-04-01 18:30:50 */ }}
转载地址:https://lostspeed.blog.csdn.net/article/details/69129279 如侵犯您的版权,请留言回复原文章的地址,我们会给您删除此文章,给您带来不便请您谅解!
发表评论
最新留言
网站不错 人气很旺了 加油
[***.192.178.218]2024年04月28日 07时07分47秒
关于作者
喝酒易醉,品茶养心,人生如梦,品茶悟道,何以解忧?唯有杜康!
-- 愿君每日到此一游!
推荐文章
tf keras SimpleRNN源码解析
2019-04-30
tf keras Dense源码解析
2019-04-30
tf rnn输入输出的维度和权重的维度
2019-04-30
检验是否服从同一分布
2019-04-30
keras、tf、numpy实现logloss对比
2019-04-30
MyBatisPlus简单入门(SpringBoot)
2019-04-30
攻防世界web进阶PHP2详解
2019-04-30
攻防世界web进阶区web2详解
2019-04-30
xss-labs详解(上)1-10
2019-04-30
xss-labs详解(下)11-20
2019-04-30
攻防世界web进阶区ics-05详解
2019-04-30
攻防世界web进阶区FlatScience详解
2019-04-30
攻防世界web进阶区ics-04详解
2019-04-30
攻防世界web进阶区bug详解
2019-04-30
攻防世界web进阶区ics-07详解
2019-04-30
攻防世界web进阶区unfinish详解
2019-04-30
攻防世界web进阶区i-got-id-200超详解
2019-04-30
sql注入总结学习
2019-04-30
leetcode46 全排列
2019-04-30
leetcode 714 买卖股票的最佳时机含手续费
2019-04-30