使用NUnit进行并发测试
下面的代码将演示如何使用NUnit进行并发测试，启动多线程插入多个数据，并在插入完数据后删除数据
using System; using System.Collections.Generic; using System.Text; using NUnit.Framework; using WYEng.SQLServerDAL; using System.Threading; using System.Data; using System.Data.SqlClient;
namespace WYEng.TestUnit ...{ [TestFixture] public class ExamComputerInfo ...{ SQLServerDAL.ExamComputerInfo computerInfo; WYEng.Model.ExamComputerInfo mCompuerInfo; private int j = 0; private int computerID = 0; private string PARAM_COMPUTERID = "@ComputerID"; [SetUp] public void CreateObject() ...{ computerInfo = new WYEng.SQLServerDAL.ExamComputerInfo(); mCompuerInfo = new WYEng.Model.ExamComputerInfo(); TestGetComputerID(); }
[TearDown] public void DeleteObject() ...{ TestDeleteComputerInfo(); computerInfo = null; mCompuerInfo = null;
} private void TestGetComputerID() ...{ computerID = XPWY.DBUtility.DBHelperSQL.GetMaxID("ComputerID"， "ExamComputerInfo"); } private void TestDeleteComputerInfo() ...{ Console.WriteLine(computerID.ToString()); string strSql = "DELETE FROM ExamComputerInfo WHERE ComputerID>=@ComputerID"; SqlParameter pram = new SqlParameter(PARAM_COMPUTERID， SqlDbType.Int); pram.Value = computerID; XPWY.DBUtility.DBHelperSQL.ExecuteSql(strSql，pram); } [Test] [Ignore("为了测试并发插入的问题，屏蔽该方法")] public void GetComputerInfo() ...{ Thread[] threads = new Thread[1000]; for (int i = 0; i < 1000; i++) ...{ Thread t = new Thread(new ThreadStart(Func)); threads[i] = t; } for (int i = 0; i < 1000; i++) ...{ threads[i].Start(); }
} private void Func() ...{ mCompuerInfo = computerInfo.GetComputerInfo(1); Assert.AreEqual(mCompuerInfo.ComputerName， "YMF-XPWY"); } [Test] public void GetComputerInfoByMAC() ...{ mCompuerInfo = computerInfo.GetComputerInfoByMAC("00:1B:FC:64:6C:A3"); Assert.AreEqual(mCompuerInfo.ComputerName， "YMF-XPWY");//正常条件 mCompuerInfo = computerInfo.GetComputerInfoByMAC("00:sdfsdfsdf"); Assert.AreEqual(mCompuerInfo， null);//边界条件 }
[Test] public void TestInsertCPInfoWhileMorePeoper() ...{ Thread[] threads = new Thread[1000]; for (int i = 0; i < 1000; i++) ...{ j++; threads[i] = new Thread(new ThreadStart(TestInsertCPInfo)); threads[i].Start(); } } private void TestInsertCPInfo() ...{ mCompuerInfo.AudioDapater = j.ToString(); mCompuerInfo.BrowserInfo = j.ToString(); mCompuerInfo.ComputerName = "fw"; mCompuerInfo.EthernetAddress = "asdsad"; mCompuerInfo.ExamSeatNo = j; mCompuerInfo.IpAddress = "192.168.0.1"; mCompuerInfo.IsTestPassed = true; ; mCompuerInfo.NotPassedError = "yes"; mCompuerInfo.OSName = "OSName"; mCompuerInfo.OSVersion = "1.0.1"; computerInfo.InsertCPInfo(mCompuerInfo); } } }
