SqlTransaction 事物使用参数 SqlParameter 提交事物会不行? 20
stringSqlStr1=@"updateZtb_1setUserName=@UnamewhereId=@id";stringSqlStr2=@"updateZtb_2...
string SqlStr1 = @"update Ztb_1 set UserName = @Uname where Id = @id";
string SqlStr2 = @"update Ztb_2 set Jifen = @jifen where Id = @aid";
string[] SqlStrZu = new string[2];
SqlStrZu[0] = SqlStr1;
SqlStrZu[1] = SqlStr2;
SqlParameter[] SqlPara = { new SqlParameter("@Uname", "李四"), new SqlParameter("@id", 1), new SqlParameter("@jifen", "132"), new SqlParameter("@aid", 2) };
ZhiXing(SqlStrZu, SqlPara); //执行这个方法
private void ZhiXing(string[] SqlStr ,SqlParameter[] SqlPara)
{
SqlConnection Con = Zdb.ReturnCon();
Con.Open();
SqlTransaction Tran = Con.BeginTransaction();
SqlCommand Cmd = new SqlCommand();
Cmd.Connection = Con;
foreach (SqlParameter Npara in SqlPara)
{
Cmd.Parameters.Add(Npara);
}
Cmd.Transaction = Tran;
try
{
foreach (string NsqlStr in SqlStr)
{
Cmd.CommandText = NsqlStr;
Cmd.ExecuteNonQuery();
}
Tran.Commit(); // 没起作用,我故意输入错了一个语句,但是还是有个执行成功了,更新了数据表Ztb_1,我的表Ztb_2没有id 2所以没被更新 ,但是不对啊,应该2个都成功才能执行,有错误应该回滚才是,但是没有回滚。希望有高手来解答一下,指点一下。
}
catch
{
Tran.Rollback();
}
finally
{
Con.Close();
}
} 展开
string SqlStr2 = @"update Ztb_2 set Jifen = @jifen where Id = @aid";
string[] SqlStrZu = new string[2];
SqlStrZu[0] = SqlStr1;
SqlStrZu[1] = SqlStr2;
SqlParameter[] SqlPara = { new SqlParameter("@Uname", "李四"), new SqlParameter("@id", 1), new SqlParameter("@jifen", "132"), new SqlParameter("@aid", 2) };
ZhiXing(SqlStrZu, SqlPara); //执行这个方法
private void ZhiXing(string[] SqlStr ,SqlParameter[] SqlPara)
{
SqlConnection Con = Zdb.ReturnCon();
Con.Open();
SqlTransaction Tran = Con.BeginTransaction();
SqlCommand Cmd = new SqlCommand();
Cmd.Connection = Con;
foreach (SqlParameter Npara in SqlPara)
{
Cmd.Parameters.Add(Npara);
}
Cmd.Transaction = Tran;
try
{
foreach (string NsqlStr in SqlStr)
{
Cmd.CommandText = NsqlStr;
Cmd.ExecuteNonQuery();
}
Tran.Commit(); // 没起作用,我故意输入错了一个语句,但是还是有个执行成功了,更新了数据表Ztb_1,我的表Ztb_2没有id 2所以没被更新 ,但是不对啊,应该2个都成功才能执行,有错误应该回滚才是,但是没有回滚。希望有高手来解答一下,指点一下。
}
catch
{
Tran.Rollback();
}
finally
{
Con.Close();
}
} 展开
2个回答
展开全部
错在这里:
foreach (SqlParameter Npara in SqlPara)
{
Cmd.Parameters.Add(Npara);
}
Cmd.Parameters内有4个参数而下面的语句调用明显有问题
foreach (string NsqlStr in SqlStr)
{
Cmd.CommandText = NsqlStr;
Cmd.ExecuteNonQuery();
}
看你自己写的:
string SqlStr1 = @"update Ztb_1 set UserName = @Uname where Id = @id";
string SqlStr2 = @"update Ztb_2 set Jifen = @jifen where Id = @aid";
SqlStr1 只有2个参数,
SqlStr2 也只有2个参数,而Cmd.Parameters内有4个参数,能行吗>?
你改为下面的就ok了
string sqlAll= SqlStr1 +SqlStr2;
Cmd.CommandText = sqlAll;
Cmd.ExecuteNonQuery();
foreach (SqlParameter Npara in SqlPara)
{
Cmd.Parameters.Add(Npara);
}
Cmd.Parameters内有4个参数而下面的语句调用明显有问题
foreach (string NsqlStr in SqlStr)
{
Cmd.CommandText = NsqlStr;
Cmd.ExecuteNonQuery();
}
看你自己写的:
string SqlStr1 = @"update Ztb_1 set UserName = @Uname where Id = @id";
string SqlStr2 = @"update Ztb_2 set Jifen = @jifen where Id = @aid";
SqlStr1 只有2个参数,
SqlStr2 也只有2个参数,而Cmd.Parameters内有4个参数,能行吗>?
你改为下面的就ok了
string sqlAll= SqlStr1 +SqlStr2;
Cmd.CommandText = sqlAll;
Cmd.ExecuteNonQuery();
推荐律师服务:
若未解决您的问题,请您详细描述您的问题,通过百度律临进行免费专业咨询