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

more progress

This commit is contained in:
Hongze Cheng 2021-10-12 15:23:36 +08:00
parent 87dcc7fd92
commit 8287a34ccb
2 changed files with 7 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
source/server/vnode/meta/src/meta.c
View File

@ -145,19 +145,20 @@ int metaCreateTable(SMeta *pMeta, STableOpts *pTableOpts) {
taosHashPut(pMeta->pTableObjHash, &(pTableObj->pTable->uid), sizeof(tb_uid_t), &pTableObj, sizeof(pTableObj)); taosHashPut(pMeta->pTableObjHash, &(pTableObj->pTable->uid), sizeof(tb_uid_t), &pTableObj, sizeof(pTableObj));
wopt = rocksdb_writeoptions_create(); wopt = rocksdb_writeoptions_create();
rocksdb_writeoptions_disable_WAL(wopt, 1);
// Add to tbname db // Add to tbname db
rocksdb_put(pMeta->tbnameDb, wopt, pTableOpts->name, strlen(pTableOpts->name), &pTableObj->pTable->uid, rocksdb_put(pMeta->tbnameDb, wopt, pTableOpts->name, strlen(pTableOpts->name), &pTableObj->pTable->uid,
sizeof(tb_uid_t), &err); sizeof(tb_uid_t), &err);
// Add to schema db // Add to schema db
char id[12]; char id[12];
char buf[256]; char buf[256];
void *pBuf = buf; void *pBuf = buf;
*(tb_uid_t *)id = pTableObj->pTable->uid; *(tb_uid_t *)id = pTableObj->pTable->uid;
*(int32_t *)(id + sizeof(tb_uid_t)) = schemaVersion(pTableOpts->pSchema); *(int32_t *)(id + sizeof(tb_uid_t)) = schemaVersion(pTableOpts->pSchema);
int size = tdEncodeSchema(&pBuf, pTableOpts->pSchema); int size = tdEncodeSchema(&pBuf, pTableOpts->pSchema);
rocksdb_put(pMeta->schemaDb, wopt, id, 12, buf, size, &err); rocksdb_put(pMeta->schemaDb, wopt, id, 12, buf, size, &err);
rocksdb_writeoptions_destroy(wopt); rocksdb_writeoptions_destroy(wopt);

6
source/server/vnode/meta/test/metaTests.cpp
View File

@ -31,7 +31,7 @@ TEST(MetaTest, meta_open_test) {
metaClose(meta); metaClose(meta);
std::cout << "Meta is closed!" << std::endl; std::cout << "Meta is closed!" << std::endl;
// // Destroy Meta // Destroy Meta
// metaDestroy("meta"); metaDestroy("meta");
// std::cout << "Meta is destroyed!" << std::endl; std::cout << "Meta is destroyed!" << std::endl;
} }