Skip to content

Commit 38fadad

Browse files
committed
fixed:sometimes get left count value is incorrect
1 parent 480a6b2 commit 38fadad

File tree

4 files changed

+5
-5
lines changed

4 files changed

+5
-5
lines changed

XEngine_Source/MQCore_DBModule/DBModule_Define.h

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -270,7 +270,7 @@ extern "C" bool DBModule_MQData_ShowTable(XCHAR*** pppszTableName, int* pInt_Lis
270270
意思:是否成功
271271
备注:
272272
*********************************************************************/
273-
extern "C" bool DBModule_MQData_GetLeftCount(LPCXSTR lpszTableName, int nSerial, int* pInt_Count);
273+
extern "C" bool DBModule_MQData_GetLeftCount(LPCXSTR lpszTableName, __int64x nSerial, int* pInt_Count);
274274
/*************************************************************************
275275
消息用户导出函数
276276
**************************************************************************/

XEngine_Source/MQCore_DBModule/DBModule_MQData/DBModule_MQData.cpp

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -802,7 +802,7 @@ bool CDBModule_MQData::DBModule_MQData_ShowTable(XCHAR*** pppszTableName, int* p
802802
意思:是否成功
803803
备注:
804804
*********************************************************************/
805-
bool CDBModule_MQData::DBModule_MQData_GetLeftCount(LPCXSTR lpszTableName, int nSerial, int* pInt_Count)
805+
bool CDBModule_MQData::DBModule_MQData_GetLeftCount(LPCXSTR lpszTableName, __int64x nSerial, int* pInt_Count)
806806
{
807807
DBModule_IsErrorOccur = false;
808808

@@ -820,7 +820,7 @@ bool CDBModule_MQData::DBModule_MQData_GetLeftCount(LPCXSTR lpszTableName, int n
820820
XCHAR tszSQLStatement[1024];
821821
memset(tszSQLStatement, '\0', sizeof(tszSQLStatement));
822822

823-
_xstprintf(tszSQLStatement, _X("SELECT COUNT(*) FROM %s WHERE nQueueSerial > %d"), lpszTableName, nSerial);
823+
_xstprintf(tszSQLStatement, _X("SELECT COUNT(*) FROM %s WHERE nQueueSerial > %lld"), lpszTableName, nSerial);
824824
if (!DataBase_MySQL_ExecuteQuery(xhDBSQL, &xhTable, tszSQLStatement, &nllLine, &nllRow))
825825
{
826826
DBModule_IsErrorOccur = true;

XEngine_Source/MQCore_DBModule/DBModule_MQData/DBModule_MQData.h

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,7 @@ class CDBModule_MQData
2828
bool DBModule_MQData_DeleteTable(LPCXSTR lpszQueueName);
2929
bool DBModule_MQData_ModifyTable(LPCXSTR lpszSrcTable, LPCXSTR lpszDstTable);
3030
bool DBModule_MQData_ShowTable(XCHAR*** pppszTableName, int* pInt_ListCount);
31-
bool DBModule_MQData_GetLeftCount(LPCXSTR lpszTableName, int nSerial, int* pInt_Count);
31+
bool DBModule_MQData_GetLeftCount(LPCXSTR lpszTableName, __int64x nSerial, int* pInt_Count);
3232
private:
3333
bool m_bMemoryQuery = false;
3434
bool m_bMemoryInsert = false;

XEngine_Source/MQCore_DBModule/pch.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -75,7 +75,7 @@ extern "C" bool DBModule_MQData_ShowTable(XCHAR * **pppszTableName, int* pInt_Li
7575
{
7676
return m_DBData.DBModule_MQData_ShowTable(pppszTableName, pInt_ListCount);
7777
}
78-
extern "C" bool DBModule_MQData_GetLeftCount(LPCXSTR lpszTableName, int nSerial, int* pInt_Count)
78+
extern "C" bool DBModule_MQData_GetLeftCount(LPCXSTR lpszTableName, __int64x nSerial, int* pInt_Count)
7979
{
8080
return m_DBData.DBModule_MQData_GetLeftCount(lpszTableName, nSerial, pInt_Count);
8181
}

0 commit comments

Comments
 (0)