commit
6fea1f4340
|
@ -1399,16 +1399,20 @@ int32_t mnodeRetrieveShowSuperTables(SShowObj *pShow, char *data, int32_t rows,
|
||||||
void mnodeDropAllSuperTables(SDbObj *pDropDb) {
|
void mnodeDropAllSuperTables(SDbObj *pDropDb) {
|
||||||
void * pIter= NULL;
|
void * pIter= NULL;
|
||||||
int32_t numOfTables = 0;
|
int32_t numOfTables = 0;
|
||||||
int32_t dbNameLen = strlen(pDropDb->name);
|
|
||||||
SSuperTableObj *pTable = NULL;
|
SSuperTableObj *pTable = NULL;
|
||||||
|
|
||||||
|
char prefix[64] = {0};
|
||||||
|
tstrncpy(prefix, pDropDb->name, 64);
|
||||||
|
strcat(prefix, TS_PATH_DELIMITER);
|
||||||
|
int32_t prefixLen = strlen(prefix);
|
||||||
|
|
||||||
mInfo("db:%s, all super tables will be dropped from sdb", pDropDb->name);
|
mInfo("db:%s, all super tables will be dropped from sdb", pDropDb->name);
|
||||||
|
|
||||||
while (1) {
|
while (1) {
|
||||||
pIter = mnodeGetNextSuperTable(pIter, &pTable);
|
pIter = mnodeGetNextSuperTable(pIter, &pTable);
|
||||||
if (pTable == NULL) break;
|
if (pTable == NULL) break;
|
||||||
|
|
||||||
if (strncmp(pDropDb->name, pTable->info.tableId, dbNameLen) == 0) {
|
if (strncmp(prefix, pTable->info.tableId, prefixLen) == 0) {
|
||||||
SSdbOper oper = {
|
SSdbOper oper = {
|
||||||
.type = SDB_OPER_LOCAL,
|
.type = SDB_OPER_LOCAL,
|
||||||
.table = tsSuperTableSdb,
|
.table = tsSuperTableSdb,
|
||||||
|
|
Loading…
Reference in New Issue