1.1 --- /dev/null Thu Jan 01 00:00:00 1970 +0000
1.2 +++ b/os/persistentdata/persistentstorage/sqlite3api/TEST/t_sqlitewsd.cpp Fri Jun 15 03:10:57 2012 +0200
1.3 @@ -0,0 +1,221 @@
1.4 +// Copyright (c) 2007-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 <e32test.h>
1.20 +#include <e32uid.h>
1.21 +#include <f32file.h>
1.22 +#include <e32math.h>
1.23 +#include <sqlite3.h>
1.24 +#include "t_sqlitewsd.h"
1.25 +#include "sqliteTestUtl.h"
1.26 +
1.27 +#include <spawn.h>
1.28 +#include <sys/wait.h>
1.29 +
1.30 +///////////////////////////////////////////////////////////////////////////////////////
1.31 +
1.32 +const char* const KTestName = "t_sqlitewsd";
1.33 +static RFs TheFs;
1.34 +
1.35 +static pid_t TheKSqliteWsdProc2Pid = 0;
1.36 +const char* KSqliteWsdProc2Name = "z:\\sys\\bin\\t_sqlitewsd2.exe";
1.37 +
1.38 +const char* KTestDir = "c:\\test\\";
1.39 +const char* KTestDb = "c:\\test\\t_sqlitewsd.db";
1.40 +
1.41 +sqlite3* TheDb = 0;
1.42 +
1.43 +///////////////////////////////////////////////////////////////////////////////////////
1.44 +
1.45 +static void DestroyTestEnv()
1.46 + {
1.47 + if(TheDb)
1.48 + {
1.49 + (void)sqlite3_close(TheDb);
1.50 + TheDb = 0;
1.51 + }
1.52 + if(TheFs.Handle() != KNullHandle)
1.53 + {
1.54 + TFileName fname;
1.55 + fname.Copy(TPtrC8((const TUint8*)KTestDb));
1.56 + (void)TheFs.Delete(fname);
1.57 + }
1.58 + TheFs.Close();
1.59 + }
1.60 +
1.61 +///////////////////////////////////////////////////////////////////////////////////////
1.62 +
1.63 +//Test macros and functions
1.64 +void Check(TInt aValue, TInt aLine)
1.65 + {
1.66 + if(!aValue)
1.67 + {
1.68 + DestroyTestEnv();
1.69 + TestTestLine(EFalse, aLine);
1.70 + }
1.71 + }
1.72 +
1.73 +void Check(TInt aValue, TInt aExpected, TInt aLine)
1.74 + {
1.75 + if(aValue != aExpected)
1.76 + {
1.77 + RDebug::Print(_L("*** Expected error: %d, got: %d\r\n"), aExpected, aValue);
1.78 + const char* errMsg = sqlite3_errmsg(TheDb);
1.79 + if(errMsg)
1.80 + {
1.81 + TBuf<200> msgBuf;
1.82 + msgBuf.Copy(TPtrC8((const TUint8*)errMsg));
1.83 + RDebug::Print(_L("*** SQLITE error msg: \"%S\".\r\n"), &msgBuf);
1.84 + }
1.85 + DestroyTestEnv();
1.86 + TestTestLine(EFalse, aLine);
1.87 + }
1.88 + }
1.89 +
1.90 +///////////////////////////////////////////////////////////////////////////////////////
1.91 +
1.92 +static void CreateTestEnv()
1.93 + {
1.94 + TInt err = TheFs.Connect();
1.95 + TEST2(err, KErrNone);
1.96 +
1.97 + TFileName testDir;
1.98 + testDir.Copy(TPtrC8((const TUint8*)KTestDir));
1.99 + err = TheFs.MkDir(testDir);
1.100 + TEST(err == KErrNone || err == KErrAlreadyExists);
1.101 +
1.102 + TFileName fname;
1.103 + fname.Copy(TPtrC8((const TUint8*)KTestDb));
1.104 + (void)TheFs.Delete(fname);
1.105 +
1.106 + err = sqlite3_open(KTestDb, &TheDb);
1.107 + TEST2(err, SQLITE_OK);
1.108 + TEST(TheDb != 0);
1.109 + }
1.110 +
1.111 +///////////////////////////////////////////////////////////////////////////////////////
1.112 +
1.113 +static void CreateDb()
1.114 + {
1.115 + TEST(TheDb != 0);
1.116 + TInt err = sqlite3_exec(TheDb, "CREATE TABLE A(F1 INTEGER)", 0, 0, 0);
1.117 + TEST2(err, SQLITE_OK);
1.118 + }
1.119 +
1.120 +static void RunSqliteWsd2()
1.121 + {
1.122 + TInt err = posix_spawn(&TheKSqliteWsdProc2Pid, KSqliteWsdProc2Name, 0, 0, 0, 0);
1.123 + TEST2(err, 0);
1.124 + }
1.125 +
1.126 +static void DestroySqliteWsd2()
1.127 + {
1.128 + (void)waitpid(TheKSqliteWsdProc2Pid, 0, 0);
1.129 + }
1.130 +
1.131 +void DoVerify()
1.132 + {
1.133 + sqlite3_stmt* stmt = 0;
1.134 + const char* tail = 0;
1.135 + TInt err = sqlite3_prepare(TheDb, "SELECT * FROM A", -1, &stmt, &tail);
1.136 + TEST2(err, SQLITE_OK);
1.137 + TEST(!tail || tail[0] == 0);
1.138 + TInt proc1Id1recCnt = 0;
1.139 + TInt proc1Id2recCnt = 0;
1.140 + TInt proc2Id1recCnt = 0;
1.141 + TInt proc2Id2recCnt = 0;
1.142 + while((err = sqlite3_step(stmt)) == SQLITE_ROW)
1.143 + {
1.144 + TInt val = sqlite3_column_int(stmt, 0);
1.145 + switch(val)
1.146 + {
1.147 + case KWsdProc1RecId1:
1.148 + ++proc1Id1recCnt;
1.149 + break;
1.150 + case KWsdProc1RecId2:
1.151 + ++proc1Id2recCnt;
1.152 + break;
1.153 + case KWsdProc2RecId1:
1.154 + ++proc2Id1recCnt;
1.155 + break;
1.156 + case KWsdProc2RecId2:
1.157 + ++proc2Id2recCnt;
1.158 + break;
1.159 + default:
1.160 + TEST(0);
1.161 + break;
1.162 + }
1.163 + }
1.164 + sqlite3_finalize(stmt);
1.165 + TEST2(err, SQLITE_DONE);
1.166 + TEST2((proc1Id1recCnt + proc1Id2recCnt), KTestRecordCnt);
1.167 + TEST2((proc2Id1recCnt + proc2Id2recCnt), KTestRecordCnt);
1.168 + }
1.169 +
1.170 +/**
1.171 +@SYMTestCaseID SYSLIB-SQLITE3-UT-4026
1.172 +@SYMTestCaseDesc SQLITE OS porting layer - WSD test.
1.173 + The test verifies that the WSD object allocation and access inside the OS porting layer
1.174 + works properly on both the emulator and the hardware.
1.175 + The test runs two separate processes. Each process establishes a connection to the same
1.176 + database and inserts 500 records simultaneously.
1.177 + During the inserts, the SQLITE OS porting layer will use a mutex to synchronise the database
1.178 + operations between the two processes. If the WSD implementation does not work properly,
1.179 + then the mutex object won't be allocated per process and the same mutex instance will be used by
1.180 + both processes on the emulator. This will lead to panics/asserts inside the OS porting layer.
1.181 + The number of the inserted record and record ids is verified at the end of the test.
1.182 +@SYMTestPriority High
1.183 +@SYMTestActions SQLITE OS porting layer - WSD test.
1.184 +@SYMTestExpectedResults Test must not fail
1.185 +@SYMREQ REQ8782
1.186 +*/
1.187 +static void DoWsdTests()
1.188 + {
1.189 + TestStart(" @SYMTestCaseID:SYSLIB-SQLITE3-UT-4026 Create the test database ");
1.190 + CreateDb();
1.191 + TestNext("Run the second process: t_sqlitewsd2");
1.192 + RunSqliteWsd2();
1.193 + TestNext("Insert the records");
1.194 + DoInserts(KWsdProc1Id, KWsdProc1RecId1, KWsdProc1RecId2);
1.195 + DestroySqliteWsd2();
1.196 + TestNext("Verify the inserted records");
1.197 + DoVerify();
1.198 + }
1.199 +
1.200 +///////////////////////////////////////////////////////////////////////////////////////
1.201 +
1.202 +TInt E32Main()
1.203 + {
1.204 + TestOpen(KTestName);
1.205 + TestTitle();
1.206 +
1.207 + CTrapCleanup* tc = CTrapCleanup::New();
1.208 +
1.209 + __UHEAP_MARK;
1.210 +
1.211 + CreateTestEnv();
1.212 + DoWsdTests();
1.213 + DestroyTestEnv();
1.214 +
1.215 + __UHEAP_MARKEND;
1.216 +
1.217 + TestEnd();
1.218 + TestClose();
1.219 +
1.220 + delete tc;
1.221 +
1.222 + User::Heap().Check();
1.223 + return KErrNone;
1.224 + }