工具类

public class TransactionHelper
    {
        private SqlConnection connection;
        private SqlTransaction myTrans;
        SqlCommand myCommand;
        public string connString = "服务器名；Initial Catalog = 数据库名；User ID = 用户名；Pwd = 密码（没有密码可以省略）";
        /// <summary>
        /// 初始化事务
        /// </summary>
        public TransactionHelper()
        {
            connection = new SqlConnection(connString);
            connection.Open();//打开链接
            //启动一个事务
            myTrans = connection.BeginTransaction();
            //为事务创建一个命令
            myCommand = new SqlCommand();
            myCommand.Connection = connection;
            myCommand.Transaction = myTrans;
            Console.WriteLine("Transaction Init");
        }
        /// <summary>
        /// 增删改操作
        /// </summary>
        /// <param name="sql"></param>
        /// <returns>影响的行数，-1为执行失败</returns>
        public int Update(string sql)
        {
            try
            {
                myCommand.CommandText = sql;
                int a = myCommand.ExecuteNonQuery();
                Console.WriteLine("Transaction Update:" + sql);
                return a;
            }

            catch (Exception ex)

            {

                myTrans.Rollback();//遇到错误，回滚
                connection.Close();
                Console.WriteLine(ex.ToString());
                return -1;
            }
        }
        /// <summary>
        /// 提交事务
        /// </summary>
        /// <returns></returns>
        public Boolean Commit()
        {
            try
            {
                myTrans.Commit();
                Console.WriteLine("Transaction Commit");
                return true;
            }
            catch (Exception ex)
            {
                myTrans.Rollback();//遇到错误，回滚
                Console.WriteLine(ex.ToString());
                return false;
            }
            finally
            {
                connection.Close();
            }
        }
        /// <summary>
        /// 回滚
        /// </summary>
        public void Rollback()
        {
            if (connection.State != System.Data.ConnectionState.Closed)
            {
                myTrans.Rollback();
                Console.WriteLine("Transaction Rollback");
                connection.Close();
            }
        }
    }

测试类

public class Class1
    {
        TransactionHelper transactionHelper=new TransactionHelper();
        public bool test()
        {
        	// 执行sql语句
            if (transactionHelper.Update("sql1") <= 0)
            {
                transactionHelper.Rollback();//回滚
                return false;
            }
            // 执行sql语句
            if (transactionHelper.Update("sql2") <= 0)
            {
                transactionHelper.Rollback();//回滚
                return false;
            }
            //判断其他业务逻辑，如：短信发送是否成功
            if (otherfunction())
            {
                transactionHelper.Rollback();//回滚
                return false;
            }
            transactionHelper.Commit();//提交
            return true;
        }
    }