写了个单元测试辅助类，用于读取文本加入数据，删除数据和检查数据的
下面是数据文本文件的格式
“#”号是注释
“T：”是加入
“D：”是删除表里面的数据
“C：”是检查数据
数据与数据之间用TAB隔开（可以从企业管理器直接把数据拷贝出来作为数据源）
加入数据的事列如下：
#插入用户表
# null为插入空
T:Users
John <TAB>John chan
Cake<TAB>Cake.lu
jeff<TAB>jeff.hu
# CheckTable's Data
#null为检查是否为空，skip掉过不检查，notnull检查他是否不为空
C:Users
John <TAB>John chan
Cake<TAB>Cake.lu
jeff<TAB>jeff.hu
#Delete All Data
D：TAbleName
调用代码：
参数1：文本文件的路径
参数2：是Helper里面的两个常量（其实可以是个Enum，不过写的时候没有注意）
Helper.ExecuteAction('Data.txt',Helper.INSERT);
参数3：是指定对那个对象操作（T：D：C：后面的名称，如T:Users，那么就填Users）
Helper.ExecuteACtion('Data.txt',Helper.Insert,'Users')
代码如下：
using System;
using System.Data;
using System.IO;
using System.Data.SqlClient;
using Microsoft.ApplicationBlocks.Data;
using NUnit.Framework;
namespace TestCore
{
public class Helper
{
public const string DELETE='D';
public const string INSERT='T';
public const string CHECK='C';
public const string ANNOTATE='#';
public static string ConnectionString
{
//这里要写返回的连接字符串
get{return null;}
}
public static void ExecuteAction(string path,string action)
{
ExecuteAction(path,action,null);
}
public static void ExecuteAction(string path,string action,string inputTable)
{
Console.WriteLine('----------------'+action+' action is Start--------------------');
StreamReader reader=new StreamReader(path);
string line;
string table=null;
try
{
while(true)
{
line =reader.ReadLine();
if(line==null)
break;
if(line.Length==0)
continue;
string Key=line.Substring(0,1);
if(Key==action)
{
table=line.Substring(2);
if(action==DELETE)
{
if(CheckTable(inputTable,table))
{
Delete(table);
}
table=null;
}
else
{
continue;
}
}
else if(table!=null)
{
switch(action)
{
case INSERT:
if(CheckTable(inputTable,table))
{
string[] datas=line.Split('\t');
AddData(datas,table);
}
break;
case CHECK:
if(CheckTable(inputTable,table))
{
string[] checkDatas=line.Split('\t');
Check(checkDatas,table);
}
break;
}
table =null;
}
else
{
continue;
}
}
}
finally
{
Console.WriteLine('----------------'+action+' action is End--------------------');
reader.Close();
}
}
private static bool CheckTable(string inputTable,string SettingTable)
{
if(inputTable==null)
return true;
return (inputTable==SettingTable);
}
private static void Delete(string table)
{
string sql=' delete from '+table;
Console.WriteLine(sql);
try
{
SqlHelper.ExecuteNonQuery(ConnectionString,CommandType.Text,sql);
}
catch(Exception e)
{
throw new ApplicationException('删除错误:Sql是'+sql,e);
}
}
private static void AddData(string[] data,string table)
{
SqlConnection conn=new SqlConnection(ConnectionString);
string sql='insert into '+table+' values ';
string temp='(''+data[0]+''';
for(int i=1;i<data.Length;i++)
{
if(data[i]!='null')
temp+=',''+data[i]+''';
else
temp+=',null';
}
sql+=temp+')';
conn.Open();
try
{
Console.WriteLine(sql);
SqlCommand comm =new SqlCommand(sql,conn);
comm.ExecuteNonQuery();
}
catch(Exception e)
{
throw new ApplicationException(table+':'+sql,e);
}
finally
{
conn.Close();
}
}
private static void Check(string[] data,string table)
{
string sql='select * from '+table;
Console.WriteLine(sql);
DataSet ds = SqlHelper.ExecuteDataset(Helper.ConnectionString,CommandType.Text,sql);
DataTable dt=ds.Tables[0];
if(dt.Rows.Count==0)
throw new ArgumentOutOfRangeException( sql+' 返回结构为空');
foreach(DataRow dr in dt.Rows)
{
for(int i=0;i<data.Length;i++)
{
if(data[i].ToLower()=='skip')
continue;
if(data[i].ToLower()=='null')
{
Assert.IsTrue(dr[i].Equals(DBNull.Value),'expect is null ,but it's not null actualy');
continue;
}
if(data[i].ToLower()=='notnull')
{
Assert.IsFalse(dr[i].Equals(DBNull.Value),'expect isn't null but it's null actualy');
continue;
}
if(data[i].Length>=4 && data[i].Substring(0,4).ToLower()=='not:')
{
string txtValue=data[i].Substring(4).ToLower().Trim();
string dbValue=dr[i].ToString().ToLower().Trim();
Assert.IsTrue(txtValue!=dbValue,'db value is the same as data in text file,text file value is '+txtValue);
continue;
}
if(dr[i].ToString().Length!=0 || dr[i].Equals(DBNull.Value))
{
Assert.IsTrue(dr[i].ToString()==data[i],table+':Check Value Is '+data[i]+',but DB is '+dr[i]);
continue;
}
}
}
}
}
}
