public static Boolean ExecuteQuery(string ConnectionSql, string[] ExeuteSql)//这里有个sql 语句string数组
{
Boolean Rtn=true;
SqlConnection _SqlConn = new SqlConnection(ConnectionSql);
_SqlConn.Open();
SqlTransaction trans = _SqlConn.BeginTransaction();
try
{
foreach (string sql in ExeuteSql)
{
if (sql.Trim() != "")
{
ExecuteQueryEnd(_SqlConn, trans, sql);//执行下面的方法,到后面一起提交,防止出现有的提交有的不能提交的问题
}
else
{
continue;
}
}
trans.Commit();
}
catch (System.Data.SqlClient.SqlException e)
{
trans.Rollback();
Rtn = false;
throw new Exception(e.Message);
}
_SqlConn.Close();
return Rtn;
}
public static void ExecuteQueryEnd(SqlConnection conn, SqlTransaction str,string sqlcmd)
{
SqlCommand _Scmd = new SqlCommand(sqlcmd,conn);
_Scmd.Transaction = str;
_Scmd.CommandType = CommandType.Text;
_Scmd.CommandTimeout = 6000;
try
{
_Scmd.ExecuteNonQuery();
}
catch
{
str.Rollback();
} }
{
Boolean Rtn=true;
SqlConnection _SqlConn = new SqlConnection(ConnectionSql);
_SqlConn.Open();
SqlTransaction trans = _SqlConn.BeginTransaction();
try
{
foreach (string sql in ExeuteSql)
{
if (sql.Trim() != "")
{
ExecuteQueryEnd(_SqlConn, trans, sql);//执行下面的方法,到后面一起提交,防止出现有的提交有的不能提交的问题
}
else
{
continue;
}
}
trans.Commit();
}
catch (System.Data.SqlClient.SqlException e)
{
trans.Rollback();
Rtn = false;
throw new Exception(e.Message);
}
_SqlConn.Close();
return Rtn;
}
public static void ExecuteQueryEnd(SqlConnection conn, SqlTransaction str,string sqlcmd)
{
SqlCommand _Scmd = new SqlCommand(sqlcmd,conn);
_Scmd.Transaction = str;
_Scmd.CommandType = CommandType.Text;
_Scmd.CommandTimeout = 6000;
try
{
_Scmd.ExecuteNonQuery();
}
catch
{
str.Rollback();
} }
解决方案 »
免费领取超大流量手机卡,每月29元包185G流量+100分钟通话, 中国电信官方发货