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);