This commit is contained in:
Hongze Cheng 2024-04-29 13:43:31 +08:00
parent 175d50594a
commit 577c2a69f2
1 changed files with 39 additions and 0 deletions

View File

@ -479,6 +479,45 @@ TEST(tdb_test, DISABLED_simple_upsert1) {
tdbClose(pEnv);
}
TEST(tdb_test, simple_upsert2) {
int ret;
TDB *pEnv;
TTB *pDb;
int nData = 10000;
const char *key = "key";
int32_t dataSize = 256 * 1024;
void *data = taosMemoryMalloc(dataSize);
void *pData = NULL;
SPoolMem *pPool;
TXN *txn;
taosRemoveDir("tdb");
memset(data, 'a', dataSize);
// open env
ret = tdbOpen("tdb", 4096, 64, &pEnv, 0, 0, 0);
GTEST_ASSERT_EQ(ret, 0);
// open database
ret = tdbTbOpen("db.db", -1, -1, NULL, pEnv, &pDb, 0);
GTEST_ASSERT_EQ(ret, 0);
pPool = openPool();
for (int iData = 0; iData < nData; iData++) {
tdbBegin(pEnv, &txn, poolMalloc, poolFree, pPool, TDB_TXN_WRITE | TDB_TXN_READ_UNCOMMITTED);
ret = tdbTbUpsert(pDb, key, strlen(key), data, dataSize, txn);
GTEST_ASSERT_EQ(ret, 0);
tdbCommit(pEnv, txn);
tdbPostCommit(pEnv, txn);
}
tdbTbClose(pDb);
tdbClose(pEnv);
}
TEST(tdb_test, multi_thread_query) {
int ret;
TDB *pEnv;