LMDB veritabanı atomik alınıyor ve C

Question

adresinde yer almalıyım. Anahtarın LMDB veri tabanından alınması gerekiyor ve bu tuşa bağlı olarak bu tuşun değerine bazı ek veriler koyulmalı ve bu tuşun diğer kullanıcılar için bu tuşa basılması gerekli değildir. operasyonlar.

kullandığım kütüphane - github.com/LMDB/lmdb/tree/mdb.master/libraries/liblmdb ve lmdb.h dosyası - github.com/LMDB/lmdb/blob/mdb.master/libraries/liblmdb/lmdb.h

nasıl LMDB mümkündür? Her şey oldukça iyi çalışıyor ama nasıl olsun atomik işlem yapmak

#include <stdio.h> 
#include <stdlib.h> 
#include <string.h> 

#include "lmdb.h" 


#define BUF_SIZE 1024 
#define CACHE_SIZE 1UL * 1024UL * 1024UL * 1024UL 

#define E(expr) CHECK((rc = (expr)) == MDB_SUCCESS, #expr) 
#define CHECK(test, msg) ((test) ? (void)0 : ((void)fprintf(stderr, \ 
    "%s:%d: %s: %s\n", __FILE__, __LINE__, msg, mdb_strerror(rc)), abort())) 

/* Must create somedb folder first */ 
#define DBDIR "./somedb" 


/* Put the key to db */ 
int putdb(char *, char *); 

/* Put and get the key from db */ 
int getandputdb(char *, char *); 

/* Get the key from db */ 
int getdb(char *); 


int main(int argc, char * argv[]) 
{ 
    putdb("key", "value"); 
    getdb("key"); 

    /* Must to be atomic */ 
    getandputdb("KeyToGet", "ValueToBePutAfterGet"); 

    return 0; 
} 

/* Put to db */ 
int putdb(char *keyvalue, char *value) { 

    int rc; 
    MDB_env *env; 
    MDB_dbi dbi; 
    MDB_txn *txn; 
    MDB_val key, data, rdata; 
    MDB_cursor *cursor; 
    char sval[32]; 

    //printf("put %s %s\n",keyvalue, value); 

    E(mdb_env_create(&env)); 

    /* Set the cache size */ 
    E(mdb_env_set_mapsize(env, CACHE_SIZE)); 
    E(mdb_env_open(env, DBDIR, 0, 0664)); 

    /* Put some data */ 
    E(mdb_txn_begin(env, NULL, 0, &txn)); 
    E(mdb_dbi_open(txn, NULL, 0, &dbi)); 

    key.mv_data = keyvalue; 
    key.mv_size = strlen(keyvalue); 
    data.mv_data = value; 
    data.mv_size = strlen(value); 

    E(mdb_put(txn, dbi, &key, &data, 0)); 

    E(mdb_txn_commit(txn)); 

    mdb_dbi_close(env, dbi); 
    mdb_env_close(env); 

    return 0; 
} 

/* Get from lmdb */ 
int getdb(char *thekey) { 

    int rc; 
    MDB_env *env; 
    MDB_dbi dbi; 
    MDB_txn *txn; 
    MDB_val key, data, rdata; 
    MDB_cursor *cursor; 

    //printf("get %s\n", thekey); 

    E(mdb_env_create(&env)); 

    /* Set the cache size */ 
    E(mdb_env_set_mapsize(env, CACHE_SIZE)); 
    E(mdb_env_open(env, DBDIR, 0, 0664)); 

    /* Get some data */ 
    E(mdb_txn_begin(env, NULL, 0, &txn)); 
    E(mdb_dbi_open(txn, NULL, 0, &dbi)); 

    key.mv_data = thekey; 
    key.mv_size = strlen(thekey); 

    rc = mdb_get(txn, dbi, &key, &data); 
    if (!rc) { 
     char *valuen = (char *) malloc(data.mv_size + 1); 
     memcpy(valuen, data.mv_data, data.mv_size); 
     valuen[data.mv_size] = 0; 

     printf("%s %s\n", (char *) key.mv_data, valuen); 

     free(valuen); 
    } else { 
     printf("No such key\n"); 
    } 

    //printf("%s %d, %s %d\n", (char *) key.mv_data, key.mv_size, (char *)data.mv_data, data.mv_size); 

    E(mdb_txn_commit(txn)); 


    mdb_dbi_close(env, dbi); 
    mdb_env_close(env); 

    return 0; 
} 

/* Put and get from db */ 
int getandputdb(char *keyvalue, char *value) { 

    int rc; 
    MDB_env *env; 
    MDB_dbi dbi; 
    MDB_txn *txn; 
    MDB_val key, data, rdata; 
    MDB_cursor *cursor; 
    char sval[32]; 

    /* 
    * Atomic operation, how to do this? 
    * Get the key value and then put the value with some changes back in the atomic operation. 
    */ 



    return 0; 

} 

ardından bazı koşullarını kontrol ve daha sonra koyun: Burada

benim temel kodudur?

Answer 1

• mdb_txn_begin ile bir işlem oluşturun. MDB_RDONLY olarak işaretlemediğinizden emin olun.
• mdb_get
• ile ilgili bir değeri alın. Değeri gereken şekilde değiştirin.
• mdb_txn_commit

Bu hemen hemen herhangi bir veritabanı sisteminde işlemleri çalıştırmak nasıl sahip mdb_put

Finish işlem ile yeni değeri koyun. Ayrıca mtest*.c dosyalarındaki sample code dosyasına bakın.