// Copyright (c) 2003-2009 Nokia Corporation and/or its subsidiary(-ies).

 // All rights reserved.

 // This component and the accompanying materials are made available

 // under the terms of "Eclipse Public License v1.0"

 // which accompanies this distribution, and is available

 // at the URL "http://www.eclipse.org/legal/epl-v10.html".

 //

 // Initial Contributors:

 // Nokia Corporation - initial contribution.

 //

 // Contributors:

 //

 // Description:

 //

 #include <d32dbms.h>

 #include <s32file.h>

 #include <e32test.h>

 #include <e32math.h>

 #include <s32mem.h>

 LOCAL_D RTest test(_L("t_dbpanic - Panic test when cancelling two blobs transactions"));

 LOCAL_D CTrapCleanup* TheTrapCleanup;

 LOCAL_D RDbTable TheTables[2];

 LOCAL_D RFs TheFs;

 LOCAL_D RDbs TheDbs;

 LOCAL_D RDbNamedDatabase TheDatabase;

 const TPtrC KTestDatabase=_L("\\DBMS-TST\\T_PANIC.DB");

 /**

 @SYMTestCaseID          SYSLIB-DBMS-CT-0641

 @SYMTestCaseDesc        Tests for creating the database and tables

 @SYMTestPriority        Medium

 @SYMTestActions         Tests for creating the tables.Leave on error.

 @SYMTestExpectedResults Test must not fail

 @SYMREQ                 REQ0000

 */

 LOCAL_C void PreTestL()

 	{

 	test.Next(_L(" @SYMTestCaseID:SYSLIB-DBMS-CT-0641 "));

 	// Create the database:

 	User::LeaveIfError(TheDatabase.Replace(TheFs,KTestDatabase));

 	CleanupClosePushL(TheDatabase);

 	// Create tables in the database:

 	User::LeaveIfError(TheDatabase.Execute(_L("create table ta (a integer, b Long Varbinary)")));

 	User::LeaveIfError(TheDatabase.Execute(_L("create table tb (a integer, b Long Varbinary)")));

 	// Open the tables:

 	User::LeaveIfError(TheTables[0].Open(TheDatabase, _L("ta")));

 	CleanupClosePushL(TheTables[0]);

 	User::LeaveIfError(TheTables[1].Open(TheDatabase, _L("tb")));

 	CleanupClosePushL(TheTables[1]);

 	}

 /**

 @SYMTestCaseID          SYSLIB-DBMS-CT-0642

 @SYMTestCaseDesc        Tests for transaction of large data

 @SYMTestPriority        Medium

 @SYMTestActions         Tests for streaming of blob data

 @SYMTestExpectedResults Test must not fail

 @SYMREQ                 REQ0000

 */

 LOCAL_C void TestL()

 	{

 	test.Next(_L(" @SYMTestCaseID:SYSLIB-DBMS-CT-0642 "));

 	// Start a transaction:

 	TheDatabase.Begin();

 	// Create a new row on each table:

 	TheTables[0].InsertL();

 	TheTables[1].InsertL();

 	for(TInt i = 0; i < 2; ++i)

 		{

 		// Setting to null sets the dirty flag:

 		TheTables[i].SetColNullL(1);

 		// Create a blob of data:

 		_LIT8(blobdata, "abcdefghijklmnopqrstuvwxyz");

 		CBufFlat * blobbuff = CBufFlat::NewL(32);

 		CleanupStack::PushL(blobbuff);

 		blobbuff->InsertL(0, blobdata());

 		// Open a read stream on the blob:

 		RBufReadStream blobstream;

 		blobstream.Open(*blobbuff, 0);

 		CleanupClosePushL(blobstream);

 		// Open a write stream on the table:

 		RDbColWriteStream blobwrite;

 		blobwrite.OpenLC(TheTables[i], 2);

 		// Stream data from the read stream to the write stream:

 		blobwrite.WriteL(blobstream);

 		blobwrite.CommitL();

 		// Close the write stream:

 		CleanupStack::PopAndDestroy();

 		// Close the read stream:

 		CleanupStack::PopAndDestroy();

 		// Delete the blob of data:

 		CleanupStack::PopAndDestroy(blobbuff);

 		}

 	TheTables[0].Cancel();

 	TheTables[1].Cancel(); //This call to cancel panics.

 	// End the transaction:

 	TheDatabase.Commit();

 	}

 /**

 @SYMTestCaseID          SYSLIB-DBMS-CT-0643

 @SYMTestCaseDesc        Tests for closing of tables

 @SYMTestPriority        Medium

 @SYMTestActions         Tests for closing of tables and database

 @SYMTestExpectedResults Test must not fail

 @SYMREQ                 REQ0000

 */

 LOCAL_C void PostTestL()

 	{

 	test.Next(_L(" @SYMTestCaseID:SYSLIB-DBMS-CT-0643 "));

 	// Close the tables:

 	TheTables[0].Close();

 	CleanupStack::Pop(); // Table close

 	TheTables[1].Close();

 	CleanupStack::Pop(); // Table close

 	// Close the database:

 	CleanupStack::PopAndDestroy();

 	}

 void doTestL()

 	{

 	test.Start(_L("bang"));

 	// Open a connection to the DBMS server:

 	User::LeaveIfError(TheDbs.Connect());

 	CleanupClosePushL(TheDbs);

 	PreTestL();

 	TestL();

 	PostTestL();

 	CleanupStack::PopAndDestroy(); // TheDbs close

 	}

 LOCAL_C void DeleteDataFile(const TDesC& aFullName)

 	{

 	RFs fsSession;

 	TInt err = fsSession.Connect();

 	if(err == KErrNone)

 		{

 		TEntry entry;

 		if(fsSession.Entry(aFullName, entry) == KErrNone)

 			{

 			RDebug::Print(_L("Deleting \"%S\" file.\n"), &aFullName);

 			err = fsSession.SetAtt(aFullName, 0, KEntryAttReadOnly);

 			if(err != KErrNone)

 				{

 				RDebug::Print(_L("Error %d changing \"%S\" file attributes.\n"), err, &aFullName);

 				}

 			err = fsSession.Delete(aFullName);

 			if(err != KErrNone)

 				{

 				RDebug::Print(_L("Error %d deleting \"%S\" file.\n"), err, &aFullName);

 				}

 			}

 		fsSession.Close();

 		}

 	else

 		{

 		RDebug::Print(_L("Error %d connecting file session. File: %S.\n"), err, &aFullName);

 		}

 	}

 //

 // Test streaming conversions.

 //

 GLDEF_C TInt E32Main()

     {

 	test.Title();

 	TheTrapCleanup=CTrapCleanup::New();

 	TInt r=TheFs.Connect();

 	test(r==KErrNone);

 	r=TheFs.MkDir(KTestDatabase);

 	test(r==KErrNone || r==KErrAlreadyExists);

 	TRAP(r, doTestL());

 	test(r == KErrNone);

 	::DeleteDataFile(KTestDatabase);

 	test.End();

 	TheFs.Close();

 	delete TheTrapCleanup;

 	test.Close();

 	return r;

     }