1.1 --- /dev/null Thu Jan 01 00:00:00 1970 +0000
1.2 +++ b/os/persistentdata/persistentstorage/dbms/tdbms/t_dbcomp.cpp Fri Jun 15 03:10:57 2012 +0200
1.3 @@ -0,0 +1,335 @@
1.4 +// Copyright (c) 1998-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 +// MSVC++ up to 5.0 has problems with expanding inline functions
1.20 +// This disables the mad warnings for the whole project
1.21 +#if defined(NDEBUG) && defined(__VC32__) && _MSC_VER<=1100
1.22 +#pragma warning(disable : 4710) // function not expanded. MSVC 5.0 is stupid
1.23 +#endif
1.24 +
1.25 +#include <d32dbms.h>
1.26 +#include <s32file.h>
1.27 +#include <e32test.h>
1.28 +#include <e32math.h>
1.29 +#include <hal.h>
1.30 +
1.31 +static RTest TheTest(_L("t_dbcomp"));
1.32 +static RFs TheFs;
1.33 +
1.34 +//T_BENCH.DB file is created by T_BENCH test and is used by the current test (T_COMP).
1.35 +//T_COMP test will delete T_BENCH.DB at the end as it is no more needed.
1.36 +//If you want to rerun T_COMP test again, you have to ensure that T_BENCH.DB file exists -
1.37 +//run T_BENCH test again.
1.38 +TFileName TheBenchDbFileName;
1.39 +TFileName TheCompressedFileName;
1.40 +TFileName TheDecompressedFileName;
1.41 +
1.42 +RDbNamedDatabase TheCompDb;
1.43 +RDbNamedDatabase TheCopyDb;
1.44 +RDbTable TheTable1, TheTable2;
1.45 +
1.46 +///////////////////////////////////////////////////////////////////////////////////////
1.47 +
1.48 +static void CloseAll()
1.49 + {
1.50 + TheTable2.Close();
1.51 + TheTable1.Close();
1.52 + TheCopyDb.Close();
1.53 + TheCompDb.Close();
1.54 + }
1.55 +
1.56 +///////////////////////////////////////////////////////////////////////////////////////
1.57 +
1.58 +//Delete "aFullName" file.
1.59 +static void DeleteFile(const TDesC& aFullName)
1.60 + {
1.61 + RFs fsSession;
1.62 + TInt err = fsSession.Connect();
1.63 + if(err == KErrNone)
1.64 + {
1.65 + TEntry entry;
1.66 + if(fsSession.Entry(aFullName, entry) == KErrNone)
1.67 + {
1.68 + err = fsSession.SetAtt(aFullName, 0, KEntryAttReadOnly);
1.69 + if(err != KErrNone)
1.70 + {
1.71 + TheTest.Printf(_L("Error %d changing \"%S\" file attributes.\n"), err, &aFullName);
1.72 + }
1.73 + err = fsSession.Delete(aFullName);
1.74 + if(err != KErrNone)
1.75 + {
1.76 + TheTest.Printf(_L("Error %d deleting \"%S\" file.\n"), err, &aFullName);
1.77 + }
1.78 + }
1.79 + fsSession.Close();
1.80 + }
1.81 + else
1.82 + {
1.83 + TheTest.Printf(_L("Error %d connecting file session. File: %S.\n"), err, &aFullName);
1.84 + }
1.85 + }
1.86 +
1.87 +///////////////////////////////////////////////////////////////////////////////////////
1.88 +
1.89 +static void DestroyTestEnv()
1.90 + {
1.91 + CloseAll();
1.92 + DeleteFile(TheDecompressedFileName);
1.93 + DeleteFile(TheCompressedFileName);
1.94 + DeleteFile(TheBenchDbFileName);
1.95 + TheFs.Close();
1.96 + }
1.97 +
1.98 +///////////////////////////////////////////////////////////////////////////////////////
1.99 +//Tests macros and functions.
1.100 +//If (!aValue) then the test will be panicked, the test data files will be deleted.
1.101 +static void Check(TInt aValue, TInt aLine)
1.102 + {
1.103 + if(!aValue)
1.104 + {
1.105 + TheTest.Printf(_L("*** Boolean expression evaluated to false!\r\n"));
1.106 + DestroyTestEnv();
1.107 + TheTest(EFalse, aLine);
1.108 + }
1.109 + }
1.110 +//If (aValue != aExpected) then the test will be panicked, the test data files will be deleted.
1.111 +static void Check(TInt aValue, TInt aExpected, TInt aLine)
1.112 + {
1.113 + if(aValue != aExpected)
1.114 + {
1.115 + TheTest.Printf(_L("*** Expected error: %d, got: %d\r\n"), aExpected, aValue);
1.116 + DestroyTestEnv();
1.117 + TheTest(EFalse, aLine);
1.118 + }
1.119 + }
1.120 +//Use these to test conditions.
1.121 +#define TEST(arg) ::Check((arg), __LINE__)
1.122 +#define TEST2(aValue, aExpected) ::Check(aValue, aExpected, __LINE__)
1.123 +
1.124 +//////////////////////////////////////////////////////
1.125 +
1.126 +static TInt TheCounterFreq = -10000000;
1.127 +const TInt KMicroSecIn1Sec = 1000000;
1.128 +
1.129 +TUint32 CalcTickDiff(TUint32 aStartTicks, TUint32 aEndTicks)
1.130 + {
1.131 + TInt64 diffTicks = (TInt64)aEndTicks - (TInt64)aStartTicks;
1.132 + if(diffTicks < 0)
1.133 + {
1.134 + diffTicks = KMaxTUint32 + diffTicks + 1;
1.135 + }
1.136 + return (TUint32)diffTicks;
1.137 + }
1.138 +
1.139 +//Prints aFastCount parameter (converted to us)
1.140 +void PrintFcDiffAsUs(const TDesC& aFormatStr, TUint32 aFastCount)
1.141 + {
1.142 + if(TheCounterFreq <= 0)
1.143 + {
1.144 + TEST2(HAL::Get(HAL::EFastCounterFrequency, TheCounterFreq), KErrNone);
1.145 + TheTest.Printf(_L("Counter frequency=%d Hz\r\n"), TheCounterFreq);
1.146 + }
1.147 + double v = ((double)aFastCount * KMicroSecIn1Sec) / (double)TheCounterFreq;
1.148 + TInt v2 = (TInt)v;
1.149 + TheTest.Printf(aFormatStr, v2);
1.150 + }
1.151 +
1.152 +///////////////////////////////////////////////////////////////////////////////////////
1.153 +
1.154 +//
1.155 +// Prepare the test directory.
1.156 +//
1.157 +void CreateTestEnv()
1.158 + {
1.159 + TInt err = TheFs.Connect();
1.160 + TheTest(err == KErrNone);
1.161 +
1.162 + err = TheFs.MkDirAll(TheBenchDbFileName);
1.163 + TEST(err == KErrNone || err == KErrAlreadyExists);
1.164 +
1.165 + TUint dummy;
1.166 + err = TheFs.Att(TheBenchDbFileName, dummy);
1.167 + if(err != KErrNone)
1.168 + {
1.169 + TheTest.Printf(_L("*** The %S file does not exist, err=%d. Run \"T_BENCH\" test first!\r\n"), &TheBenchDbFileName, err);
1.170 + TEST2(err, KErrNone);
1.171 + }
1.172 + }
1.173 +
1.174 +///////////////////////////////////////////////////////////////////////////////////////
1.175 +
1.176 +//
1.177 +// Compress the database
1.178 +//
1.179 +void CompressL(const TDesC& aSource, const TDesC& aTarget, TBool aCompress)
1.180 + {
1.181 + CFileMan* man = CFileMan::NewL(TheFs);
1.182 + TInt err = man->Copy(aSource, aTarget);
1.183 + delete man;
1.184 + User::LeaveIfError(err);
1.185 +
1.186 + User::LeaveIfError(TheFs.SetAtt(aTarget, 0, KEntryAttReadOnly));
1.187 + CFileStore* store = CFileStore::OpenLC(TheFs, aTarget, EFileRead|EFileWrite);
1.188 +
1.189 + TUint32 fc = User::FastCounter();
1.190 + if(aCompress)
1.191 + {
1.192 + RDbStoreDatabase::CompressL(*store, store->Root());
1.193 + }
1.194 + else
1.195 + {
1.196 + RDbStoreDatabase::DecompressL(*store, store->Root());
1.197 + }
1.198 + TUint32 time = CalcTickDiff(fc, User::FastCounter());
1.199 + PrintFcDiffAsUs(_L(" %d us\r\n"), time);
1.200 +
1.201 + store->CompactL();
1.202 + store->CommitL();
1.203 +
1.204 + CleanupStack::PopAndDestroy(store);
1.205 + }
1.206 +
1.207 +void CheckTableL(RDbDatabase& aDatabase, RDbDatabase& aCopy, const TDesC& aTable)
1.208 + {
1.209 + TheTest.Printf(_L("Processing table %S\n"), &aTable);
1.210 +
1.211 + TInt err = TheTable1.Open(aDatabase, aTable, RDbRowSet::EReadOnly);
1.212 + TEST2(err, KErrNone);
1.213 +
1.214 + err = TheTable2.Open(aCopy, aTable, RDbRowSet::EReadOnly);
1.215 + TEST2(err, KErrNone);
1.216 +
1.217 + TInt columns = TheTable1.ColCount();
1.218 + while(TheTable1.NextL())
1.219 + {
1.220 + TheTable1.GetL();
1.221 + TEST(TheTable2.NextL());
1.222 + TheTable2.GetL();
1.223 + for(TInt ii=1;ii<=columns;++ii)
1.224 + {
1.225 + if(TDbCol::IsLong(TheTable1.ColType(ii)))
1.226 + {
1.227 + TInt len = TheTable1.ColSize(ii);
1.228 + TEST2(len, TheTable2.ColSize(ii));
1.229 + RDbColReadStream strm1;
1.230 + strm1.OpenLC(TheTable1, ii);
1.231 + RDbColReadStream strm2;
1.232 + strm2.OpenLC(TheTable2, ii);
1.233 + TBuf8<512> buf1;
1.234 + TBuf8<512> buf2;
1.235 + while(len)
1.236 + {
1.237 + TInt block = Min(512, len);
1.238 + strm1.ReadL(buf1, block);
1.239 + strm2.ReadL(buf2, block);
1.240 + TEST(buf1 == buf2);
1.241 + len -= block;
1.242 + }
1.243 + CleanupStack::PopAndDestroy(2);
1.244 + }
1.245 + else
1.246 + {
1.247 + TEST(TheTable1.ColDes8(ii) == TheTable2.ColDes8(ii));
1.248 + }
1.249 + }
1.250 + }
1.251 + TheTable2.Close();
1.252 + TheTable1.Close();
1.253 + }
1.254 +
1.255 +void CheckL(const TDesC& aSource, const TDesC& aTarget)
1.256 + {
1.257 + TInt err = TheCompDb.Open(TheFs, aSource, KNullDesC, RDbNamedDatabase::EReadOnly);
1.258 + TEST2(err, KErrNone);
1.259 +
1.260 + err = TheCopyDb.Open(TheFs, aTarget, KNullDesC, RDbNamedDatabase::EReadOnly);
1.261 + TEST2(err, KErrNone);
1.262 +
1.263 + CDbTableNames* tables = TheCompDb.TableNamesL();
1.264 + for(TInt ii=0;ii<tables->Count();++ii)
1.265 + {
1.266 + CheckTableL(TheCompDb, TheCopyDb, (*tables)[ii]);
1.267 + }
1.268 + delete tables;
1.269 + TheCopyDb.Close();
1.270 + TheCompDb.Close();
1.271 + }
1.272 +
1.273 +/**
1.274 +@SYMTestCaseID SYSLIB-DBMS-CT-0593
1.275 +@SYMTestCaseDesc Database compression tests.
1.276 +@SYMTestPriority Medium
1.277 +@SYMTestActions Tests for RDbStoreDatabase::CompressL(),RDbStoreDatabase::DecompressL() functions
1.278 +@SYMTestExpectedResults Test must not fail
1.279 +@SYMREQ REQ0000
1.280 +*/
1.281 +void Test(const TDesC& aSource, const TDesC& aTarget, TBool aCompress)
1.282 + {
1.283 + TRAPD(err, CompressL(aSource, aTarget, aCompress));
1.284 + TEST2(err, KErrNone);
1.285 + TheTest.Printf(_L("Checking database"));
1.286 + TRAP(err, CheckL(aSource, aTarget));
1.287 + TEST2(err, KErrNone);
1.288 + }
1.289 +
1.290 +void DoTests()
1.291 + {
1.292 + TheTest.Start(_L(" @SYMTestCaseID:SYSLIB-DBMS-CT-0593 Compressing..."));
1.293 + Test(TheBenchDbFileName, TheCompressedFileName, ETrue);
1.294 +
1.295 + TheTest.Next(_L("Decompressing..."));
1.296 + Test(TheCompressedFileName, TheDecompressedFileName, EFalse);
1.297 + }
1.298 +
1.299 +//Usage: "t_comp [<drive letter>:]]"
1.300 +TInt E32Main()
1.301 + {
1.302 + TheTest.Title();
1.303 +
1.304 + CTrapCleanup* tc = CTrapCleanup::New();
1.305 + TheTest(tc != NULL);
1.306 +
1.307 + TBuf<256> cmdline;
1.308 + User::CommandLine(cmdline);
1.309 +
1.310 + TParse parse;
1.311 +
1.312 + _LIT(KBenchDbFile, "C:\\DBMS-TST\\T_BENCH.DB");
1.313 + parse.Set(cmdline, &KBenchDbFile, 0);
1.314 + TheBenchDbFileName.Copy(parse.FullName());
1.315 +
1.316 + _LIT(KCompressedFile, "C:\\DBMS-TST\\T_COMP.DB1");
1.317 + parse.Set(cmdline, &KCompressedFile, 0);
1.318 + TheCompressedFileName.Copy(parse.FullName());
1.319 +
1.320 + _LIT(KDecompressedFile, "C:\\DBMS-TST\\T_COMP.DB2");
1.321 + parse.Set(cmdline, &KDecompressedFile, 0);
1.322 + TheDecompressedFileName.Copy(parse.FullName());
1.323 +
1.324 + __UHEAP_MARK;
1.325 +
1.326 + CreateTestEnv();
1.327 + DoTests();
1.328 + DestroyTestEnv();
1.329 +
1.330 + delete tc;
1.331 +
1.332 + __UHEAP_MARKEND;
1.333 +
1.334 + TheTest.End();
1.335 + TheTest.Close();
1.336 +
1.337 + return 0;
1.338 + }