.NET事务处理使用示例

using (SqlConnection conn = new SqlConnection("server=(local);database=pubs;user id=sa;password=sa;"))
{
    conn.Open();
    //事务开始
    using (SqlTransaction trans = conn.BeginTransaction())
    {
        try
        {
            SqlCommand cmd = new SqlCommand();
            cmd.Connection = conn;
            cmd.CommandType = CommandType.Text;
            cmd.Transaction = trans;

            //添加
            cmd.CommandText = "Insert INTO test([name],[age]) VALUES('aaa',20)";
            cmd.ExecuteNonQuery();
            cmd.CommandText = "Insert INTO test([name],[age]) VALUES('bbb',21)";
            cmd.ExecuteNonQuery();
            cmd.CommandText = "Insert INTO test([name],[age]) VALUES('ccc',22)";
            cmd.ExecuteNonQuery();

            //throw new Exception("Error");

            //提交事务
            trans.Commit();

            Response.Write("ok");
        }
        catch(Exception ex)
        {
            //回滚事务
            trans.Rollback();
            Response.Write(ex.Message);
        }
    }
    conn.Close();
}


上一篇: DAL层返回IList示例
下一篇: C#预处理指令
文章来自: 本站原创
引用通告: 查看所有引用 | 我要引用此文章
Tags:
最新日志:
评论: 0 | 引用: 0 | 查看次数: 3316
发表评论
登录后再发表评论!