开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 数据库系统 > MySQL数据库 > 查看源码
adoInsertRecs.cpp
资源名称：mysql-4.1.16-win-src.zip　[点击查看]
上传用户：romrleung
上传日期：2022-05-23
资源大小：18897k
文件大小：14k
源码类别：

MySQL数据库

开发平台：

Visual C++

adoInsertRecs.cpp：源码内容
  1. /* Copyright (C) 2003 MySQL AB
  3.    This program is free software; you can redistribute it and/or modify
  4.    it under the terms of the GNU General Public License as published by
  5.    the Free Software Foundation; either version 2 of the License, or
  6.    (at your option) any later version.
  8.    This program is distributed in the hope that it will be useful,
  9.    but WITHOUT ANY WARRANTY; without even the implied warranty of
  10.    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  11.    GNU General Public License for more details.
  13.    You should have received a copy of the GNU General Public License
  14.    along with this program; if not, write to the Free Software
  15.    Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA */
  17. // InsertRecs.cpp : Defines the entry point for the console application.
  18. //
  21. #include "stdafx.h"
  22. #import "C:Program FilesCommon FilesSystemADOmsado15.dll" 
  23.     no_namespace rename("EOF", "EndOfFile")
  26. // data for CALL_CONTEXT and GROUP_RESOURCE
  27. static TCHAR STATUS_DATA[]=_T("000102030405060708090A0B0C0D0E0F000102030405060708090A0B0C0D0E0F")
  28.    _T("101112131415161718191A1B1C1D1E1F000102030405060708090A0B0C0D0E0F")
  29.    _T("202122232425262728292A2B2C2D2E2F000102030405060708090A0B0C0D0E0F")
  30.    _T("303132333435363738393A3B3C3D3E3F000102030405060708090A0B0C0D0E0F")
  31.    _T("404142434445464748494A4B4C4D4E4F000102030405060708090A0B0C0D0E0F")
  32.    _T("505152535455565758595A5B5C5D5E5F000102030405060708090A0B0C0D0E0F")
  33.    _T("606162636465666768696A6B6C6D6E6F000102030405060708090A0B0C0D0E0F")
  34.    _T("707172737475767778797A7B7C7D7E7F000102030405060708090A0B0C0D0E0F")
  35.    _T("808182838485868788898A8B8C8D8E8F000102030405060708090A0B0C0D0E0F")
  36.    _T("909192939495969798999A9B9C9D9E9F000102030405060708090A0B0C0D0E0F")
  37.    _T("10010110210310410510610710810910A000102030405060708090A0B0C0D0EF")
  38.    _T("10B10C10D10E10F110111112113114115000102030405060708090A0B0C0D0EF")
  39.    _T("11611711811911A11B11C11D11E11F120000102030405060708090A0B0C0D0EF")
  40.    _T("12112212312412512612712812912A12B000102030405060708090A0B0C0D0EF")
  41.    _T("12C12D12E12F130131132134135136137000102030405060708090A0B0C0D0EF")
  42.    _T("13813913A13B13C13D13E13F140141142000102030405060708090A0B0C0D0EF")
  43.    _T("14314414514614714814914A14B14C14D000102030405060708090A0B0C0D0EF")
  44.    _T("14E14F150151152153154155156157158000102030405060708090A0B0C0D0EF")
  45.    _T("15915A15B15C15D15E15F160161162163000102030405060708090A0B0C0D0EF")
  46.    _T("16416516616716816916A16B16C16D16E000102030405060708090A0B0C0D0EF")
  47.    _T("16F170171172173174175176177178179000102030405060708090A0B0C0D0EF")
  48.    _T("17A17B17C17D17E17F180181182183184000102030405060708090A0B0C0D0EF")
  49.    _T("18518618718818918A18B18C18D18E18F000102030405060708090A0B0C0D0EF")
  50.    _T("19019119219319419519619719819919A000102030405060708090A0B0C0D0EF")
  51.    _T("19B19C19D19E19F200201202203204205000102030405060708090A0B0C0D0EF")
  52.    _T("20620720820920A20B20C20D20F210211000102030405060708090A0B0C0D0EF")
  53.    _T("21221321421521621721821921A21B21C000102030405060708090A0B0C0D0EF")
  54.    _T("21D21E21F220221222223224225226227000102030405060708090A0B0C0D0EF")
  55.    _T("22822922A22B22C22D22E22F230231232000102030405060708090A0B0C0D0EF")
  56.    _T("23323423523623723823923A23B23C23D000102030405060708090A0B0C0D0EF")
  57.    _T("23E23F240241242243244245246247248000102030405060708090A0B0C0D0EF")
  58.    _T("24924A24B24C24D24E24F250251252253000102030405060708090A0B0C0D0EF")
  59.    _T("101112131415161718191A1B1C1D1E1F000102030405060708090A0B0C0D0E0F")
  60.    _T("202122232425262728292A2B2C2D2E2F000102030405060708090A0B0C0D0E0F")
  61.    _T("303132333435363738393A3B3C3D3E3F000102030405060708090A0B0C0D0E0F")
  62.    _T("404142434445464748494A4B4C4D4E4F000102030405060708090A0B0C0D0E0F")
  63.    _T("505152535455565758595A5B5C5D5E5F000102030405060708090A0B0C0D0E0F")
  64.    _T("606162636465666768696A6B6C6D6E6F000102030405060708090A0B0C0D0E0F")
  65.    _T("707172737475767778797A7B7C7D7E7F000102030405060708090A0B0C0D0E0F")
  66.    _T("808182838485868788898A8B8C8D8E8F000102030405060708090A0B0C0D0E0F")
  67.    _T("909192939495969798999A9B9C9D9E9F000102030405060708090A0B0C0D0E0F")
  68.    _T("10010110210310410510610710810910A000102030405060708090A0B0C0D0EF")
  69.    _T("10B10C10D10E10F110111112113114115000102030405060708090A0B0C0D0EF")
  70.    _T("11611711811911A11B11C11D11E11F120000102030405060708090A0B0C0D0EF")
  71.    _T("12112212312412512612712812912A12B000102030405060708090A0B0C0D0EF")
  72.    _T("12C12D12E12F130131132134135136137000102030405060708090A0B0C0D0EF")
  73.    _T("13813913A13B13C13D13E13F140141142000102030405060708090A0B0C0D0EF")
  74.    _T("14314414514614714814914A14B14C14D000102030405060708090A0B0C0D0EF")
  75.    _T("14E14F150151152153154155156157158000102030405060708090A0B0C0D0EF")
  76.    _T("15915A15B15C15D15E15F160161162163000102030405060708090A0B0C0D0EF")
  77.    _T("16416516616716816916A16B16C16D16E000102030405060708090A0B0C0D0EF")
  78.    _T("16F170171172173174175176177178179000102030405060708090A0B0C0D0EF")
  79.    _T("17A17B17C17D17E17F180181182183184000102030405060708090A0B0C0D0EF")
  80.    _T("18518618718818918A18B18C18D18E18F000102030405060708090A0B0C0D0EF")
  81.    _T("19019119219319419519619719819919A000102030405060708090A0B0C0D0EF")
  82.    _T("19B19C19D19E19F200201202203204205000102030405060708090A0B0C0D0EF")
  83.    _T("20620720820920A20B20C20D20F210211000102030405060708090A0B0C0D0EF")
  84.    _T("21221321421521621721821921A21B21C000102030405060708090A0B0C0D0EF")
  85.    _T("21D21E21F220221222223224225226227000102030405060708090A0B0C0D0EF")
  86.    _T("22822922A22B22C22D22E22F230231232000102030405060708090A0B0C0D0EF")
  87.    _T("23323423523623723823923A23B23C23D000102030405060708090A0B0C0D0EF")
  88.    _T("2366890FE1438751097E7F6325DC0E6326F")
  89.    _T("25425525625725825925A25B25C25D25E25F000102030405060708090A0B0C0F");
  90. // Thread function for Call Context Inserts
  92. struct _ParamStruct
  93. {
  94. HANDLE hShutdownEvent;
  95. int nStartingRecordNum;
  96. long* pnNumCallsProcessed;
  97. };
  99. HANDLE hShutdownEvent = 0;
  101. BOOL WINAPI ConsoleCtrlHandler(DWORD dwCtrlType)
  102. {
  103. if(CTRL_C_EVENT == dwCtrlType)
  104. {
  105. SetEvent(hShutdownEvent);
  106. return TRUE;
  107. }
  108. return FALSE;
  109. }
  111. DWORD WINAPI RuntimeCallContext(LPVOID lpParam)
  112. {
  113.     long nNumCallsProcessed = 0;
  115. struct _ParamStruct* pData = (struct _ParamStruct*)lpParam;
  116.     int nStartingRecordID = pData->nStartingRecordNum;
  118.     HRESULT hr = CoInitialize(NULL);
  119. if(FAILED(hr))
  120. {
  121. printf("Error Initializing COM Libraryn");
  122. return (int)hr;
  123. }
  125. _ConnectionPtr cn = NULL;
  126. _CommandPtr cmdUpdate = NULL, cmdInsert = NULL, cmdDelete = NULL, cmdSelect = NULL;
  127. _RecordsetPtr rs = NULL;
  128. _ParameterPtr paramContextID = NULL;
  129.     _ParameterPtr paramVersion = NULL;
  130. _ParameterPtr paramLockFlag = NULL;
  131. _ParameterPtr ttparamLockFlag = NULL;
  132. _ParameterPtr paramLockTime = NULL;
  133. _ParameterPtr paramLockTimeUSec = NULL;
  134. _ParameterPtr paramContextData = NULL;
  135. _variant_t vtVersion;
  136. _variant_t vtLockFlag;
  137. _variant_t vtLockTime;
  138. _variant_t vtLockTimeUSec;
  139. _variant_t vtContextData;
  140. // Initialize Values
  141.     vtVersion = CALL_CONTEXT_VERSION;
  142. vtLockFlag = CALL_CONTEXT_LOCK_FLAG;
  143. vtLockTime = CALL_CONTEXT_LOCK_TIME;
  144. vtLockTimeUSec = CALL_CONTEXT_LOCK_TIME_USEC;
  145. vtContextData = STATUS_DATA;
  147. LARGE_INTEGER freq;
  149. DWORD dwStartTime, dwEndTime;
  150. LARGE_INTEGER liStartTime, liEndTime;
  152.     try
  153.     {
  154.         cn.CreateInstance(__uuidof(Connection));
  155.         cn->ConnectionString = _T("DSN=TTTelcoCS;");
  156.         cn->Open(_T(""),_T(""),_T(""),adConnectUnspecified);
  158. cmdUpdate.CreateInstance(__uuidof(Command));
  159.         cmdInsert.CreateInstance(__uuidof(Command));
  160.         cmdDelete.CreateInstance(__uuidof(Command));
  161.         cmdSelect.CreateInstance(__uuidof(Command));
  163. TCHAR tszInsert[10000], tszUpdate[10000];
  164. memset(tszInsert, 0, sizeof(tszInsert));
  165. memset(tszUpdate, 0, sizeof(tszUpdate));
  166. strcpy(tszInsert, "INSERT INTO dbo.CallContext(ContextId,Version,LockFlag,LockTime,LockTimeUSec,ContextData) VALUES(?,?,?,?,?,'");
  167. strcat(tszInsert, STATUS_DATA);
  168. strcat(tszInsert, "')");
  170.         cmdInsert->CommandText= tszInsert;
  171. cmdInsert->ActiveConnection = cn;
  172.         cmdInsert->Prepared = TRUE;
  175. strcpy(tszUpdate, "UPDATE dbo.CallContext SET ContextData = '");
  176. strcat(tszUpdate, STATUS_DATA);
  177. strcat(tszUpdate, "' WHERE ContextId = ?");
  178.         cmdUpdate->CommandText= tszUpdate;
  179. cmdUpdate->ActiveConnection = cn;
  180.         cmdUpdate->Prepared = TRUE;
  182.         cmdDelete->CommandText=_T("DELETE FROM dbo.CallContext WHERE ContextId = ?");
  183. cmdDelete->ActiveConnection = cn;
  184.         cmdDelete->Prepared = TRUE;
  186.         cmdSelect->CommandText=_T("SELECT ContextData FROM dbo.CallContext WHERE ContextId = ?");
  187. cmdSelect->ActiveConnection = cn;
  188.         cmdSelect->Prepared = TRUE;
  191. //Create params
  192. paramContextID = cmdInsert->CreateParameter(_T("ContextID"),adInteger,adParamInput,sizeof(int),nStartingRecordID);
  193. paramVersion = cmdInsert->CreateParameter(_T("Version"),adInteger,adParamInput,sizeof(int),1);//vtVersion);
  194. paramLockFlag = cmdInsert->CreateParameter(_T("LockFlag"),adInteger,adParamInput,sizeof(int),1);//vtLockFlag);
  195. ttparamLockFlag = cmdUpdate->CreateParameter(_T("LockFlag"),adInteger,adParamInput,sizeof(int),1);//vtLockFlag);
  196. paramLockTime = cmdInsert->CreateParameter(_T("LockTime"),adInteger,adParamInput,sizeof(int),1);//vtLockTime);
  197. paramLockTimeUSec = cmdInsert->CreateParameter(_T("LockTimeUSec"),adInteger,adParamInput,sizeof(int),1);//vtLockTimeUSec);
  198. paramContextData = cmdInsert->CreateParameter(_T("ContextData"), adBSTR, adParamInput, SysStringByteLen(vtContextData.bstrVal), vtContextData);
  199. //paramContextData->put_Value(vtContextData);
  203. //Append params
  204. cmdInsert->Parameters->Append(paramContextID);
  205. cmdInsert->Parameters->Append(paramVersion);
  206. cmdInsert->Parameters->Append(paramLockFlag);
  207. cmdInsert->Parameters->Append(paramLockTime);
  208. cmdInsert->Parameters->Append(paramLockTimeUSec);
  209. //cmdInsert->Parameters->Append(paramContextData);
  212.         cmdUpdate->Parameters->Append(paramContextID);
  213. //cmdUpdate->Parameters->Append(paramContextID);
  215.         cmdSelect->Parameters->Append(paramContextID);
  217.         cmdDelete->Parameters->Append(paramContextID);
  219.         while(WaitForSingleObject(pData->hShutdownEvent,0) != WAIT_OBJECT_0)
  220.         {
  221.             paramContextID->Value = nStartingRecordID++;
  223. bool bTimeLatency = (nStartingRecordID == 100) ? TRUE : FALSE;
  225. if (bTimeLatency)
  226. {
  227. BOOL bSuccess = QueryPerformanceFrequency(&freq);
  228. if (!bSuccess)
  229. printf("Error retrieving frequency: %dn", GetLastError());
  231. }
  235.             for (int i=0; i < 20; i++)
  236.             {
  237.                 switch(i)
  238.                 {
  239.                     case 3:
  240.                     case 6:
  241.                     case 9: 
  242.                     case 11: 
  243.                     case 12: 
  244.                     case 15: 
  245.                     case 18:   // Query Record
  246. if (bTimeLatency)
  247.    QueryPerformanceCounter(&liStartTime);
  249.                         cmdSelect->Execute(NULL, NULL, -1);
  250. if (bTimeLatency)
  251. {
  252. QueryPerformanceCounter(&liEndTime);
  253. printf("Read = %d msec.n", (liEndTime.QuadPart - liStartTime.QuadPart) / (freq.QuadPart/1000));
  254. }
  255.                         break;
  256.                     case 19:    // Delete Record
  257. if (bTimeLatency)
  258.    QueryPerformanceCounter(&liStartTime);
  259.                         cmdDelete->Execute(NULL,NULL,adExecuteNoRecords);
  260. if (bTimeLatency)
  261. {
  262. QueryPerformanceCounter(&liEndTime);
  263. printf("Delete = %d msec.n", (liEndTime.QuadPart - liStartTime.QuadPart) / (freq.QuadPart/1000));
  264. }
  265.                         break;
  266.                     case 0: // Insert Record
  267. if (bTimeLatency)
  268.    QueryPerformanceCounter(&liStartTime);
  269.                 cmdInsert->Execute(NULL,NULL,adExecuteNoRecords);
  270. if (bTimeLatency)
  271. {
  272. QueryPerformanceCounter(&liEndTime);
  273. printf("Insert = %d msec.n", (liEndTime.QuadPart - liStartTime.QuadPart) / (freq.QuadPart/1000));
  274. }
  275.                         break;
  276.                     default:    // Update Record
  277. if (bTimeLatency)
  278.    QueryPerformanceCounter(&liStartTime);
  279.                         cmdUpdate->Execute(NULL,NULL,adExecuteNoRecords);
  280. if (bTimeLatency)
  281. {
  282. QueryPerformanceCounter(&liEndTime);
  283. printf("Update = %d msec.n", (liEndTime.QuadPart - liStartTime.QuadPart) / (freq.QuadPart/1000));
  284. }
  285.                         
  286. break;
  287.                 }
  288.             }
  290. nNumCallsProcessed++;
  292.             InterlockedIncrement(pData->pnNumCallsProcessed);
  293.         }
  295. cn->Close();
  296.     }
  297.     catch(_com_error &e)
  298.     {
  299.         printf("%d: nt%snt%sn", 
  300. e.Error(), 
  301. e.ErrorMessage(), 
  302. e.Source());
  304.     }
  306.     return 0;
  307. }
  310. int _tmain(int argc, _TCHAR* argv[])
  311. {
  312. long nNumThreads=4;
  313. long nSeed = 0;
  314. if(lstrcmp(argv[1],_T("/?")) == 0)
  315. {
  316. _tprintf(_T("InsertRecs [No.Of Threads] [Record Seed No.]n"));
  317. return 0;
  318. }
  320. if(argc > 1) 
  321.      nNumThreads = _ttol(argv[1]);
  322. else
  323. nNumThreads = 4;
  324. if (argc > 2)
  325. nSeed = _ttol(argv[2]);
  326. _tprintf(_T("Num of Threads = %d, Seed = %d"), nNumThreads, nSeed);
  328. long nNumCallsProcessed = 0;
  330.     SetConsoleCtrlHandler(ConsoleCtrlHandler,true); 
  331. hShutdownEvent = CreateEvent(NULL,TRUE,FALSE,NULL);
  333. DWORD dwStartTime  = GetTickCount();
  335. DWORD dwThreadID = 0;
  336. HANDLE hThreads[50];
  338. struct _ParamStruct params[50];
  341. for(int ij=0;ij<nNumThreads;ij++) {
  342. params[ij].hShutdownEvent = hShutdownEvent;
  343. params[ij].nStartingRecordNum = (ij*5000) + nSeed;
  344. params[ij].pnNumCallsProcessed = &nNumCallsProcessed;
  345. }
  348. for(int ij=0;ij<nNumThreads;ij++) {
  349. hThreads[ij] = CreateThread(NULL,NULL,RuntimeCallContext,&params[ij],0,&dwThreadID);
  350. }
  352. //Wait for the threads to finish
  353.     WaitForMultipleObjects(nNumThreads,hThreads,TRUE,INFINITE);
  354. DWORD dwEndTime  = GetTickCount();
  356. CloseHandle(hShutdownEvent);
  358. //Print time taken
  359. _tprintf(_T("Time Taken for %d Calls is %ld msec (= %ld calls/secn"),
  360. nNumCallsProcessed,dwEndTime-dwStartTime, (1000*nNumCallsProcessed/(dwEndTime-dwStartTime)));
  361. return 0;
  363. }