1.1 --- /dev/null Thu Jan 01 00:00:00 1970 +0000
1.2 +++ b/os/persistentdata/persistentstorage/dbms/tdbms/t_dbpanic.cpp Fri Jun 15 03:10:57 2012 +0200
1.3 @@ -0,0 +1,204 @@
1.4 +// Copyright (c) 2003-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 +
1.25 +LOCAL_D RTest test(_L("t_dbpanic - Panic test when cancelling two blobs transactions"));
1.26 +LOCAL_D CTrapCleanup* TheTrapCleanup;
1.27 +LOCAL_D RDbTable TheTables[2];
1.28 +LOCAL_D RFs TheFs;
1.29 +LOCAL_D RDbs TheDbs;
1.30 +LOCAL_D RDbNamedDatabase TheDatabase;
1.31 +
1.32 +const TPtrC KTestDatabase=_L("\\DBMS-TST\\T_PANIC.DB");
1.33 +
1.34 +/**
1.35 +@SYMTestCaseID SYSLIB-DBMS-CT-0641
1.36 +@SYMTestCaseDesc Tests for creating the database and tables
1.37 +@SYMTestPriority Medium
1.38 +@SYMTestActions Tests for creating the tables.Leave on error.
1.39 +@SYMTestExpectedResults Test must not fail
1.40 +@SYMREQ REQ0000
1.41 +*/
1.42 +LOCAL_C void PreTestL()
1.43 + {
1.44 + test.Next(_L(" @SYMTestCaseID:SYSLIB-DBMS-CT-0641 "));
1.45 + // Create the database:
1.46 + User::LeaveIfError(TheDatabase.Replace(TheFs,KTestDatabase));
1.47 + CleanupClosePushL(TheDatabase);
1.48 +
1.49 + // Create tables in the database:
1.50 + User::LeaveIfError(TheDatabase.Execute(_L("create table ta (a integer, b Long Varbinary)")));
1.51 + User::LeaveIfError(TheDatabase.Execute(_L("create table tb (a integer, b Long Varbinary)")));
1.52 +
1.53 + // Open the tables:
1.54 + User::LeaveIfError(TheTables[0].Open(TheDatabase, _L("ta")));
1.55 + CleanupClosePushL(TheTables[0]);
1.56 + User::LeaveIfError(TheTables[1].Open(TheDatabase, _L("tb")));
1.57 + CleanupClosePushL(TheTables[1]);
1.58 + }
1.59 +
1.60 +/**
1.61 +@SYMTestCaseID SYSLIB-DBMS-CT-0642
1.62 +@SYMTestCaseDesc Tests for transaction of large data
1.63 +@SYMTestPriority Medium
1.64 +@SYMTestActions Tests for streaming of blob data
1.65 +@SYMTestExpectedResults Test must not fail
1.66 +@SYMREQ REQ0000
1.67 +*/
1.68 +LOCAL_C void TestL()
1.69 + {
1.70 + test.Next(_L(" @SYMTestCaseID:SYSLIB-DBMS-CT-0642 "));
1.71 + // Start a transaction:
1.72 + TheDatabase.Begin();
1.73 +
1.74 + // Create a new row on each table:
1.75 + TheTables[0].InsertL();
1.76 + TheTables[1].InsertL();
1.77 +
1.78 + for(TInt i = 0; i < 2; ++i)
1.79 + {
1.80 + // Setting to null sets the dirty flag:
1.81 + TheTables[i].SetColNullL(1);
1.82 +
1.83 + // Create a blob of data:
1.84 + _LIT8(blobdata, "abcdefghijklmnopqrstuvwxyz");
1.85 + CBufFlat * blobbuff = CBufFlat::NewL(32);
1.86 + CleanupStack::PushL(blobbuff);
1.87 + blobbuff->InsertL(0, blobdata());
1.88 +
1.89 + // Open a read stream on the blob:
1.90 + RBufReadStream blobstream;
1.91 + blobstream.Open(*blobbuff, 0);
1.92 + CleanupClosePushL(blobstream);
1.93 +
1.94 + // Open a write stream on the table:
1.95 + RDbColWriteStream blobwrite;
1.96 + blobwrite.OpenLC(TheTables[i], 2);
1.97 +
1.98 + // Stream data from the read stream to the write stream:
1.99 + blobwrite.WriteL(blobstream);
1.100 + blobwrite.CommitL();
1.101 +
1.102 + // Close the write stream:
1.103 + CleanupStack::PopAndDestroy();
1.104 + // Close the read stream:
1.105 + CleanupStack::PopAndDestroy();
1.106 + // Delete the blob of data:
1.107 + CleanupStack::PopAndDestroy(blobbuff);
1.108 + }
1.109 +
1.110 + TheTables[0].Cancel();
1.111 + TheTables[1].Cancel(); //This call to cancel panics.
1.112 +
1.113 +
1.114 + // End the transaction:
1.115 + TheDatabase.Commit();
1.116 + }
1.117 +
1.118 +/**
1.119 +@SYMTestCaseID SYSLIB-DBMS-CT-0643
1.120 +@SYMTestCaseDesc Tests for closing of tables
1.121 +@SYMTestPriority Medium
1.122 +@SYMTestActions Tests for closing of tables and database
1.123 +@SYMTestExpectedResults Test must not fail
1.124 +@SYMREQ REQ0000
1.125 +*/
1.126 +LOCAL_C void PostTestL()
1.127 + {
1.128 + test.Next(_L(" @SYMTestCaseID:SYSLIB-DBMS-CT-0643 "));
1.129 + // Close the tables:
1.130 + TheTables[0].Close();
1.131 + CleanupStack::Pop(); // Table close
1.132 + TheTables[1].Close();
1.133 + CleanupStack::Pop(); // Table close
1.134 +
1.135 + // Close the database:
1.136 + CleanupStack::PopAndDestroy();
1.137 + }
1.138 +
1.139 +void doTestL()
1.140 + {
1.141 + test.Start(_L("bang"));
1.142 +
1.143 + // Open a connection to the DBMS server:
1.144 + User::LeaveIfError(TheDbs.Connect());
1.145 + CleanupClosePushL(TheDbs);
1.146 +
1.147 + PreTestL();
1.148 + TestL();
1.149 + PostTestL();
1.150 +
1.151 + CleanupStack::PopAndDestroy(); // TheDbs close
1.152 + }
1.153 +
1.154 +LOCAL_C void DeleteDataFile(const TDesC& aFullName)
1.155 + {
1.156 + RFs fsSession;
1.157 + TInt err = fsSession.Connect();
1.158 + if(err == KErrNone)
1.159 + {
1.160 + TEntry entry;
1.161 + if(fsSession.Entry(aFullName, entry) == KErrNone)
1.162 + {
1.163 + RDebug::Print(_L("Deleting \"%S\" file.\n"), &aFullName);
1.164 + err = fsSession.SetAtt(aFullName, 0, KEntryAttReadOnly);
1.165 + if(err != KErrNone)
1.166 + {
1.167 + RDebug::Print(_L("Error %d changing \"%S\" file attributes.\n"), err, &aFullName);
1.168 + }
1.169 + err = fsSession.Delete(aFullName);
1.170 + if(err != KErrNone)
1.171 + {
1.172 + RDebug::Print(_L("Error %d deleting \"%S\" file.\n"), err, &aFullName);
1.173 + }
1.174 + }
1.175 + fsSession.Close();
1.176 + }
1.177 + else
1.178 + {
1.179 + RDebug::Print(_L("Error %d connecting file session. File: %S.\n"), err, &aFullName);
1.180 + }
1.181 + }
1.182 +
1.183 +//
1.184 +// Test streaming conversions.
1.185 +//
1.186 +GLDEF_C TInt E32Main()
1.187 + {
1.188 + test.Title();
1.189 + TheTrapCleanup=CTrapCleanup::New();
1.190 +
1.191 + TInt r=TheFs.Connect();
1.192 + test(r==KErrNone);
1.193 + r=TheFs.MkDir(KTestDatabase);
1.194 + test(r==KErrNone || r==KErrAlreadyExists);
1.195 +
1.196 + TRAP(r, doTestL());
1.197 + test(r == KErrNone);
1.198 +
1.199 + ::DeleteDataFile(KTestDatabase);
1.200 +
1.201 + test.End();
1.202 +
1.203 + TheFs.Close();
1.204 + delete TheTrapCleanup;
1.205 + test.Close();
1.206 + return r;
1.207 + }