1 /* Copyright (c) 2003-2005 MySQL AB
2 Use is subject to license terms
3
4 This program is free software; you can redistribute it and/or modify
5 it under the terms of the GNU General Public License as published by
6 the Free Software Foundation; version 2 of the License.
7
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.
12
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., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA */
16
17 // InsertRecs.cpp : Defines the entry point for the console application.
18 //
19
20
21 #include "stdafx.h"
22 #import "C:\Program Files\Common Files\System\ADO\msado15.dll" \
23 no_namespace rename("EOF", "EndOfFile")
24
25
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
91
92 struct _ParamStruct
93 {
94 HANDLE hShutdownEvent;
95 int nStartingRecordNum;
96 long* pnNumCallsProcessed;
97 };
98
99 HANDLE hShutdownEvent = 0;
100
ConsoleCtrlHandler(DWORD dwCtrlType)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 }
110
RuntimeCallContext(LPVOID lpParam)111 DWORD WINAPI RuntimeCallContext(LPVOID lpParam)
112 {
113 long nNumCallsProcessed = 0;
114
115 struct _ParamStruct* pData = (struct _ParamStruct*)lpParam;
116 int nStartingRecordID = pData->nStartingRecordNum;
117
118 HRESULT hr = CoInitialize(NULL);
119 if(FAILED(hr))
120 {
121 printf("Error Initializing COM Library\n");
122 return (int)hr;
123 }
124
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;
146
147 LARGE_INTEGER freq;
148
149 DWORD dwStartTime, dwEndTime;
150 LARGE_INTEGER liStartTime, liEndTime;
151
152 try
153 {
154 cn.CreateInstance(__uuidof(Connection));
155 cn->ConnectionString = _T("DSN=TTTelcoCS;");
156 cn->Open(_T(""),_T(""),_T(""),adConnectUnspecified);
157
158 cmdUpdate.CreateInstance(__uuidof(Command));
159 cmdInsert.CreateInstance(__uuidof(Command));
160 cmdDelete.CreateInstance(__uuidof(Command));
161 cmdSelect.CreateInstance(__uuidof(Command));
162
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, "')");
169
170 cmdInsert->CommandText= tszInsert;
171 cmdInsert->ActiveConnection = cn;
172 cmdInsert->Prepared = TRUE;
173
174
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;
181
182 cmdDelete->CommandText=_T("DELETE FROM dbo.CallContext WHERE ContextId = ?");
183 cmdDelete->ActiveConnection = cn;
184 cmdDelete->Prepared = TRUE;
185
186 cmdSelect->CommandText=_T("SELECT ContextData FROM dbo.CallContext WHERE ContextId = ?");
187 cmdSelect->ActiveConnection = cn;
188 cmdSelect->Prepared = TRUE;
189
190
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);
200
201
202
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);
210
211
212 cmdUpdate->Parameters->Append(paramContextID);
213 //cmdUpdate->Parameters->Append(paramContextID);
214
215 cmdSelect->Parameters->Append(paramContextID);
216
217 cmdDelete->Parameters->Append(paramContextID);
218
219 while(WaitForSingleObject(pData->hShutdownEvent,0) != WAIT_OBJECT_0)
220 {
221 paramContextID->Value = nStartingRecordID++;
222
223 bool bTimeLatency = (nStartingRecordID == 100) ? TRUE : FALSE;
224
225 if (bTimeLatency)
226 {
227 BOOL bSuccess = QueryPerformanceFrequency(&freq);
228 if (!bSuccess)
229 printf("Error retrieving frequency: %d\n", GetLastError());
230
231 }
232
233
234
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);
248
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 }
289
290 nNumCallsProcessed++;
291
292 InterlockedIncrement(pData->pnNumCallsProcessed);
293 }
294
295 cn->Close();
296 }
297 catch(_com_error &e)
298 {
299 printf("%d: \n\t%s\n\t%s\n",
300 e.Error(),
301 e.ErrorMessage(),
302 e.Source());
303
304 }
305
306 return 0;
307 }
308
309
_tmain(int argc,_TCHAR * argv[])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 }
319
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);
327
328 long nNumCallsProcessed = 0;
329
330 SetConsoleCtrlHandler(ConsoleCtrlHandler,true);
331 hShutdownEvent = CreateEvent(NULL,TRUE,FALSE,NULL);
332
333 DWORD dwStartTime = GetTickCount();
334
335 DWORD dwThreadID = 0;
336 HANDLE hThreads[50];
337
338 struct _ParamStruct params[50];
339
340
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 }
346
347
348 for(int ij=0;ij<nNumThreads;ij++) {
349 hThreads[ij] = CreateThread(NULL,NULL,RuntimeCallContext,¶ms[ij],0,&dwThreadID);
350 }
351
352 //Wait for the threads to finish
353 WaitForMultipleObjects(nNumThreads,hThreads,TRUE,INFINITE);
354 DWORD dwEndTime = GetTickCount();
355
356 CloseHandle(hShutdownEvent);
357
358 //Print time taken
359 _tprintf(_T("Time Taken for %d Calls is %ld msec (= %ld calls/sec\n"),
360 nNumCallsProcessed,dwEndTime-dwStartTime, (1000*nNumCallsProcessed/(dwEndTime-dwStartTime)));
361 return 0;
362
363 }
364