Facilities/IBatisNet/Castle.Facilities.IBatisNetIntegration.Tests/DaoTestCase.cs

   1 #region License
   2
   3 // Copyright 2004-2008 Castle Project - http://www.castleproject.org/
   4 //
   5 // Licensed under the Apache License, Version 2.0 (the "License");
   6 // you may not use this file except in compliance with the License.
   7 // You may obtain a copy of the License at
   8 //
   9 //     http://www.apache.org/licenses/LICENSE-2.0
  10 //
  11 // Unless required by applicable law or agreed to in writing, software
  12 // distributed under the License is distributed on an "AS IS" BASIS,
  13 // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  14 // See the License for the specific language governing permissions and
  15 // limitations under the License.
  16 //
  17 //  --
  18 //
  19 //  This facility was a contribution kindly
  20 //  donated by Gilles Bayon <gilles.bayon@gmail.com>
  21 //
  22 //  --
  23
  24 #endregion
  25
  26 namespace Castle.Facilities.IBatisNetIntegration.Tests
  27 {
  28         using System;
  29         using System.Threading;
  30         using Castle.Facilities.AutomaticTransactionManagement;
  31         using Castle.Facilities.IBatisNetIntegration.Tests.Dao;
  32         using Castle.Facilities.IBatisNetIntegration.Tests.Domain;
  33         using NUnit.Framework;
  34
  35         [TestFixture]
  36         public class DaoTestCase : AbstractIBatisNetTestCase
  37         {
  38                 private ManualResetEvent _startEvent = new ManualResetEvent(false);
  39                 private ManualResetEvent _stopEvent = new ManualResetEvent(false);
  40                 private IAccountDao _dao = null;
  41
  42                 [Test]
  43                 public void CommonUsage()
  44                 {
  45                         container = CreateConfiguredContainer();
  46                         container.AddFacility("IBatisNet", new IBatisNetFacility());
  47
  48                         container.AddComponent("AccountDao", typeof (IAccountDao), typeof (AccountDao));
  49
  50                         ResetDatabase();
  51
  52                         IAccountDao dao = container["AccountDao"] as AccountDao;
  53                         Account account = new Account();
  54                         account.Id = 99;
  55                         account.EmailAddress = "ibatis@somewhere.com";
  56                         account.FirstName = "Gilles";
  57                         account.LastName = "Bayon";
  58
  59                         dao.InsertAccount(account);
  60                         account = null;
  61                         account = dao.GetAccount(99) as Account;
  62
  63                         Assert.IsNotNull(account);
  64                         Assert.AreEqual(99, account.Id, "account.Id");
  65                 }
  66
  67                 [Test]
  68                 public void CommonUsageMultithread()
  69                 {
  70                         container = CreateConfiguredContainer();
  71                         container.AddFacility("IBatisNet", new IBatisNetFacility());
  72
  73                         container.AddComponent("AccountDao", typeof (IAccountDao), typeof (AccountDao));
  74
  75                         ResetDatabase();
  76
  77                         _dao = container["AccountDao"] as AccountDao;
  78
  79                         const int threadCount = 10;
  80
  81                         Thread[] threads = new Thread[threadCount];
  82
  83                         for (int i = 0; i < threadCount; i++)
  84                         {
  85                                 threads[i] = new Thread(new ThreadStart(ExecuteMethodUntilSignal));
  86                                 threads[i].Start();
  87                         }
  88
  89                         _startEvent.Set();
  90
  91                         Thread.CurrentThread.Join(1*2000);
  92
  93                         _stopEvent.Set();
  94                 }
  95
  96                 public void ExecuteMethodUntilSignal()
  97                 {
  98                         Random _random = new Random();
  99                         _startEvent.WaitOne(int.MaxValue, false);
 100
 101                         while (!_stopEvent.WaitOne(1, false))
 102                         {
 103                                 int id = _random.Next();
 104                                 Account account = new Account();
 105                                 account.Id = id;
 106                                 account.EmailAddress = "ibatis@somewhere.com";
 107                                 account.FirstName = "Gilles";
 108                                 account.LastName = "Bayon";
 109
 110                                 _dao.InsertAccount(account);
 111                                 account = null;
 112                                 account = _dao.GetAccount(id);
 113                                 Assert.IsNotNull(account);
 114                         }
 115                 }
 116
 117                 [Test]
 118                 public void TransactionalUsageMultithread()
 119                 {
 120                         container = CreateConfiguredContainer();
 121                         container.AddFacility("IBatisNet", new IBatisNetFacility());
 122                         container.AddFacility("transaction", new TransactionFacility());
 123
 124                         container.AddComponent("AccountDao", typeof (IAccountDao), typeof (AccountDao));
 125
 126                         _dao = container["AccountDao"] as AccountDao;
 127
 128                         const int threadCount = 10;
 129
 130                         Thread[] threads = new Thread[threadCount];
 131
 132                         for (int i = 0; i < threadCount; i++)
 133                         {
 134                                 threads[i] = new Thread(new ThreadStart(ExecuteMethodUntilSignal));
 135                                 threads[i].Start();
 136                         }
 137
 138                         _startEvent.Set();
 139
 140                         Thread.CurrentThread.Join(1*2000);
 141
 142                         _stopEvent.Set();
 143                 }
 144         }
 145 }