modify:delete table to clear cache supported

Author: xengine-qyt

XEngine_Source/MQCore_DBModule/DBModule_MQData/DBModule_MQData.cpp

@@ -602,6 +602,15 @@ bool CDBModule_MQData::DBModule_MQData_DeleteTable(LPCXSTR lpszQueueName)
 		DBModule_dwErrorCode = DataBase_GetLastError();
 		return false;
 	}
+
+	if (m_bMemoryCache)
+	{
+		XENGINE_DBMESSAGEQUEUE st_MessageQueue = {};
+
+		st_MessageQueue.nQueueSerial = -1;
+		_tcsxcpy(st_MessageQueue.tszQueueName, lpszQueueName);
+		MemoryCache_DBData_DataDelete(&st_MessageQueue);
+	}
 	return true;
 }
 /********************************************************************

XEngine_Source/MQCore_MemoryCache/MemoryCache_DBData/MemoryCache_DBData.cpp

@@ -184,18 +184,35 @@ bool CMemoryCache_DBData::MemoryCache_DBData_DataDelete(XENGINE_DBMESSAGEQUEUE*
 		return false;
 	}
 
-	std::tuple<__int64x, std::string> stl_Key(pSt_DBMessageInfo->nQueueSerial, pSt_DBMessageInfo->tszQueueName);
-
 	st_LockerQuery.lock();
-	auto stl_MapIterator = stl_MapQuery.find(stl_Key);
-	if (stl_MapIterator == stl_MapQuery.end())
+	if (-1 == pSt_DBMessageInfo->nQueueSerial)
 	{
-		MemoryCache_IsErrorOccur = true;
-		MemoryCache_dwErrorCode = ERROR_XENGINE_MQCORE_MEMORYCACHE_DBDATA_NOTFOUND;
-		st_LockerQuery.unlock();
-		return false;
+		for (auto stl_MapIterator = stl_MapQuery.begin(); stl_MapIterator != stl_MapQuery.end(); )
+		{
+			if (std::get<1>((stl_MapIterator->first)) == pSt_DBMessageInfo->tszQueueName)
+			{
+				stl_MapIterator = stl_MapQuery.erase(stl_MapIterator);
+			}
+			else
+			{
+				stl_MapIterator++;
+			}
+		}
+	}
+	else
+	{
+		std::tuple<__int64x, std::string> stl_Key(pSt_DBMessageInfo->nQueueSerial, pSt_DBMessageInfo->tszQueueName);
+
+		auto stl_MapIterator = stl_MapQuery.find(stl_Key);
+		if (stl_MapIterator == stl_MapQuery.end())
+		{
+			MemoryCache_IsErrorOccur = true;
+			MemoryCache_dwErrorCode = ERROR_XENGINE_MQCORE_MEMORYCACHE_DBDATA_NOTFOUND;
+			st_LockerQuery.unlock();
+			return false;
+		}
+		stl_MapQuery.erase(stl_Key);
 	}
-	stl_MapQuery.erase(stl_Key);
 	st_LockerQuery.unlock();
 	return true;
 }

XEngine_Source/MQCore_MemoryCache/MemoryCache_DBData/MemoryCache_DBData.h

@@ -24,7 +24,6 @@ struct TupleHash
 	{
 		return std::apply([](auto&&... args)
 			{
-			// 使用std::hash对每个元素分别哈希并组合结果
 			std::size_t seed = 0;
 			((seed ^= std::hash<std::decay_t<decltype(args)>>()(args) + 0x9e3779b9 + (seed << 6) + (seed >> 2)), ...);
 			return seed;