using System;
using NUnit.Framework;
using System.EnterpriseServices;

namespace TransactionTest
{
    [TestFixture]
    [Transaction(TransactionOption.Required)]
    public class DatabaseFixture:ServicedComponent
    {
        [TearDown]
        public void TransactionTearDown()
        {
            if(ContextUtil.IsInTransaction)
            {
                ContextUtil.SetAbort();
            }
        }
    }
}

using System;
using NUnit.Framework;
using System.Data;
using System.Data.SqlClient;

namespace TransactionTest
{
    public class CategoryTests:DatabaseFixture
    {
        string CONN = @"Server=192.168.0.58\sun;Database=Northwind;uid=帐号;pwd=密码";

        [Test]
        public void InsertTest()
        {
            string categoryName = Insert("Test category");
            VerifyRowExists(categoryName, true);
        }

        [Test]
        public void DeleteTest()
        {
            string categoryName = Insert("Test category");
            Delete(categoryName);
            VerifyRowExists(categoryName, false);
        }

        /**//// <summary>
        /// 新增一条记录
        /// </summary>
        /// <param name="categoryName"></param>
        /// <returns></returns>
        private string Insert(string categoryName)
        {
            using (SqlConnection conn = new SqlConnection(CONN))
            {
                string strSQL = "Insert Categories (CategoryName) values('" + categoryName + "')";
                SqlCommand cmd = new SqlCommand(strSQL, conn);
                conn.Open();
                cmd.ExecuteNonQuery();
            }
            return categoryName;
        }

        /**//// <summary>
        /// 删除一条记录
        /// </summary>
        /// <param name="categoryName"></param>
        /// <returns></returns>
        private string Delete(string categoryName)
        {
            using (SqlConnection conn = new SqlConnection(CONN))
            {
                string strSQL = "Delete from Categories Where CategoryName='" + categoryName + "'";
                SqlCommand cmd = new SqlCommand(strSQL, conn);
                conn.Open();
                cmd.ExecuteNonQuery();
            }
            return categoryName;
        }

        /**//// <summary>
        /// 对执行的数据库操作进行验证
        /// </summary>
        /// <param name="categoryName"></param>
        /// <param name="shouldExist"></param>
        private void VerifyRowExists(string categoryName,bool shouldExist)
        {
            SqlConnection conn = new SqlConnection(CONN);
            conn.Open();

            string strSQL = "Select * from Categories where CategoryName='" + categoryName + "'";
            SqlCommand cmd = new SqlCommand(strSQL, conn);
            SqlDataReader dr = cmd.ExecuteReader(CommandBehavior.CloseConnection);
            Assert.AreEqual(shouldExist,dr.HasRows);
            dr.Close();
        }
    }
}