c# 事务处理
1 创建一个connection
string connstr = ConfigurationManager.ConnectionStrings["default"].ConnectionString;
SqlConnection sqlconn = new SqlConnection(connstr);
2 创建一个command 连接到 connection上
SqlCommand cmd = new SqlCommand();
cmd.Connection = sqlconn;
3 创建一个 transaction 当 connection 打开的时候将事务和connection 绑定 然后将transaction也和command绑定
SqlTransaction sqltran;
sqlconn.Open();
sqltran = sqlconn.BeginTransaction();
cmd.Transaction = sqltran;
4 处理
try
{
StreamReader sr = new StreamReader(postedFile.InputStream);
string headLine = sr.ReadLine();
headLine = headLine.Replace(";", "],[");
headLine = "[" + headLine + "]";
int lineNumber = 1;
while (!sr.EndOfStream)
{
string saleDataLine = sr.ReadLine();
//rdLine = rdLine.Replace("N/A", "null");
saleDataLine = saleDataLine.Replace("'", "''");
saleDataLine = saleDataLine.Replace(";", "','");
string command = "insert into SalesUploadTest (" + headLine + ") values ('" + saleDataLine + "')";
cmd.CommandText = command;
cmd.CommandType = CommandType.Text;
cmd.ExecuteNonQuery();
lineNumber++;
}
sqltran.Commit();
}
catch (Exception)
{
sqltran.Rollback();
}
finally
{
cmd.Dispose();
sqlconn.Close();
}
