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

more TDB

This commit is contained in:
Hongze Cheng 2022-03-01 03:46:40 +00:00
parent 5fdfb80855
commit afe0f1b6e0
4 changed files with 22 additions and 5 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

@ -69,6 +69,11 @@ int tdbDbClose(STDb *pDb) {
return 0; return 0;
} }
int tdbDbDrop(STDb *pDb) {
// TODO
return 0;
}
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) {
// TODO // TODO
return 0; return 0;

10
source/libs/tdb/src/db/tdbPFile.c
View File

@ -31,10 +31,16 @@ struct SPFile {
u8 inTran; u8 inTran;
}; };
typedef struct { typedef struct __attribute__((__packed__)) {
/* TODO */ u8 hdrString[16];
u16 pageSize;
SPgno freePage;
u32 nFreePages;
u8 reserved[102];
} SFileHdr; } SFileHdr;
TDB_STATIC_ASSERT(sizeof(SFileHdr) == 128, "Size of file header is not correct");
static int tdbPFileReadPage(SPFile *pFile, SPage *pPage); static int tdbPFileReadPage(SPFile *pFile, SPage *pPage);
int tdbPFileOpen(SPCache *pCache, const char *fileName, SPFile **ppFile) { int tdbPFileOpen(SPCache *pCache, const char *fileName, SPFile **ppFile) {

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

@ -24,6 +24,7 @@ typedef struct STDb STDb;
int tdbDbOpen(const char *fname, int keyLen, int valLen, FKeyComparator keyCmprFn, STEnv *pEnv, STDb **ppDb); int tdbDbOpen(const char *fname, int keyLen, int valLen, FKeyComparator keyCmprFn, STEnv *pEnv, STDb **ppDb);
int tdbDbClose(STDb *pDb); int tdbDbClose(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);
#ifdef __cplusplus #ifdef __cplusplus

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

@ -15,9 +15,14 @@ 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 // // Insert some data
ret = tdbDbInsert(pDb, "1", 1, "world", 5); // ret = tdbDbInsert(pDb, "1", 1, "world", 5);
GTEST_ASSERT_EQ(ret, 0); // GTEST_ASSERT_EQ(ret, 0);
ret = tdbDbDrop(pDb);
if (pDb == NULL) {
return -1;
}
// Close a database // Close a database
tdbDbClose(pDb); tdbDbClose(pDb);