xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

start the query

This commit is contained in:
Hongze Cheng 2022-03-23 10:30:52 +00:00
parent b633a96bed
commit 2aa6d7e384
3 changed files with 33 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
source/libs/tdb/src/db/tdbDb.c
View File

@ -85,5 +85,10 @@ int tdbDbInsert(STDb *pDb, const void *pKey, int keyLen, const void *pVal, int v
return -1; return -1;
} }
return 0;
}
int tdbDbGet(STDb *pDb, const void *pKey, int kLen, void *pVal, int *vLen) {
// TODO
return 0; return 0;
} }

1
source/libs/tdb/src/inc/tdbDb.h
View File

@ -26,6 +26,7 @@ int tdbDbOpen(const char *fname, int keyLen, int valLen, FKeyComparator keyCmprF
int tdbDbClose(STDb *pDb); int tdbDbClose(STDb *pDb);
int tdbDbDrop(STDb *pDb); int tdbDbDrop(STDb *pDb);
int tdbDbInsert(STDb *pDb, const void *pKey, int keyLen, const void *pVal, int valLen); int tdbDbInsert(STDb *pDb, const void *pKey, int keyLen, const void *pVal, int valLen);
int tdbDbGet(STDb *pDb, const void *pKey, int kLen, void *pVal, int *vLen);
#ifdef __cplusplus #ifdef __cplusplus
} }

35
source/libs/tdb/test/tdbTest.cpp
View File

@ -6,6 +6,7 @@ TEST(tdb_test, simple_test) {
int ret; int ret;
STEnv *pEnv; STEnv *pEnv;
STDb *pDb; STDb *pDb;
int nData = 1000;
// Open Env // Open Env
ret = tdbEnvOpen("tdb", 1024, 256, &pEnv); ret = tdbEnvOpen("tdb", 1024, 256, &pEnv);
@ -15,15 +16,33 @@ TEST(tdb_test, simple_test) {
ret = tdbDbOpen("db.db", TDB_VARIANT_LEN, TDB_VARIANT_LEN, NULL, pEnv, &pDb); ret = tdbDbOpen("db.db", TDB_VARIANT_LEN, TDB_VARIANT_LEN, NULL, pEnv, &pDb);
GTEST_ASSERT_EQ(ret, 0); GTEST_ASSERT_EQ(ret, 0);
{ // Insert some data {
char key[64]; char key[64];
char val[64]; char val[64];
void *pVal;
int vLen;
for (int i = 1; i <= 1000; i++) { { // Insert some data
sprintf(key, "key%d", i);
sprintf(val, "value%d", i); for (int i = 1; i <= nData; i++) {
ret = tdbDbInsert(pDb, key, strlen(key), val, strlen(val)); sprintf(key, "key%d", i);
GTEST_ASSERT_EQ(ret, 0); sprintf(val, "value%d", i);
ret = tdbDbInsert(pDb, key, strlen(key), val, strlen(val));
GTEST_ASSERT_EQ(ret, 0);
}
}
{ // Query the data
for (int i = 1; i <= nData; i++) {
sprintf(key, "key%d", i);
sprintf(val, "value%d", i);
ret = tdbDbGet(pDb, key, strlen(key), pVal, &vLen);
GTEST_ASSERT_EQ(ret, 0);
GTEST_ASSERT_EQ(vLen, strlen(val));
GTEST_ASSERT_EQ(memcmp(val, pVal, vLen), 0);
}
} }
} }