Skip to content

Commit d02c823

Browse files
xengine-qytxengine-qyt
committed
added:modify bucket name for timerelease and key and owner
1 parent 703cfc5 commit d02c823

File tree

5 files changed

+182
-2
lines changed

5 files changed

+182
-2
lines changed

‎XEngine_Source/MQCore_DBModule/DBModule_Define.h‎

Lines changed: 58 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -411,6 +411,25 @@ extern "C" BOOL DBModule_MQUser_KeyDelete(XENGINE_DBUSERKEY* pSt_UserKey);
411411
备注：
412412
*********************************************************************/
413413
extern "C" BOOL DBModule_MQUser_KeyUPDate(XENGINE_DBUSERKEY* pSt_UserKey);
414+
/********************************************************************
415+
函数名称：DBModule_MQUser_KeyTopicUPDate
416+
函数功能：更新队列信息表
417+
参数.一：lpszSourceTable
418+
In/Out：In
419+
类型：常量字符指针
420+
可空：N
421+
意思：输入原始表名
422+
参数.二：lpszDestTable
423+
In/Out：In
424+
类型：常量字符指针
425+
可空：N
426+
意思：输入目标表名
427+
返回值
428+
类型：逻辑型
429+
意思：是否成功
430+
备注：
431+
*********************************************************************/
432+
extern "C" BOOL DBModule_MQUser_KeyTopicUPDate(LPCTSTR lpszSourceTable, LPCTSTR lpszDestTable);
414433
/*************************************************************************
415434
定时发布导出函数
416435
**************************************************************************/
@@ -475,6 +494,25 @@ extern "C" BOOL DBModule_MQUser_TimeDelete(XENGINE_DBTIMERELEASE * pSt_DBInfo);
475494
备注：
476495
*********************************************************************/
477496
extern "C" BOOL DBModule_MQUser_TimeClaer(time_t nTime = 0);
497+
/********************************************************************
498+
函数名称：DBModule_MQUser_TimeTopicUPDate
499+
函数功能：更新定时发布表
500+
参数.一：lpszSourceTable
501+
In/Out：In
502+
类型：常量字符指针
503+
可空：N
504+
意思：输入原始表名
505+
参数.二：lpszDestTable
506+
In/Out：In
507+
类型：常量字符指针
508+
可空：N
509+
意思：输入目标表名
510+
返回值
511+
类型：逻辑型
512+
意思：是否成功
513+
备注：
514+
*********************************************************************/
515+
extern "C" BOOL DBModule_MQUser_TimeTopicUPDate(LPCTSTR lpszSourceTable, LPCTSTR lpszDestTable);
478516
/*************************************************************************
479517
主题所有者导出函数
480518
**************************************************************************/
@@ -519,4 +557,23 @@ extern "C" BOOL DBModule_MQUser_OwnerDelete(XENGINE_DBTOPICOWNER* pSt_DBOwner);
519557
意思：是否成功
520558
备注：
521559
*********************************************************************/
522-
extern "C" BOOL DBModule_MQUser_OwnerQuery(XENGINE_DBTOPICOWNER* pSt_DBOwner);
560+
extern "C" BOOL DBModule_MQUser_OwnerQuery(XENGINE_DBTOPICOWNER* pSt_DBOwner);
561+
/********************************************************************
562+
函数名称：DBModule_MQUser_OwnerTopicUPDate
563+
函数功能：更新所有者表
564+
参数.一：lpszSourceTable
565+
In/Out：In
566+
类型：常量字符指针
567+
可空：N
568+
意思：输入原始表名
569+
参数.二：lpszDestTable
570+
In/Out：In
571+
类型：常量字符指针
572+
可空：N
573+
意思：输入目标表名
574+
返回值
575+
类型：逻辑型
576+
意思：是否成功
577+
备注：
578+
*********************************************************************/
579+
extern "C" BOOL DBModule_MQUser_OwnerTopicUPDate(LPCTSTR lpszSourceTable, LPCTSTR lpszDestTable);

‎XEngine_Source/MQCore_DBModule/DBModule_MQUser/DBModule_MQUser.cpp‎

Lines changed: 105 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -572,6 +572,41 @@ BOOL CDBModule_MQUser::DBModule_MQUser_KeyUPDate(XENGINE_DBUSERKEY* pSt_UserKey)
572572

