【C#】关于数据操作的回滚

admin

SqlCommand cmd = con.CreateCommand();
SqlTransaction transaction;
transaction=con.BeginTransaction();
cmd.Connection = con;

try
{
    string re = "";

    cmd.CommandText = "SELECT * FROM HD_Partner WHERE HD_User_ID=" + UserID;
    SqlDataAdapter da = new SqlDataAdapter(cmd.CommandText, con);
    SqlCommandBuilder cb = new SqlCommandBuilder(da);
    da.SelectCommand.Transaction = transaction;
    DataTable dt = new DataTable("HD_Parter");
    da.Fill(dt);
    DataRow dr;
    if (dt.Rows.Count == 0)
    {
        dr = dt.NewRow();
    }
    else
    {
        dr = dt.Rows[0];
    }
    dr["HD_User_ID"] = UserID;
    dr["HD_Partner_ID"] = partnerid;
    if (dt.Rows.Count == 0)
    {
        dt.Rows.Add(dr);
        da.Update(dt);
    }
    else
    {
        da.Update(dt);
        dt.AcceptChanges();
    }
    dt.Dispose();
    da.Dispose();
    cmd.CommandText = "UPDATE HD_User SET HD_Partner_ID=" + partnerid + " WHERE HD_ID=" + UserID;
    cmd.Transaction = transaction;
    cmd.ExecuteNonQuery();
    cmd.Dispose();

    transaction.Commit();
    re = "{\"stat\":\"ok\",\"msg\":\"提交成功！\"}";
    return re;
}
catch (Exception e)
{
    transaction.Rollback();
    return "{\"stat\":\"err\",\"msg\":\"提交失败(" + e.Message + ")！\"}";
}