Data Access and Transaction Handling Framework

using System;
using System.Threading;
using System.Diagnostics;
using NUnit.Framework;
using Framework.DataAccess;

namespace Framework.UnitTests
{
	/// <summary>
	/// Summary description for ThreadTests.
	/// </summary>
	[TestFixture]
	public class ThreadTests
	{
		private static int _numberOfThreads = 10;

		public ThreadTests() {}

		[Test]
		public void MultipleGetDefaultDataSource() 
		{
			Thread[] threads = new Thread[_numberOfThreads];

			FactoryTests tt = new FactoryTests();

			for (int i = 0; i < _numberOfThreads; i++) 
			{
				Thread t = new Thread(new ThreadStart(tt.GetDefaultDataSource));
				threads[i] = t;
				Debug.WriteLine("new thread:" + t.GetHashCode());
			}
			for (int i = 0; i < _numberOfThreads; i++) 
			{
				threads[i].Start();
			}
		}

		[Test]
		public void MultipleExecuteNonQuery() 
		{
			Thread[] threads = new Thread[_numberOfThreads];

			CommandTests tt = new CommandTests();

			for (int i = 0; i < _numberOfThreads; i++) 
			{
				Thread t = new Thread(new ThreadStart(tt.ExecuteNonQuery));
				threads[i] = t;
				Debug.WriteLine("new thread:" + t.GetHashCode());
			}
			for (int i = 0; i < _numberOfThreads; i++) 
			{
				threads[i].Start();
			}
		}

		[Test]
		public void MultipleRetrieveTestCommand1() 
		{
			Thread[] threads = new Thread[_numberOfThreads];

			CommandTests tt = new CommandTests();

			for (int i = 0; i < _numberOfThreads; i++) 
			{
				Thread t = new Thread(new ThreadStart(tt.RetrieveTestCommand1));
				threads[i] = t;
				Debug.WriteLine("new thread:" + t.GetHashCode());
			}
			for (int i = 0; i < _numberOfThreads; i++) 
			{
				threads[i].Start();
			}
		}

		[Test]
		public void MultipleExecuteReader() 
		{
			Thread[] threads = new Thread[_numberOfThreads];

			CommandTests tt = new CommandTests();

			for (int i = 0; i < _numberOfThreads; i++) 
			{
				Thread t = new Thread(new ThreadStart(tt.ExecuteReader));
				threads[i] = t;
				Debug.WriteLine("new thread:" + t.GetHashCode());
			}
			for (int i = 0; i < _numberOfThreads; i++) 
			{
				threads[i].Start();
			}
		}

		[Test]
		public void MultipleTransactionContexts() 
		{
			Thread[] threads = new Thread[_numberOfThreads];

			TransactionContextTests tct = new TransactionContextTests();

			for (int i = 0; i < _numberOfThreads; i++) 
			{
				Thread t = new Thread(new ThreadStart(tct.TestNestedContexts1));
				threads[i] = t;
				Debug.WriteLine("new thread:" + t.GetHashCode());
			}
			for (int i = 0; i < _numberOfThreads; i++) 
			{
				threads[i].Start();
			}
		}

		[Test]
		public void MultipleTransactionContextsWithDataAccess() 
		{
			Thread[] threads = new Thread[_numberOfThreads];

			TransactionContextTests tct = new TransactionContextTests();

			for (int i = 0; i < _numberOfThreads; i++) 
			{
				Thread t = new Thread(new ThreadStart(tct.TestNestedContextWithDataAccess1));
				threads[i] = t;
				Debug.WriteLine("new thread:" + t.GetHashCode());
			}
			for (int i = 0; i < _numberOfThreads; i++) 
			{
				threads[i].Start();
			}
		}

	}
}