public bool ExecuteSqlsWithTransaction(string[] cmdTexts, Func<bool>[] funcs)
{
if (cmdTexts.Length == 0)
{
return false;
}

using (MySqlConnection connection = new MySqlConnection(connStr))
{
connection.Open();
MySqlTransaction trans = connection.BeginTransaction();
foreach (var sql in cmdTexts)
{
using (MySqlCommand cmd = new MySqlCommand(sql, connection, trans))
{
try
{
LoggerManager.Info(string.Format("执行SQL:{0}", sql));
int rows = cmd.ExecuteNonQuery();
if (rows != 1)
{
trans.Rollback();
LoggerManager.Error("批量执行sql语句失败，事务回滚", null);

return false;
}
LoggerManager.Info(string.Format("影响行数为:{0}", rows));
}
catch (Exception ex)
{
trans.Rollback();
LoggerManager.Error("批量执行sql语句失败，事务回滚", ex);
throw;
}
}
}

if (funcs != null)
{
foreach (Func<bool> func in funcs)
{
//执行方法失败,回滚事务
if (!func())
{
trans.Rollback();

LoggerManager.Error(string.Format("批量执行{0}操作失败，事务回滚", func.Method.Name), null);
return false;
}
}
}

trans.Commit();
LoggerManager.Info("批量执行sql语句成功，事务提交");
return true;
}
}

上面我写的这个方法只能执行没有参数的方法，如果有参数呢？我知道可以 Func<int,bool>[] funcs 可是如果参数数量和类型都不确定呢？我想写个通用的这种方法

ITPub博客

【求助】C#怎样控制SQL执行和移动文件在同一个事务执行

最新文章