.NET的多种事务处理

Oracle 的事务操作，有时候想在批量操作数据集合的时候，执行一次失败，即为了避免数据异常，将所有的操作回滚。
.NET给我们提供了良好的事务操作，Oracle端也有事务操作，可以灵活使用，此处介绍.NET的事务。

1、.NET事务操作Oracle存储过程
public string insert_input_attach_info_moto(DataTable dt, string ass_code, string cust_model, string ship_date, string cust_name, string ship_city,
string ship_country, string po_cstname, string po_no, string chd_code, ref decimal batch_id)
{
string rtnMsg = "";                //存储过程返回信息
OracleConnection conn = (OracleConnection)DataBase.Provider.GetConnection();    //创建并开启 OracleConnection
conn.Open();
//启动事务
OracleTransaction tran = conn.BeginTransaction();
try
{
OracleCommand cmd = conn.CreateCommand();
cmd.Transaction = tran;         //绑定事务
cmd.CommandType = CommandType.StoredProcedure;
cmd.CommandText = "pkg_name.procedure_name";            //具体的方法

cmd.Parameters.AddWithValue("p_ass_code", ass_code);    //参数占位符
cmd.Parameters.AddWithValue("p_cust_model", cust_model);
cmd.Parameters.AddWithValue("p_ship_date", ship_date);
cmd.Parameters.AddWithValue("p_cust_name", cust_name);
cmd.Parameters.AddWithValue("p_ship_city", ship_city);

cmd.Parameters.AddWithValue("p_ship_country", ship_country);
cmd.Parameters.AddWithValue("p_po_cstname", po_cstname);
cmd.Parameters.AddWithValue("p_po_no", po_no);
cmd.Parameters.AddWithValue("p_chd_code", chd_code);
cmd.Parameters.AddWithValue("p_batch_id", batch_id);

cmd.Parameters.Add("p_msg", OracleType.VarChar, 100);

cmd.Parameters[10].Direction = ParameterDirection.Output;

foreach(DataRow row in dt.Rows)
{
cmd.Parameters[0].Value = row["SN"];          //此处是改变的参数，根据实际情况赋值
cmd.ExecuteNonQuery();
rtnMsg = cmd.Parameters[10].Value.ToString(); //每次执行的返回值,若出现异常，可以对此值判断，并确认是否回滚操作
}

tran.Commit();
}
catch (Exception ex)
{
tran.Rollback();
throw (ex);
}
finally
{
if (conn.State != ConnectionState.Closed)          //关闭链接，避免资源浪费
conn.Close();
}

return rtnMsg;

//对比无事务的
//OracleParameter[] paras = new OracleParameter[]
//{
//    new OracleParameter("p_ass_code", ass_code),
//    new OracleParameter("p_cust_model", cust_model),
//    new OracleParameter("p_ship_date", ship_date),
//    new OracleParameter("p_cust_name", cust_name),
//    new OracleParameter("p_ship_city", ship_city),

//    new OracleParameter("p_ship_country", ship_country),
//    new OracleParameter("p_po_cstname", po_cstname),
//    new OracleParameter("p_po_no", po_no),
//    new OracleParameter("p_chd_code", chd_code),
//    new OracleParameter("p_batch_id", batch_id),

//    new OracleParameter("p_msg", OracleType.VarChar, 100)
//};
//paras[10].Direction = ParameterDirection.Output;
//DataBase.Provider.ExecuteNonQuery(CommandType.StoredProcedure, @"pkg_name.procedure_name", paras);

//batch_id = Convert.ToDecimal(paras[9].Value);
//return paras[10].Value.ToString();
}

public string updateSuccessFlag(DataTable dt)
{
string rtnMsg = "";
OracleConnection conn = (OracleConnection)DataBase.Provider.GetConnection();
conn.Open();
//启动事务
OracleTransaction tran = conn.BeginTransaction();
try
{
OracleCommand cmd = conn.CreateCommand();
cmd.Transaction = tran;         //绑定事务
cmd.CommandType = CommandType.Text;
cmd.CommandText = @"UPDATE table_name d SET d.flag = 1 WHERE d.prodid = :prod_id";

cmd.Parameters.AddWithValue("prod_id", "");           //参数占位符

//cmd.Parameters.Add("p_msg", OracleType.VarChar, 100);
//cmd.Parameters[10].Direction = ParameterDirection.Output;

foreach (DataRow dr in dt.Rows)                      //动态参数,我们参数
{
cmd.Parameters["prod_id"].Value = Convert.ToString(dr["PRODID"]);
cmd.ExecuteNonQuery();
}
tran.Commit();
rtnMsg = "SUCCESS";
}
catch (Exception ex)
{
tran.Rollback();
throw (ex);
}
finally
{
if (conn.State != ConnectionState.Closed)
conn.Close();
}

return rtnMsg;
}

//SQL语句事务
//更新数据到SqlServer
public string UploadStbDataToHuaWei(DataTable dt)
{
string rtnMsg = "";
//获取链接，并开启链接
SqlConnection conn = (SqlConnection)DataBase.ProviderSQL.GetConnection();
conn.Open();
//启动事务
SqlTransaction tran = conn.BeginTransaction();
try
{
SqlCommand cmd = conn.CreateCommand();
cmd.Transaction = tran;         //绑定事务
cmd.CommandType = CommandType.Text;
cmd.CommandText = @"insert into [database_name].[dbo].[table_name] ([bar_code] ,[type] ,[stb_value],[created_date], [updated_date])
values(
@bar_code, @type, @stb_value, GETDATE(),
GETDATE())";

cmd.Parameters.AddWithValue("@bar_code", "");               //占位符
cmd.Parameters.AddWithValue("@type", "");
cmd.Parameters.AddWithValue("@stb_value", "");

foreach (DataRow dr in dt.Rows)
{
///cmd.Parameters.Add("@bar_code", SqlDbType.VarChar);  //输出             //SqlServer的事务
cmd.Parameters["@bar_code"].Value = Convert.ToString(dr["PRODID"]);
cmd.Parameters["@type"].Value = Convert.ToString(dr["TYPES"]);
cmd.Parameters["@stb_value"].Value = Convert.ToString(dr["VAL"]);
cmd.ExecuteNonQuery();
}
tran.Commit();
rtnMsg = "SUCCESS";
}
catch (Exception ex)
{
tran.Rollback();
throw (ex);
}
finally
{
if (conn.State != ConnectionState.Closed)
conn.Close();
}
return rtnMsg;
}
-------------------------------------------------------------------------------------------------------
//事务的一般写法和逻辑
SqlConnection conn = DataBase.Provider.GetConnection() as OracleConnection;
//OracleCommand cmd = conn.CreateCommand();
conn.Open();
//...创建数据库连接 cnn
System.Data.SqlClient.SqlTransaction trans = cnn.BeginTransaction();
try
{
foreach (DataRow dr in dt.Rows)
{
cm.CommandText = "update   [表]   set   [数量]   =   @amount   where   productID   =   @productID";
cm.Parameters.Add("@amount", SqlDbType.Int);
cm.Parameters["@amount"].Value = Convert.ToInt32(dr["amount"]);
cm.Parameters.Add("@productID", SqlDbType.VarChar);
cm.Parameters["@productID"].Value = dr["productID"].ToString();
cm.ExecuteNonQuery();
}
trans.Commit();
}
catch
{
trans.Rollback();
}

分享共进步
谢谢阅读！