LevelDB C迭代器

Question

我需要在c語言中遍歷leveldb數據庫 - https://github.com/google/leveldb/blob/master/include/leveldb/c.h。一切正常，除了iterating.The結果去與一些二進制噪聲數據：

key: value1 
key: value2 
key#&^$&*# value 
one1(*@(# value1 
two2%*@(value2 

隨着& $ *＃等符號我發現二進制輸出，計算器不允許把這裏二進制輸出。

代碼：

#include <leveldb/c.h> 
#include <stdio.h> 

int main() { 
    leveldb_t *db; 
    leveldb_options_t *options; 
    leveldb_readoptions_t *roptions; 
    leveldb_writeoptions_t *woptions; 
    char *err = NULL; 
    char *read; 
    size_t read_len; 

    /******************************************/ 
    /* OPEN */ 

    options = leveldb_options_create(); 
    leveldb_options_set_create_if_missing(options, 1); 
    db = leveldb_open(options, "testdb", &err); 

    if (err != NULL) { 
     fprintf(stderr, "Open fail.\n"); 
     return(1); 
    } 

    /* reset error var */ 
    leveldb_free(err); err = NULL; 

    /******************************************/ 
    /* WRITE */ 

    woptions = leveldb_writeoptions_create(); 
    leveldb_put(db, woptions, "one", 3, "value1", 6, &err); 

    if (err != NULL) { 
     fprintf(stderr, "Write fail.\n"); 
     return(1); 
    } 

    leveldb_free(err); err = NULL; 

    /******************************************/ 
    /* WRITE 2 */ 

    woptions = leveldb_writeoptions_create(); 
    leveldb_put(db, woptions, "two", 3, "value2", 6, &err); 

    if (err != NULL) { 
     fprintf(stderr, "Write fail.\n"); 
     return(1); 
    } 

    leveldb_free(err); err = NULL; 

    /******************************************/ 
    /* READ */ 

    roptions = leveldb_readoptions_create(); 
    read = leveldb_get(db, roptions, "one", 3, &read_len, &err); 

    if (err != NULL) { 
     fprintf(stderr, "Read fail.\n"); 
     return(1); 
    } 

    printf("key: %s\n", read); 

    leveldb_free(err); err = NULL; 

    /******************************************/ 
    /* READ 2 */ 

    roptions = leveldb_readoptions_create(); 
    read = leveldb_get(db, roptions, "two", 3, &read_len, &err); 

    if (err != NULL) { 
     fprintf(stderr, "Read fail.\n"); 
     return(1); 
    } 

    printf("key: %s\n", read); 

    leveldb_free(err); err = NULL; 

    /******************************************/ 
    /* ITERATE */ 

    roptions = leveldb_readoptions_create(); 
    leveldb_iterator_t *iter = leveldb_create_iterator(db, roptions); 

    for (leveldb_iter_seek_to_first(iter); leveldb_iter_valid(iter); leveldb_iter_next(iter)) 
    { 
     size_t key_len, value_len; 
     const char *key_ptr = leveldb_iter_key(iter, &key_len); 
     const char *value_ptr = leveldb_iter_value(iter, &value_len); 

     /* Prints some binary noise with the data */ 
     printf("%s %s\n", key_ptr, value_ptr); 
    } 
    leveldb_iter_destroy(iter); 
    leveldb_free(err); err = NULL; 

    /******************************************/ 
    /* CLOSE */ 

    leveldb_close(db); 

    return(0); 
} 

如何通過性LevelDB迭代正確使用C？

Answer 1

看來由leveldb_iter_key和leveldb_iter_value返回的值不正確的以NULL結尾的字符串。

所以，骯髒的解決方案是使用

printf("%.*s %.*s\n", (int) key_len, key_ptr, (int) value_len, value_ptr); 

代替

printf("%s %s\n", key_ptr, value_ptr); 

然而，國際海事組織，最好根據自己的長度這些值複製，然後使用它們。

正如你可以看到https://github.com/google/leveldb/blob/master/db/c.cc#L197創建leveldb_get適當長度（Slice(key, keylen)上L205）的切片和返回鍵（CopyString上L208）的複製。

附加：

我檢查與您的Valgrind的代碼和有與選項的一些內存泄漏。您應該手動釋放它們（例如leveldb_writeoptions_destroy用於woptions）。 leveldb_get結果（read）也應該被釋放。

示例代碼：

// allocate new strings 
char * key = (char *) malloc(key_len + 1); 
char * value = (char *) malloc(value_len + 1); 

// copy string content and ensure that string is null-terminated 
memcpy(key, key_ptr, key_len); 
key[key_len] = 0; 
memcpy(value, value_ptr, value_len); 
value[value_len] = 0; 

// print 
printf("%s %s\n", key, value); 

// free 
free(key); 
free(value);