573573
return TRUE;
574574
}
575+
/********************************************************************
576+
函数名称：DBModule_MQUser_KeyTopicUPDate
577+
函数功能：更新队列信息表
578+
参数.一：lpszSourceTable
579+
In/Out：In
580+
类型：常量字符指针
581+
可空：N
582+
意思：输入原始表名
583+
参数.二：lpszDestTable
584+
In/Out：In
585+
类型：常量字符指针
586+
可空：N
587+
意思：输入目标表名
588+
返回值
589+
类型：逻辑型
590+
意思：是否成功
591+
备注：
592+
*********************************************************************/
593+
BOOL CDBModule_MQUser::DBModule_MQUser_KeyTopicUPDate(LPCTSTR lpszSourceTable, LPCTSTR lpszDestTable)
594+
{
595+
DBModule_IsErrorOccur = FALSE;
596+
597+
TCHAR tszSQLQuery[2048];
598+
memset(tszSQLQuery, '\0', sizeof(tszSQLQuery));
599+
600+
_stprintf(tszSQLQuery, _T("UPDATE `UserKey` SET tszQueueName = '%s' WHERE tszQueueName = '%s'"), lpszSourceTable, lpszDestTable);
601+
if (!DataBase_MySQL_Execute(xhDBSQL, tszSQLQuery))
602+
{
603+
DBModule_IsErrorOccur = TRUE;
604+
DBModule_dwErrorCode = DataBase_GetLastError();
605+
return FALSE;
606+
}
607+
608+
return TRUE;
609+
}
575610
//////////////////////////////////////////////////////////////////////////
576611
/********************************************************************
577612
函数名称：DBModule_MQUser_TimeInsert
@@ -743,6 +778,41 @@ BOOL CDBModule_MQUser::DBModule_MQUser_TimeClaer(time_t nTime /* = 0 */)
743778
return TRUE;
744779
}
745780
/********************************************************************
781+
函数名称：DBModule_MQUser_TimeTopicUPDate
782+
函数功能：更新定时发布表
783+
参数.一：lpszSourceTable
784+
In/Out：In
785+
类型：常量字符指针
786+
可空：N
787+
意思：输入原始表名
788+
参数.二：lpszDestTable
789+
In/Out：In
790+
类型：常量字符指针
791+
可空：N
792+
意思：输入目标表名
793+
返回值
794+
类型：逻辑型
795+
意思：是否成功
796+
备注：
797+
*********************************************************************/
798+
BOOL CDBModule_MQUser::DBModule_MQUser_TimeTopicUPDate(LPCTSTR lpszSourceTable, LPCTSTR lpszDestTable)
799+
{
800+
DBModule_IsErrorOccur = FALSE;
801+
802+
TCHAR tszSQLQuery[2048];
803+
memset(tszSQLQuery, '\0', sizeof(tszSQLQuery));
804+
805+
_stprintf(tszSQLQuery, _T("UPDATE `UserTime` SET tszQueueName = '%s' WHERE tszQueueName = '%s'"), lpszSourceTable, lpszDestTable);
806+
if (!DataBase_MySQL_Execute(xhDBSQL, tszSQLQuery))
807+
{
808+
DBModule_IsErrorOccur = TRUE;
809+
DBModule_dwErrorCode = DataBase_GetLastError();
810+
return FALSE;
811+
}
812+
813+
return TRUE;
814+
}
815+
/********************************************************************
746816
函数名称：DBModule_MQUser_OwnerInsert
747817
函数功能：主题所有者插入
748818
参数.一：pSt_DBOwner
@@ -861,6 +931,41 @@ BOOL CDBModule_MQUser::DBModule_MQUser_OwnerQuery(XENGINE_DBTOPICOWNER* pSt_DBOw
861931
}
862932
return TRUE;
863933
}
934+
/********************************************************************
935+
函数名称：DBModule_MQUser_OwnerTopicUPDate
936+
函数功能：更新所有者表
937+
参数.一：lpszSourceTable
938+
In/Out：In
939+
类型：常量字符指针
940+
可空：N
941+
意思：输入原始表名
942+
参数.二：lpszDestTable
943+
In/Out：In
944+
类型：常量字符指针
945+
可空：N
946+
意思：输入目标表名
947+
返回值
948+
类型：逻辑型
949+
意思：是否成功
950+
备注：
951+
*********************************************************************/
952+
BOOL CDBModule_MQUser::DBModule_MQUser_OwnerTopicUPDate(LPCTSTR lpszSourceTable, LPCTSTR lpszDestTable)
953+
{
954+
DBModule_IsErrorOccur = FALSE;
955+
956+
TCHAR tszSQLQuery[2048];
957+
memset(tszSQLQuery, '\0', sizeof(tszSQLQuery));
958+
959+
_stprintf(tszSQLQuery, _T("UPDATE `KeyOwner` SET tszKeyName = '%s' WHERE tszKeyName = '%s'"), lpszSourceTable, lpszDestTable);
960+
if (!DataBase_MySQL_Execute(xhDBSQL, tszSQLQuery))
961+
{
962+
DBModule_IsErrorOccur = TRUE;
963+
DBModule_dwErrorCode = DataBase_GetLastError();
964+
return FALSE;
965+
}
966+
967+
return TRUE;
968+
}
864969
//////////////////////////////////////////////////////////////////////////
865970
// 线程函数
866971
//////////////////////////////////////////////////////////////////////////

