diff --git a/uart/uart.cpp b/uart/uart.cpp index b23c2dd..65cd705 100644 --- a/uart/uart.cpp +++ b/uart/uart.cpp @@ -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); }