1.1 --- /dev/null Thu Jan 01 00:00:00 1970 +0000
1.2 +++ b/os/persistentdata/persistentstorage/dbms/tdbms/t_dbperf3.cpp Fri Jun 15 03:10:57 2012 +0200
1.3 @@ -0,0 +1,659 @@
1.4 +// Copyright (c) 2006-2009 Nokia Corporation and/or its subsidiary(-ies).
1.5 +// All rights reserved.
1.6 +// This component and the accompanying materials are made available
1.7 +// under the terms of "Eclipse Public License v1.0"
1.8 +// which accompanies this distribution, and is available
1.9 +// at the URL "http://www.eclipse.org/legal/epl-v10.html".
1.10 +//
1.11 +// Initial Contributors:
1.12 +// Nokia Corporation - initial contribution.
1.13 +//
1.14 +// Contributors:
1.15 +//
1.16 +// Description:
1.17 +//
1.18 +
1.19 +#include <d32dbms.h>
1.20 +#include <s32file.h>
1.21 +#include <e32test.h>
1.22 +#include <e32math.h>
1.23 +#include <s32mem.h>
1.24 +#include <hal.h>
1.25 +
1.26 +static RTest TheTest(_L("t_dbperf3"));
1.27 +static CTrapCleanup* TheTrapCleanup;
1.28 +static RFs TheFs;
1.29 +static RDbs TheDbs;
1.30 +static RDbNamedDatabase TheDatabase;
1.31 +static RDbRowSet TheRowSet, TheRowSet2;
1.32 +static RFile TheTestFile;
1.33 +static TFileName TheDatabaseFileName;
1.34 +
1.35 +#define COUNT_OF(array) (sizeof(array)/sizeof(array[0]))
1.36 +
1.37 +const TInt KTrackRecordCount = 200;
1.38 +const TInt KCategoryRecordCount = 50;
1.39 +const TInt KStatsRecordCount = 50;
1.40 +const TInt KTestBlobSize = 4096;
1.41 +
1.42 +//_LIT(KCreateTrackTable, "CREATE TABLE TRACKS (id INTEGER, marked_2_play INTEGER, category_id INTEGER, artist_last_name CHAR(15) NOT NULL,artist_first_name CHAR(15) NOT NULL, title CHAR(16) NOT NULL,download_site CHAR(30) NOT NULL,band_name CHAR(20) NOT NULL,origin CHAR(16),autostart INTEGER, init_volume INTEGER, music_file LONG VARCHAR)");
1.43 +_LIT(KCreateTrackIndex, "CREATE INDEX IDX1 ON TRACKS(id,marked_2_play,category_id)");
1.44 +_LIT(KCreateTrackTable, "CREATE TABLE TRACKS (id INTEGER, marked_2_play INTEGER, category_id INTEGER, artist_last_name CHAR(15) NOT NULL,artist_first_name CHAR(15) NOT NULL, title CHAR(16) NOT NULL,download_site CHAR(30) NOT NULL,band_name CHAR(20) NOT NULL,origin CHAR(16),autostart INTEGER, init_volume INTEGER)");
1.45 +_LIT(KCreateTrackTable2, "CREATE TABLE TRACKS2 (id INTEGER, music_file LONG VARCHAR)");
1.46 +//_LIT(KCreateTrackIndex2, "CREATE INDEX IDX4 ON TRACKS2(id)");
1.47 +
1.48 +//_LIT(KTrackTable,"TRACKS");
1.49 +
1.50 +_LIT(KId,"id");
1.51 +_LIT(KLastName,"artist_last_name");
1.52 +_LIT(KFirstName,"artist_first_name");
1.53 +_LIT(KTitle,"title");
1.54 +_LIT(KDownloadSite,"download_site");
1.55 +_LIT(KBandName,"band_name");
1.56 +_LIT(KOrigin,"origin");
1.57 +_LIT(KAutoStart,"autostart");
1.58 +_LIT(KInitVolume,"init_volume");
1.59 +_LIT(KMarked2Play,"marked_2_play");
1.60 +_LIT(KCategoryId,"category_id");
1.61 +_LIT(KMusicFile,"music_file");
1.62 +
1.63 +
1.64 +//category Table LITS
1.65 +_LIT(KCreateCategoryTable, "CREATE TABLE CATEGORY (category_id INTEGER,category_name CHAR(20),genre INTEGER)");
1.66 +_LIT(KCreateCategoryIndex, "CREATE INDEX IDX2 ON CATEGORY(category_id)");
1.67 +
1.68 +//_LIT(KCategoryTable,"CATEGORY");
1.69 +
1.70 +//KCategoryId defined for category table
1.71 +_LIT(KCategoryName,"category_name");
1.72 +_LIT(KGenre,"genre");
1.73 +
1.74 +
1.75 +//STATS Table LITS
1.76 +_LIT(KCreatestatsTable, "CREATE TABLE STATS (category_id INTEGER, no_of_tracks INTEGER, no_autostart INTEGER,no_manualstart INTEGER,no_marked_2_play INTEGER, no_unmarked_2_play INTEGER, size_of_musicfiles INTEGER)");
1.77 +_LIT(KCreatestatsIndex, "CREATE UNIQUE INDEX IDX3 ON STATS(category_id)");
1.78 +
1.79 +//_LIT(KStatsTable,"STATS");
1.80 +
1.81 +//KCategoryId defined for category table
1.82 +_LIT(KNoOfTracks,"no_of_tracks");
1.83 +_LIT(KNoMarked2Play,"no_marked_2_play");
1.84 +_LIT(KNoUnmarked2Play,"no_unmarked_2_play");
1.85 +_LIT(KNoAutostart,"no_autostart");
1.86 +_LIT(KNoManualStart,"no_manualstart");
1.87 +_LIT(KSizeOfMusicFiles,"size_of_musicfiles");
1.88 +
1.89 +//////////////////////////////////////////////////////
1.90 +
1.91 +static TInt TheCounterFreq = -10000000;
1.92 +const TInt KMicroSecIn1Sec = 1000000;
1.93 +
1.94 +TUint32 CalcTickDiff(TUint32 aStartTicks, TUint32 aEndTicks)
1.95 + {
1.96 + TInt64 diffTicks = (TInt64)aEndTicks - (TInt64)aStartTicks;
1.97 + if(diffTicks < 0)
1.98 + {
1.99 + diffTicks = KMaxTUint32 + diffTicks + 1;
1.100 + }
1.101 + return (TUint32)diffTicks;
1.102 + }
1.103 +
1.104 +//Prints aFastCount parameter (converted to us)
1.105 +void PrintFcDiffAsUs(const TDesC& aFormatStr, TUint32 aFastCount)
1.106 + {
1.107 + double v = ((double)aFastCount * KMicroSecIn1Sec) / (double)TheCounterFreq;
1.108 + TInt v2 = (TInt)v;
1.109 + TheTest.Printf(aFormatStr, v2);
1.110 + }
1.111 +
1.112 +///////////////////////////////////////////////////////////////////////////////////////
1.113 +
1.114 +//Delete "aFullName" file.
1.115 +static void DeleteFile(const TDesC& aFullName)
1.116 + {
1.117 + RFs fsSession;
1.118 + TInt err = fsSession.Connect();
1.119 + if(err == KErrNone)
1.120 + {
1.121 + TEntry entry;
1.122 + if(fsSession.Entry(aFullName, entry) == KErrNone)
1.123 + {
1.124 + err = fsSession.SetAtt(aFullName, 0, KEntryAttReadOnly);
1.125 + if(err != KErrNone)
1.126 + {
1.127 + TheTest.Printf(_L("Error %d changing \"%S\" file attributes.\n"), err, &aFullName);
1.128 + }
1.129 + err = fsSession.Delete(aFullName);
1.130 + if(err != KErrNone)
1.131 + {
1.132 + TheTest.Printf(_L("Error %d deleting \"%S\" file.\n"), err, &aFullName);
1.133 + }
1.134 + }
1.135 + fsSession.Close();
1.136 + }
1.137 + else
1.138 + {
1.139 + TheTest.Printf(_L("Error %d connecting file session. File: %S.\n"), err, &aFullName);
1.140 + }
1.141 + }
1.142 +
1.143 +///////////////////////////////////////////////////////////////////////////////////////
1.144 +
1.145 +static void CloseAll()
1.146 + {
1.147 + TheRowSet2.Close();
1.148 + TheRowSet.Close();
1.149 + TheDatabase.Close();
1.150 + TheDbs.Close();
1.151 + TheFs.Close();
1.152 + }
1.153 +
1.154 +///////////////////////////////////////////////////////////////////////////////////////
1.155 +///////////////////////////////////////////////////////////////////////////////////////
1.156 +//Tests macros and functions.
1.157 +//If (!aValue) then the test will be panicked, the test data files will be deleted.
1.158 +static void Check(TInt aValue, TInt aLine)
1.159 + {
1.160 + if(!aValue)
1.161 + {
1.162 + CloseAll();
1.163 + DeleteFile(TheDatabaseFileName);
1.164 + TheTest(EFalse, aLine);
1.165 + }
1.166 + }
1.167 +//If (aValue != aExpected) then the test will be panicked, the test data files will be deleted.
1.168 +static void Check(TInt aValue, TInt aExpected, TInt aLine)
1.169 + {
1.170 + if(aValue != aExpected)
1.171 + {
1.172 + TheTest.Printf(_L("*** Expected error: %d, got: %d\r\n"), aExpected, aValue);
1.173 + CloseAll();
1.174 + DeleteFile(TheDatabaseFileName);
1.175 + TheTest(EFalse, aLine);
1.176 + }
1.177 + }
1.178 +//Use these to test conditions.
1.179 +#define TEST(arg) ::Check((arg), __LINE__)
1.180 +#define TEST2(aValue, aExpected) ::Check(aValue, aExpected, __LINE__)
1.181 +
1.182 +///////////////////////////////////////////////////////////////////////////////////////
1.183 +
1.184 +void PrintFileSize()
1.185 + {
1.186 + RDbDatabase::TSize s = TheDatabase.Size();
1.187 + TheTest.Printf(_L("####FileSize: %d\r\n"), s.iSize);
1.188 + }
1.189 +
1.190 +///////////////////////////////////////////////////////////////////////////////////////
1.191 +
1.192 +void FillRandomData(TDes& aData, TInt64 aSeed)
1.193 + {
1.194 + aData.Zero();
1.195 + for (TInt i=0; i<aData.MaxLength(); ++i)
1.196 + {
1.197 + // add next character (we stick to lowercase alphabet for now)
1.198 + aData.Append(TChar(Math::FRand(aSeed)*25 + 'a'));
1.199 + }
1.200 + }
1.201 +
1.202 +void FillRandomData(TDes& aData)
1.203 + {
1.204 + // get random seed
1.205 + TTime time;
1.206 + time.UniversalTime();
1.207 + TInt64 seed = time.Int64();
1.208 + // do the filling
1.209 + FillRandomData(aData, seed);
1.210 + }
1.211 +
1.212 +///////////////////////////////////////////////////////////////////////////////////////
1.213 +
1.214 +void CreateDatabase()
1.215 + {
1.216 + TInt err = TheDatabase.Replace(TheFs, TheDatabaseFileName);
1.217 + TEST2(err, KErrNone);
1.218 + TheDatabase.Close();
1.219 + err = TheDbs.Connect();
1.220 + TEST2(err, KErrNone);
1.221 + err = TheDatabase.Open(TheDbs, TheDatabaseFileName);
1.222 + TEST2(err, KErrNone);
1.223 + err = TheDatabase.Execute(KCreateTrackTable);
1.224 + TEST2(err, KErrNone);
1.225 + err = TheDatabase.Execute(KCreateTrackIndex);
1.226 + TEST2(err, KErrNone);
1.227 + err = TheDatabase.Execute(KCreateTrackTable2);
1.228 + TEST2(err, KErrNone);
1.229 + //err = TheDatabase.Execute(KCreateTrackIndex2);
1.230 + //TEST2(err, KErrNone);
1.231 + err = TheDatabase.Execute(KCreateCategoryTable);
1.232 + TEST2(err, KErrNone);
1.233 + err = TheDatabase.Execute(KCreateCategoryIndex);
1.234 + TEST2(err, KErrNone);
1.235 + err = TheDatabase.Execute(KCreatestatsTable);
1.236 + TEST2(err, KErrNone);
1.237 + err = TheDatabase.Execute(KCreatestatsIndex);
1.238 + TEST2(err, KErrNone);
1.239 + //err = TheDatabase.Compact();
1.240 + //TEST2(err, KErrNone);
1.241 + }
1.242 +
1.243 +void InsertTrackTableL()
1.244 + {
1.245 + HBufC* randomDataBuf = HBufC::NewLC(KTestBlobSize);
1.246 + TPtr randomData(randomDataBuf->Des());
1.247 + FillRandomData(randomData);
1.248 +
1.249 + RDbView view;
1.250 + TInt err = view.Prepare(TheDatabase, _L("select * from TRACKS"), view.EInsertOnly);
1.251 + TEST2(err, KErrNone);
1.252 + TheRowSet = view;
1.253 +
1.254 + CDbColSet* colSet = TheRowSet.ColSetL();
1.255 + const TInt KIdIdx = colSet->ColNo(KId);
1.256 + const TInt KLastNameIdx = colSet->ColNo(KLastName);
1.257 + const TInt KFirstNameIdx = colSet->ColNo(KFirstName);
1.258 + const TInt KTitleIdx = colSet->ColNo(KTitle);
1.259 + const TInt KDownloadSiteIdx = colSet->ColNo(KDownloadSite);
1.260 + const TInt KBandNameIdx = colSet->ColNo(KBandName);
1.261 + const TInt KOriginIdx = colSet->ColNo(KOrigin);
1.262 + const TInt KAutoStartIdx = colSet->ColNo(KAutoStart);
1.263 + const TInt KInitVolumeIdx = colSet->ColNo(KInitVolume);
1.264 + const TInt KMarkedToPlayIdx = colSet->ColNo(KMarked2Play);
1.265 + const TInt KCategoryIdIdx = colSet->ColNo(KCategoryId);
1.266 + //const TInt KMusicFileIdx = colSet->ColNo(KMusicFile);
1.267 + delete colSet;
1.268 + colSet = NULL;
1.269 +
1.270 + err = TheDatabase.Begin();
1.271 + TEST2(err, KErrNone);
1.272 +
1.273 + for (TInt ii=1;ii<=KTrackRecordCount;++ii)
1.274 + {
1.275 + TheRowSet.InsertL();
1.276 + TheRowSet.SetColL(KIdIdx, ii);
1.277 + TheRowSet.SetColL(KLastNameIdx, _L("Dummy"));
1.278 + TheRowSet.SetColL(KFirstNameIdx,_L("Dummy"));
1.279 + TheRowSet.SetColL(KTitleIdx,_L("Dummy"));
1.280 + TheRowSet.SetColL(KDownloadSiteIdx,_L("Dummy"));
1.281 + TheRowSet.SetColL(KBandNameIdx,_L("Dummy"));
1.282 + TheRowSet.SetColL(KOriginIdx,_L("Dummy"));
1.283 + TheRowSet.SetColL(KAutoStartIdx,(ii%2));
1.284 + TheRowSet.SetColL(KInitVolumeIdx,(ii%2));
1.285 + TheRowSet.SetColL(KMarkedToPlayIdx,(ii%2));
1.286 + TheRowSet.SetColL(KCategoryIdIdx,(ii%KCategoryRecordCount));
1.287 +
1.288 + //RDbColWriteStream musicfile;
1.289 + //musicfile.OpenLC(TheRowSet, KMusicFileIdx);
1.290 + //musicfile.WriteL(randomData,KTestBlobSize);
1.291 + //musicfile.CommitL();
1.292 + //CleanupStack::PopAndDestroy(&musicfile);
1.293 +
1.294 + TheRowSet.PutL();
1.295 + }
1.296 +
1.297 + err = TheDatabase.Commit();
1.298 + TEST2(err, KErrNone);
1.299 +
1.300 + //err = TheDatabase.Compact();
1.301 + //TEST2(err, KErrNone);
1.302 +
1.303 + TheRowSet.Close();
1.304 +
1.305 + ////////////////////////////////////////////////////////////////////////////////////////////////
1.306 +
1.307 + err = view.Prepare(TheDatabase, _L("select * from TRACKS2"), view.EInsertOnly);
1.308 + TEST2(err, KErrNone);
1.309 + TheRowSet = view;
1.310 +
1.311 + colSet = TheRowSet.ColSetL();
1.312 + const TInt KIdIdx2 = colSet->ColNo(KId);
1.313 + const TInt KMusicFileIdx2 = colSet->ColNo(KMusicFile);
1.314 + delete colSet;
1.315 +
1.316 + err = TheDatabase.Begin();
1.317 + TEST2(err, KErrNone);
1.318 +
1.319 + for (TInt ii=1;ii<=KTrackRecordCount;++ii)
1.320 + {
1.321 + TheRowSet.InsertL();
1.322 + TheRowSet.SetColL(KIdIdx2, ii);
1.323 +
1.324 + RDbColWriteStream musicfile;
1.325 + musicfile.OpenLC(TheRowSet, KMusicFileIdx2);
1.326 + musicfile.WriteL(randomData,KTestBlobSize);
1.327 + musicfile.CommitL();
1.328 + CleanupStack::PopAndDestroy(&musicfile);
1.329 +
1.330 + TheRowSet.PutL();
1.331 + }
1.332 +
1.333 + err = TheDatabase.Commit();
1.334 + TEST2(err, KErrNone);
1.335 +
1.336 + //err = TheDatabase.Compact();
1.337 + //TEST2(err, KErrNone);
1.338 +
1.339 + TheRowSet.Close();
1.340 +
1.341 + CleanupStack::PopAndDestroy(randomDataBuf);
1.342 + }
1.343 +
1.344 +void InsertCategoryTableL()
1.345 + {
1.346 + RDbView view;
1.347 + TInt err = view.Prepare(TheDatabase, _L("select * from CATEGORY"), view.EInsertOnly);
1.348 + TEST2(err, KErrNone);
1.349 + TheRowSet = view;
1.350 +
1.351 + CDbColSet* colSet = TheRowSet.ColSetL();
1.352 + const TInt KCategoryIdIdx = colSet->ColNo(KCategoryId);
1.353 + const TInt KCategoryNameIdx = colSet->ColNo(KCategoryName);
1.354 + const TInt KGenreIdx = colSet->ColNo(KGenre);
1.355 + delete colSet;
1.356 +
1.357 + err = TheDatabase.Begin();
1.358 + TEST2(err, KErrNone);
1.359 +
1.360 + for (TInt ii=1;ii<=KCategoryRecordCount;++ii)
1.361 + {
1.362 + TheRowSet.InsertL();
1.363 + TheRowSet.SetColL(KCategoryIdIdx, ii);
1.364 + TheRowSet.SetColL(KCategoryNameIdx, _L("History"));
1.365 + TheRowSet.SetColL(KGenreIdx,(ii*500));
1.366 + TheRowSet.PutL();
1.367 + }
1.368 +
1.369 + err = TheDatabase.Commit();
1.370 + TEST2(err, KErrNone);
1.371 +
1.372 + //err = TheDatabase.Compact();
1.373 + //TEST2(err, KErrNone);
1.374 +
1.375 + TheRowSet.Close();
1.376 + }
1.377 +
1.378 +void InsertStatsTableL()
1.379 + {
1.380 + RDbView view;
1.381 + TInt err = view.Prepare(TheDatabase, _L("select * from STATS"), view.EInsertOnly);
1.382 + TEST2(err, KErrNone);
1.383 + TheRowSet = view;
1.384 +
1.385 + CDbColSet* colSet = TheRowSet.ColSetL();
1.386 + const TInt KCategoryIdIdx = colSet->ColNo(KCategoryId);
1.387 + const TInt KTrackCntIdx = colSet->ColNo(KNoOfTracks);
1.388 + const TInt KMarkedToPlayCntIdx = colSet->ColNo(KNoMarked2Play);
1.389 + const TInt KUnmarkedToPlayCntIdx = colSet->ColNo(KNoUnmarked2Play);
1.390 + const TInt KAutoStartCntIdx = colSet->ColNo(KNoAutostart);
1.391 + const TInt KManualStartCntIdx = colSet->ColNo(KNoManualStart);
1.392 + const TInt KSizeMusicFilesIdx = colSet->ColNo(KSizeOfMusicFiles);
1.393 + delete colSet;
1.394 +
1.395 + TInt default_Stat = 0;
1.396 +
1.397 + err = TheDatabase.Begin();
1.398 + TEST2(err, KErrNone);
1.399 +
1.400 + for (TInt ii=0;ii<KStatsRecordCount;++ii)
1.401 + {
1.402 + TheRowSet.InsertL();
1.403 + TheRowSet.SetColL(KCategoryIdIdx, ii);
1.404 + TheRowSet.SetColL(KTrackCntIdx,default_Stat);
1.405 + TheRowSet.SetColL(KMarkedToPlayCntIdx,default_Stat);
1.406 + TheRowSet.SetColL(KUnmarkedToPlayCntIdx,default_Stat);
1.407 + TheRowSet.SetColL(KAutoStartCntIdx,default_Stat);
1.408 + TheRowSet.SetColL(KManualStartCntIdx,default_Stat);
1.409 + TheRowSet.SetColL(KSizeMusicFilesIdx,default_Stat);
1.410 + TheRowSet.PutL();
1.411 + }
1.412 +
1.413 + err = TheDatabase.Commit();
1.414 + TEST2(err, KErrNone);
1.415 +
1.416 + //err = TheDatabase.Compact();
1.417 + //TEST2(err, KErrNone);
1.418 +
1.419 + TheRowSet.Close();
1.420 + }
1.421 +
1.422 +void FillDatabaseL()
1.423 + {
1.424 + InsertTrackTableL();
1.425 + InsertCategoryTableL();
1.426 + InsertStatsTableL();
1.427 + }
1.428 +
1.429 +void DestroyDatabase()
1.430 + {
1.431 + TheRowSet.Close();
1.432 + TheDatabase.Close();
1.433 + TheDbs.Close();
1.434 + TInt err = TheFs.Delete(TheDatabaseFileName);
1.435 + TEST2(err, KErrNone);
1.436 + }
1.437 +
1.438 +///////////////////////////////////////////////////////////////////////////////////////
1.439 +
1.440 +void GetFastCounterFrequency()
1.441 + {
1.442 + TEST2(HAL::Get(HAL::EFastCounterFrequency, TheCounterFreq), KErrNone);
1.443 + TheTest.Printf(_L("Counter frequency=%d\r\n"), TheCounterFreq);
1.444 + }
1.445 +
1.446 +///////////////////////////////////////////////////////////////////////////////////////
1.447 +
1.448 +void SelectTracksL(TInt aCount, RArray<TInt>& aTracks)
1.449 + {
1.450 + TUint32 fc = User::FastCounter();
1.451 + RDbView view;
1.452 + TUint32 fc2 = User::FastCounter();
1.453 + TInt err = view.Prepare(TheDatabase, _L("select id from TRACKS"), view.EReadOnly);
1.454 + TEST2(err, KErrNone);
1.455 + PrintFcDiffAsUs(_L("###\"Prepare()\",time=%d us\r\n"), CalcTickDiff(fc2, User::FastCounter()));
1.456 + fc2 = User::FastCounter();
1.457 + err = view.EvaluateAll();
1.458 + TEST2(err, KErrNone);
1.459 + PrintFcDiffAsUs(_L("###\"EvaluateAll()\",time=%d us\r\n"), CalcTickDiff(fc2, User::FastCounter()));
1.460 + TheRowSet = view;
1.461 +
1.462 + TUint32 diff1 = 0, diff2 = 0;
1.463 + TInt count = 0;
1.464 + while(count < aCount)
1.465 + {
1.466 + fc2 = User::FastCounter();
1.467 + if(!TheRowSet.NextL())
1.468 + {
1.469 + break;
1.470 + }
1.471 + diff1 += CalcTickDiff(fc2, User::FastCounter());
1.472 + fc2 = User::FastCounter();
1.473 + TheRowSet.GetL();
1.474 + diff2 += CalcTickDiff(fc2, User::FastCounter());
1.475 + aTracks.Append(TheRowSet.ColInt(1));
1.476 + ++count;
1.477 + }
1.478 + TEST2(count, aCount);
1.479 + PrintFcDiffAsUs(_L("###\"Total NextL()\",time=%d us\r\n"), diff1);
1.480 + PrintFcDiffAsUs(_L("###\"Total GetL()\",time=%d us\r\n"), diff2);
1.481 +
1.482 + fc2 = User::FastCounter();
1.483 + TheRowSet.Close();
1.484 + PrintFcDiffAsUs(_L("###\"Close()\",time=%d us\r\n"), CalcTickDiff(fc2, User::FastCounter()));
1.485 + PrintFcDiffAsUs(_L("###\"SELECT FROM TRACKS\",time=%d us\r\n"), CalcTickDiff(fc, User::FastCounter()));
1.486 + }
1.487 +
1.488 +/**
1.489 +@SYMTestCaseID PDS-DBMS-UT-4009
1.490 +@SYMTestCaseDesc DBMS performance tests.
1.491 +@SYMTestPriority High
1.492 +@SYMTestActions The test opens the test database and:
1.493 + - selects the ids of the tracks to be deleted and collects them into an array;
1.494 + - deletes the recods with matching track ids from TRACK table;
1.495 + - deletes the recods with matching track ids from TRACK2 table;
1.496 + The execution times are printed out.
1.497 +@SYMTestExpectedResults Test must not fail
1.498 +@SYMREQ REQ7141
1.499 +*/
1.500 +void DeleteTracksL()
1.501 + {
1.502 + TheTest.Printf(_L("Record count: %d\r\n"), KTrackRecordCount);
1.503 +
1.504 + RArray<TInt> tracks;
1.505 + tracks.ReserveL(KTrackRecordCount);
1.506 + CleanupClosePushL(tracks);
1.507 + SelectTracksL(KTrackRecordCount, tracks);
1.508 + //
1.509 + _LIT(KDeleteSql, "DELETE FROM tracks WHERE id>=%d AND id<=%d");
1.510 +
1.511 + TBuf<100> sql;
1.512 + sql.Format(KDeleteSql, tracks[0], tracks[tracks.Count() - 1]);
1.513 +
1.514 + TUint32 fc2 = User::FastCounter();
1.515 +
1.516 + TInt err = TheDatabase.Begin();
1.517 + TEST2(err, KErrNone);
1.518 +
1.519 + TUint32 fc = User::FastCounter();
1.520 + TInt rc = TheDatabase.Execute(sql);
1.521 + PrintFcDiffAsUs(_L("###\"DELETE FROM TRACKS\",time=%d us\r\n"), CalcTickDiff(fc, User::FastCounter()));
1.522 + TEST2(rc, KTrackRecordCount);
1.523 + TheTest.Printf(_L("Deleted record count: %d\r\n"), rc);
1.524 +
1.525 + sql.Replace(12, 6, _L("TRACKS2"));
1.526 + fc = User::FastCounter();
1.527 + rc = TheDatabase.Execute(sql);
1.528 + PrintFcDiffAsUs(_L("###\"DELETE FROM TRACKS2\",time=%d us\r\n"), CalcTickDiff(fc, User::FastCounter()));
1.529 + TEST2(rc, KTrackRecordCount);
1.530 + TheTest.Printf(_L("Deleted record count: %d\r\n"), rc);
1.531 +
1.532 + err = TheDatabase.Commit();
1.533 + TEST2(err, KErrNone);
1.534 +
1.535 + PrintFcDiffAsUs(_L("###Total \"DELETE FROM TRACKS\",time=%d us\r\n"), CalcTickDiff(fc2, User::FastCounter()));
1.536 +
1.537 + CleanupStack::PopAndDestroy(&tracks);
1.538 + }
1.539 +
1.540 +///////////////////////////////////////////////////////////////////////////////////////
1.541 +
1.542 +//This test checks how RDbDatabase::Commit() works if there are some active RDbRowSet objects -
1.543 +//read-only and updatable. The expectation is that the Commit() call won't fail, the RDbRowSet objects
1.544 +//retain their pre-commit positions.
1.545 +void CommitTestL()
1.546 + {
1.547 + //Create 2 test tables, insert some records in the first table
1.548 + TheDatabase.Close();
1.549 + TInt err = TheDatabase.Replace(TheFs, TheDatabaseFileName);
1.550 + TEST2(err, KErrNone);
1.551 + err = TheDatabase.Execute(_L("CREATE TABLE AA1(Id INTEGER)"));
1.552 + TEST2(err, KErrNone);
1.553 + err = TheDatabase.Execute(_L("CREATE TABLE AA2(Id INTEGER)"));
1.554 + TEST2(err, KErrNone);
1.555 + err = TheDatabase.Execute(_L("INSERT INTO AA1(Id) VALUES(1)"));
1.556 + TEST2(err, 1);
1.557 + err = TheDatabase.Execute(_L("INSERT INTO AA1(Id) VALUES(2)"));
1.558 + TEST2(err, 1);
1.559 + err = TheDatabase.Execute(_L("INSERT INTO AA1(Id) VALUES(3)"));
1.560 + TEST2(err, 1);
1.561 + //Begin transaction
1.562 + err = TheDatabase.Begin();
1.563 + TEST2(err, KErrNone);
1.564 + //Prepare read-only view and call FirstL() (TheRowSet object)
1.565 + RDbView view;
1.566 + err = view.Prepare(TheDatabase, _L("select * from AA1"), RDbRowSet::EReadOnly);
1.567 + TEST2(err, KErrNone);
1.568 + TheRowSet = view;
1.569 + err = view.EvaluateAll(); //DBMS can use FirstL() without the EvaluateAll() call in this case
1.570 + TEST2(err, KErrNone);
1.571 + TBool rc = TheRowSet.FirstL();
1.572 + TEST(rc);
1.573 + //Prepare updatable view and call NextL() (TheRowSet2 object)
1.574 + err = view.Prepare(TheDatabase, _L("select * from AA1"), RDbRowSet::EUpdatable);
1.575 + TEST2(err, KErrNone);
1.576 + TheRowSet2 = view;
1.577 + err = view.EvaluateAll(); //DBMS can use NextL() without the EvaluateAll() call in this case
1.578 + TEST2(err, KErrNone);
1.579 + rc = TheRowSet2.FirstL();
1.580 + TEST(rc);
1.581 + rc = TheRowSet2.NextL();
1.582 + TEST(rc);
1.583 + //Execute one INSERT statement
1.584 + err = TheDatabase.Execute(_L("INSERT INTO AA2(Id) VALUES(1)"));
1.585 + TEST2(err, 1);
1.586 + //Commit transaction
1.587 + err = TheDatabase.Commit();
1.588 + TEST2(err, KErrNone);
1.589 + //Check the retrieved by TheRowSet record
1.590 + TheRowSet.GetL();
1.591 + TEST2(TheRowSet.ColInt(1), 1);
1.592 + //Check the retrieved by TheRowSet2 record
1.593 + TheRowSet2.GetL();
1.594 + TEST2(TheRowSet2.ColInt(1), 2);
1.595 + //Cleanup
1.596 + TheRowSet2.Close();
1.597 + TheRowSet.Close();
1.598 + TheDatabase.Close();
1.599 + }
1.600 +
1.601 +///////////////////////////////////////////////////////////////////////////////////////
1.602 +
1.603 +void DoTestL()
1.604 + {
1.605 + TheTest.Start(_L("Get fast counter frequency"));
1.606 + GetFastCounterFrequency();
1.607 +
1.608 + TheTest.Next(_L("Create&Fill test database"));
1.609 + CreateDatabase();
1.610 + FillDatabaseL();
1.611 +
1.612 + TheTest.Next(_L(" @SYMTestCaseID:PDS-DBMS-UT-4009 Delete tracks"));
1.613 + DeleteTracksL();
1.614 +
1.615 + TheTest.Next(_L("Commit() test (not a performance test)"));
1.616 + CommitTestL();
1.617 + }
1.618 +
1.619 +///////////////////////////////////////////////////////////////////////////////////////
1.620 +
1.621 +//Usage: "t_dbperf3 [<drive letter>:]"
1.622 +TInt E32Main()
1.623 + {
1.624 + TheTest.Title();
1.625 +
1.626 + TheTrapCleanup = CTrapCleanup::New();
1.627 + TEST(TheTrapCleanup != NULL);
1.628 +
1.629 + //Construct test database file name
1.630 + _LIT(KTestDatabase, "c:\\dbms-tst\\t_dbperf3.db");
1.631 + TFileName fname;
1.632 + User::CommandLine(fname);
1.633 + TParse parse;
1.634 + parse.Set(fname, &KTestDatabase, 0);
1.635 + const TDesC& dbFilePath = parse.FullName();
1.636 + TheDatabaseFileName.Copy(dbFilePath);
1.637 + TheTest.Printf(_L("Test database: %S\r\n"), &TheDatabaseFileName);
1.638 +
1.639 + __UHEAP_MARK;
1.640 +
1.641 + TInt err = TheFs.Connect();
1.642 + TEST2(err, KErrNone);
1.643 + err = TheFs.MkDir(TheDatabaseFileName);
1.644 + TheTest.Printf(_L("MkDir(): err=%d\r\n"), err);
1.645 + TEST(err == KErrNone || err == KErrAlreadyExists);
1.646 +
1.647 + DeleteFile(TheDatabaseFileName);
1.648 +
1.649 + TRAP(err, DoTestL());
1.650 + TEST2(err, KErrNone);
1.651 +
1.652 + CloseAll();
1.653 + DeleteFile(TheDatabaseFileName);
1.654 +
1.655 + __UHEAP_MARKEND;
1.656 +
1.657 + TheTest.End();
1.658 + TheTest.Close();
1.659 +
1.660 + delete TheTrapCleanup;
1.661 + return KErrNone;
1.662 + }