使用junit进行并发测试
2009-05-09 18:26
190 查看
下面的代码将演示如何使用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);
}
}
}
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);
}
}
}
相关文章推荐
- JUnit:使用ExpectedException进行异常测试
- 使用JUnit工具进行单元测试
- Spring整合JUnit框架进行单元测试代码使用详解
- 使用Ant进行Junit测试
- JUnit3 一次运行多个测试类和进行多次重复测试:使用测试套件和RepeatedTest
- Junit 实例精讲基础教程(三) 使用@Test(timeout=5000)模拟超时进行单元测试
- [转]使用 JUnit 对规则进行单元测试
- 使用Travis CI进行持续化集成(涉及Ant+Junit)
- 使用JUnit进行单元测试
- 无废话Android之android下junit测试框架配置、保存文件到手机内存、android下文件访问的权限、保存文件到SD卡、获取SD卡大小、使用SharedPreferences进行数据存储、使用Pull解析器操作XML文件、android下操作sqlite数据库和事务(2)
- java如何使用JUnit进行单元测试
- 使用Junit进行单元测试
- 【转】使用junit进行单元测试(初级篇)
- 使用junit进行接口测试的几个知识点
- Eclipse学习4-在Eclipse中使用JUnit进行单元测试(上)
- 使用Junit进行单元测试
- hibernate入门第五课 通过Hibernate API编写访问数据库代码并使用junit进行单元测试
- 对基于JUnit和Ant的测试用例执行过程使用Kieker(AspectJ)进行监控的方法
- (软件项目管理)在eclipse里使用junit进行单元测试以及Maven的学习
- Junit使用GroboUtils进行多线程测试