提交 bb404285 编写于 作者: H Hongze Cheng

more

上级 2ab7dc06
set(META_DB_IMPL_LIST "BDB" "SQLITE") set(META_DB_IMPL_LIST "BDB" "SQLITE")
set(META_DB_IMPL "BDB" CACHE STRING "Use BDB as the default META implementation") set(META_DB_IMPL "SQLITE" CACHE STRING "Use BDB as the default META implementation")
set_property(CACHE META_DB_IMPL PROPERTY STRINGS ${META_DB_IMPL_LIST}) set_property(CACHE META_DB_IMPL PROPERTY STRINGS ${META_DB_IMPL_LIST})
if(META_DB_IMPL IN_LIST META_DB_IMPL_LIST) if(META_DB_IMPL IN_LIST META_DB_IMPL_LIST)
......
...@@ -26,7 +26,7 @@ typedef struct SMetaDB SMetaDB; ...@@ -26,7 +26,7 @@ typedef struct SMetaDB SMetaDB;
int metaOpenDB(SMeta *pMeta); int metaOpenDB(SMeta *pMeta);
void metaCloseDB(SMeta *pMeta); void metaCloseDB(SMeta *pMeta);
int metaSaveTableToDB(SMeta *pMeta, const STbCfg *pTbOptions); int metaSaveTableToDB(SMeta *pMeta, const STbCfg *pTbCfg);
int metaRemoveTableFromDb(SMeta *pMeta, tb_uid_t uid); int metaRemoveTableFromDb(SMeta *pMeta, tb_uid_t uid);
#ifdef __cplusplus #ifdef __cplusplus
......
...@@ -39,6 +39,8 @@ int metaOpenDB(SMeta *pMeta) { ...@@ -39,6 +39,8 @@ int metaOpenDB(SMeta *pMeta) {
return -1; return -1;
} }
// pMeta->pDB->pEvn->set_cachesize(pMeta->pDB->pEvn, )
ret = pMeta->pDB->pEvn->open(pMeta->pDB->pEvn, pMeta->path, DB_CREATE | DB_INIT_MPOOL, 0); ret = pMeta->pDB->pEvn->open(pMeta->pDB->pEvn, pMeta->path, DB_CREATE | DB_INIT_MPOOL, 0);
if (ret != 0) { if (ret != 0) {
// TODO: handle error // TODO: handle error
...@@ -106,7 +108,7 @@ void metaCloseDB(SMeta *pMeta) { ...@@ -106,7 +108,7 @@ void metaCloseDB(SMeta *pMeta) {
} }
} }
int metaSaveTableToDB(SMeta *pMeta, const STbCfg *pTbOptions) { int metaSaveTableToDB(SMeta *pMeta, const STbCfg *pTbCfg) {
// TODO // TODO
return 0; return 0;
} }
......
...@@ -95,13 +95,15 @@ void metaCloseDB(SMeta *pMeta) { ...@@ -95,13 +95,15 @@ void metaCloseDB(SMeta *pMeta) {
// TODO // TODO
} }
int metaSaveTableToDB(SMeta *pMeta, const STbCfg *pTbOptions) { int metaSaveTableToDB(SMeta *pMeta, const STbCfg *pTbCfg) {
char sql[256]; char sql[256];
char *err = NULL; char * err = NULL;
int rc; int rc;
tb_uid_t uid;
switch (pTbOptions->type) { switch (pTbCfg->type) {
case META_SUPER_TABLE: case META_SUPER_TABLE:
uid = pTbCfg->stbCfg.suid;
// sprintf(sql, "INSERT INTO tb VALUES (\'%s\', %" PRIu64 // sprintf(sql, "INSERT INTO tb VALUES (\'%s\', %" PRIu64
// ");" // ");"
// "INSERT INTO stb VALUES (%" PRIu64 // "INSERT INTO stb VALUES (%" PRIu64
...@@ -119,15 +121,19 @@ int metaSaveTableToDB(SMeta *pMeta, const STbCfg *pTbOptions) { ...@@ -119,15 +121,19 @@ int metaSaveTableToDB(SMeta *pMeta, const STbCfg *pTbOptions) {
} }
break; break;
case META_NORMAL_TABLE: case META_NORMAL_TABLE:
// sprintf(sql, "INSERT INTO tb VALUES (\'%s\', %" PRIu64 uid = metaGenerateUid(pMeta);
// ");" // sprintf(sql,
// "INSERT INTO ntb VALUES (%" PRIu64 ", \'%s\', );"); // "INSERT INTO tb VALUES (\'%s\', %" PRIu64
// ");"
// "INSERT INTO ntb VALUES (%" PRIu64 ", \'%s\', );",
// pTbCfg->name, uid, uid, pTbCfg->name, );
rc = sqlite3_exec(pMeta->pDB->pDB, sql, NULL, NULL, &err); rc = sqlite3_exec(pMeta->pDB->pDB, sql, NULL, NULL, &err);
if (rc != SQLITE_OK) { if (rc != SQLITE_OK) {
printf("failed to create normal table since %s\n", err); printf("failed to create normal table since %s\n", err);
} }
break; break;
case META_CHILD_TABLE: case META_CHILD_TABLE:
uid = metaGenerateUid(pMeta);
// sprintf(sql, "INSERT INTO tb VALUES (\'%s\', %" PRIu64 // sprintf(sql, "INSERT INTO tb VALUES (\'%s\', %" PRIu64
// ");" // ");"
// "INSERT INTO stb_%" PRIu64 " VALUES (%" PRIu64 ", \'%s\', );"); // "INSERT INTO stb_%" PRIu64 " VALUES (%" PRIu64 ", \'%s\', );");
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册