‎XEngine_Source/MQCore_DBModule/DBModule_MQUser/DBModule_MQUser.h‎

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -29,15 +29,18 @@ class CDBModule_MQUser
2929
BOOL DBModule_MQUser_KeyList(LPCTSTR lpszUser, LPCTSTR lpszKeyName, XENGINE_DBUSERKEY*** pppSt_UserKey, int* pInt_ListCount);
3030
BOOL DBModule_MQUser_KeyDelete(XENGINE_DBUSERKEY* pSt_UserKey);
3131
BOOL DBModule_MQUser_KeyUPDate(XENGINE_DBUSERKEY* pSt_UserKey);
32+
BOOL DBModule_MQUser_KeyTopicUPDate(LPCTSTR lpszSourceTable, LPCTSTR lpszDestTable);
3233
public:
3334
BOOL DBModule_MQUser_TimeInsert(XENGINE_DBTIMERELEASE* pSt_DBInfo);
3435
BOOL DBModule_MQUser_TimeQuery(XENGINE_DBTIMERELEASE*** pppSt_DBInfo, int* pInt_ListCount);
3536
BOOL DBModule_MQUser_TimeDelete(XENGINE_DBTIMERELEASE* pSt_DBInfo);
3637
BOOL DBModule_MQUser_TimeClaer(time_t nTime = 0);
38+
BOOL DBModule_MQUser_TimeTopicUPDate(LPCTSTR lpszSourceTable, LPCTSTR lpszDestTable);
3739
public:
3840
BOOL DBModule_MQUser_OwnerInsert(XENGINE_DBTOPICOWNER* pSt_DBOwner);
3941
BOOL DBModule_MQUser_OwnerDelete(XENGINE_DBTOPICOWNER* pSt_DBOwner);
4042
BOOL DBModule_MQUser_OwnerQuery(XENGINE_DBTOPICOWNER* pSt_DBOwner);
43+
BOOL DBModule_MQUser_OwnerTopicUPDate(LPCTSTR lpszSourceTable, LPCTSTR lpszDestTable);
4144
protected:
4245
static XHTHREAD CALLBACK DBModule_MQUser_TimeThread(LPVOID lParam);
4346
private:

‎XEngine_Source/MQCore_DBModule/MQCore_DBModule.def‎

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,12 +26,15 @@ EXPORTS
2626
DBModule_MQUser_KeyList
2727
DBModule_MQUser_KeyDelete
2828
DBModule_MQUser_KeyUPDate
29+
DBModule_MQUser_KeyTopicUPDate
2930

3031
DBModule_MQUser_TimeInsert
3132
DBModule_MQUser_TimeQuery
3233
DBModule_MQUser_TimeDelete
3334
DBModule_MQUser_TimeClaer
35+
DBModule_MQUser_TimeTopicUPDate
3436

3537
DBModule_MQUser_OwnerInsert
3638
DBModule_MQUser_OwnerDelete
37-
DBModule_MQUser_OwnerQuery
39+
DBModule_MQUser_OwnerQuery
40+
DBModule_MQUser_OwnerTopicUPDate

‎XEngine_Source/MQCore_DBModule/pch.cpp‎

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -121,6 +121,10 @@ extern "C" BOOL DBModule_MQUser_KeyUPDate(XENGINE_DBUSERKEY * pSt_UserKey)
121121
{
122122
return m_DBUser.DBModule_MQUser_KeyUPDate(pSt_UserKey);
123123
}
124+
extern "C" BOOL DBModule_MQUser_KeyTopicUPDate(LPCTSTR lpszSourceTable, LPCTSTR lpszDestTable)
125+
{
126+
return m_DBUser.DBModule_MQUser_KeyTopicUPDate(lpszSourceTable, lpszDestTable);
127+
}
124128
/*************************************************************************
125129
定时发布导出函数
126130
**************************************************************************/
@@ -140,6 +144,10 @@ extern "C" BOOL DBModule_MQUser_TimeClaer(time_t nTime)
140144
{
141145
return m_DBUser.DBModule_MQUser_TimeClaer(nTime);
142146
}
147+
extern "C" BOOL DBModule_MQUser_TimeTopicUPDate(LPCTSTR lpszSourceTable, LPCTSTR lpszDestTable)
148+
{
149+
return m_DBUser.DBModule_MQUser_TimeTopicUPDate(lpszSourceTable, lpszDestTable);
150+
}
143151
/*************************************************************************
144152
主题所有者导出函数
145153
**************************************************************************/
@@ -154,4 +162,8 @@ extern "C" BOOL DBModule_MQUser_OwnerDelete(XENGINE_DBTOPICOWNER * pSt_DBOwner)
154162
extern "C" BOOL DBModule_MQUser_OwnerQuery(XENGINE_DBTOPICOWNER * pSt_DBOwner)
155163
{
156164
return m_DBUser.DBModule_MQUser_OwnerQuery(pSt_DBOwner);
165+
}
166+
extern "C" BOOL DBModule_MQUser_OwnerTopicUPDate(LPCTSTR lpszSourceTable, LPCTSTR lpszDestTable)
167+
{
168+
return m_DBUser.DBModule_MQUser_OwnerTopicUPDate(lpszSourceTable, lpszDestTable);
157169
}

0 commit comments

Comments
 (0)