c 语言驱动访问mongodb 一些问题

xpston008

c驱动  mongo-c-driver-1.4.2（功能：一个线程查询数据后更新一个状态为处理状态
一个线程将处理结果后一些状态更新到这个表
数据量很大，所以分开两个线程。
）

1. BOOL RSmppMongoDb::_db_res_query()
   
2. {
   
3.    const bson_t *doc;
   
4.    bson_error_t error;
   
5. 
   
6.    const char *collection_name = "cac_sms_sent_pool";
   
7.    bson_t *query;
   
8.    char *str;
   
9.    mongoc_collection_t *collection;
   
10.    mongoc_cursor_t *cursor;
    
11. 
    
12. 
    
13.    query = bson_new ();  
    
14.    BSON_APPEND_UTF8 (query, "apply_state", "0");
    
15.    collection = mongoc_client_get_collection (m_pClient, "cac", collection_name);
    
16.    cursor     = mongoc_collection_find (collection, MONGOC_QUERY_NONE, 0, 0, 0, \
    
17.                                         query, NULL,/* Fields, NULL for all. */ NULL); /* Read Prefs, NULL for default */
    
18.    while (mongoc_cursor_next (cursor, &doc))
    
19.    {
    
20.        str = bson_as_json (doc, NULL);
    
21.        fprintf (stdout, "%s\n", str);
    
22.        bson_free (str);
    
23.    }
    
24. 
    
25.    if (mongoc_cursor_error (cursor, &error)) {
    
26.        fprintf (stderr, "Cursor Failure: %s\n", error.message);
    
27.        return EXIT_FAILURE;
    
28.    }
    
29. 
    
30.    bson_destroy (query);
    
31.    mongoc_cursor_destroy (cursor);
    
32.    mongoc_collection_destroy (collection);
    
33. }

复制代码

1.  这里面有哪些是非线程安全的函数。 是不是所有的操作都需要加锁，保证线程安全。2. 如此复杂的语句在c 里面该如何写 ，下面是mysql的语句。

1. "UPDATE tb_test  set apply_time=str_to_date('%s','%s') , \
   
2.                       apply_state=CASE WHEN apply_state='-1' THEN '-1' ELSE '%d' END , \
   
3.                       fail_apply_reason=concat(IFNULL(fail_apply_reason,''),'%s')    , \
   
4.                       return_message_id =concat(IFNULL(return_message_id,''),'%s ')    \
   
5.                       WHERE message_id='%s' ",iter->apply_time,"%Y%m%d%H%i%s",         \
   
6.                 iter->last_appy_state,iter->fail_reason,iter->return_message_id,iter->rec_id.c_str());

复制代码

大神们帮忙回复。