zhangsheng/WLG
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

modify table exist

Browse Source
This commit is contained in:
zhangsheng 2024-11-21 15:11:03 +08:00
parent aec0bdb13b
commit ef4dd93863
1 changed files with 8 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
uart/uart.cpp
View File

@ -637,18 +637,20 @@ void Uart::DealDataNodeName(const char *pData) {
data_publish(strData.c_str(), GlobalConfig::Topic_G.mPubConfig.c_str());
char szTableName[50] = {0x00};
char sql_table_exist[50] = {0};
sprintf(szTableName, "t_data_%s", MeasurementID);
sprintf(sql_table_exist,"select count(*) from sqlite_master where type='table' and name = '%s';",szTableName);
int ret = sqlite_db_ctrl::instance().ExeSql(sql_table_exist);
memset(whereCon,0,sizeof(whereCon));
sprintf(whereCon,"type='table' and name = '%s'",szTableName);
int ret = sqlite_db_ctrl::instance().GetTableRows("sqlite_master",whereCon);
zlog_info(zct, "ret = %d", ret);
if (ret == 0){
sqlite_db_ctrl::instance().Createtable(szTableName);
}
memset(sql_table_exist, 0x00, sizeof(sql_table_exist));
memset(szTableName, 0x00, sizeof(szTableName));
sprintf(szTableName, "t_dataStatic_%s", MeasurementID);
sprintf(sql_table_exist,"select count(*) from sqlite_master where type='table' and name = '%s';",szTableName);
ret = sqlite_db_ctrl::instance().ExeSql(sql_table_exist);
memset(whereCon,0,sizeof(whereCon));
sprintf(whereCon,"type='table' and name = '%s'",szTableName);
ret = sqlite_db_ctrl::instance().GetTableRows("sqlite_master",whereCon);
zlog_info(zct, "ret = %d", ret);
if (ret == 0){
sqlite_db_ctrl::instance().CreatedataStatictable(szTableName);
}