1

public static class DataTableHelper
{
public static List ToModel(this DataTable dt) where T : class ,new()
{
if (dt == null || dt.Rows.Count == )
return null;
Type type = typeof(T);
var list = new List();
for (int row = ; row < dt.Rows.Count; row++)
{
Object obj = type.Assembly.CreateInstance(type.FullName);

            System.Reflection.PropertyInfo\[\] Props = typeof(T).GetProperties();

            for (int i = ; i < Props.Length; i++)  
            {  
                if (Props\[i\].CanWrite && dt.Columns.IndexOf(Props\[i\].Name) > -)  
                {  
                    Props\[i\].SetValue(obj, dt.Rows\[row\]\[Props\[i\].Name\], null);  
                }  
            }

            list.Add(obj as T);  
        }

        return list;  
    }  
}  
public class StudentModel  
{  
    public int Id { get; set; }  
    public string Name { get; set; }  
    public DateTime CreateTime { get; set; }  
}  
//数据库访问对象  
public class Studuent  
{  
    public static IList<StudentModel> GetList()  
    {  
        //不允许脏读  
        string sql = "SELECT Id,Name,CreateTime FROM Student ORDER BY Id DESC;";  
        DataTable dt = SqlHelper.Instance.ExecuteDataTable(CommandType.Text, sql);  
        return dt.ToModel<StudentModel>();  
    }

    public static bool Add(string name)  
    {  
        SqlParameter\[\] parms = {  
                                   new SqlParameter("@Name", SqlDbType.NVarChar, ) { Value = name },  
                                   new SqlParameter("@CreateTime", SqlDbType.DateTime) { Value = DateTime.Now }  
                               };  
        string sql = "INSERT INTO Student (Name,CreateTime) VALUES (@Name,@CreateTime)";  
        return SqlHelper.Instance.ExecuteNonQuery(CommandType.Text, sql, parms) > ;  
    }

    public static void Clear()  
    {  
        SqlHelper.Instance.ExecuteNonQuery("DELETE From Student");  
    }

    //公共方法，输出学生列表

}  
public class TransactionScopeTest  
{  
    static void PrintStudent()  
    {  
        IList<StudentModel> list = Studuent.GetList();  
        if (list == null)  
            return;  
        foreach (var item in list)  
        {  
            Console.WriteLine("{0}\\t{1}\\t{2}", Thread.CurrentThread.ManagedThreadId, item.Name, item.CreateTime);  
        }  
        Console.WriteLine();  
    }

    public static void Excute()  
    {  
        Studuent.Clear();  
        Task.Run(() =>  
        {  
            Console.WriteLine("开始添加用户");  
            using (TransactionScope scope = new TransactionScope())  
            {  
                Studuent.Add("Grace");  
                Studuent.Add("Aven");  
                scope.Complete();  
                //在Compltete已提交数据库  
                Console.WriteLine(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "Scope已提交");  
                Thread.Sleep( \* );  
            }

            //在作用范围外解除锁表  
            Console.WriteLine(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "scope已释放");  
        });  
        //PrintStudent();  
    }  
}