diff --git a/插件库/Lskj.Core/SqlHelper.cs b/插件库/Lskj.Core/SqlHelper.cs index 691a4fa..84fa694 100644 --- a/插件库/Lskj.Core/SqlHelper.cs +++ b/插件库/Lskj.Core/SqlHelper.cs @@ -43,6 +43,12 @@ namespace Lskj.Core /// 请求超时时间 /// public static int CommandTimeout; + + /// + /// 上一次失败的sql + /// + public static string LastFailureSql; + /// /// 说明:是否已经连接数据库 /// 创建者:朗速科技有限公司 @@ -251,6 +257,7 @@ namespace Lskj.Core /// DataSet. public static DataSet ExecuteDataSet(CommandType cmdType, string cmdText, string tabName, params DbParameter[] commandParameters) { + LastFailureSql = string.Empty; DataSet set2; DbCommand cmd = dbFactory.CreateCommand(); try @@ -276,8 +283,10 @@ namespace Lskj.Core sqlParameter.Value = resultTable.Rows[0][$"outputValue{i}"]; } } + if (returnValue + "" == "-1") LastFailureSql = cmd.CommandText; } //adapter.FillSchema(dataSet, SchemaType.Mapped, tabName); + set2 = dataSet; } catch (Exception e) @@ -339,6 +348,7 @@ namespace Lskj.Core /// DataSet. public static DataSet ExecuteDataSet(string procedureName, string tabName, string[] parameterNames, DbParameter[] parameterValues) { + LastFailureSql = string.Empty; DataSet set2; try { @@ -375,6 +385,7 @@ namespace Lskj.Core sqlParameter.Value = resultTable.Rows[0][$"outputValue{i}"]; } } + if (returnValue + "" == "-1") LastFailureSql = cmd.CommandText; } set2 = dataSet; } @@ -398,6 +409,7 @@ namespace Lskj.Core /// System.Int32. public static int ExecuteNonQuery(CommandType cmdType, string cmdText, params DbParameter[] commandParameters) { + LastFailureSql = string.Empty; DbCommand cmd = dbFactory.CreateCommand(); int num = 0; try @@ -428,6 +440,7 @@ namespace Lskj.Core sqlParameter.Value = resultTable.Rows[0][$"outputValue{i}"]; } } + if (returnValue + "" == "-1") LastFailureSql = cmd.CommandText; } } else @@ -476,6 +489,7 @@ namespace Lskj.Core /// public static int ExecuteNonQuery(CommandType cmdType, string cmdText, DbTransaction Trans, int a, params DbParameter[] commandParameters) { + LastFailureSql = string.Empty; DbCommand cmd = dbFactory.CreateCommand(); int num = 0; try @@ -506,6 +520,7 @@ namespace Lskj.Core sqlParameter.Value = resultTable.Rows[0][$"outputValue{i}"]; } } + if (returnValue + "" == "-1") LastFailureSql = cmd.CommandText; } } else @@ -746,7 +761,7 @@ namespace Lskj.Core /// Type of the command. /// The command text. /// The command parms. - private static void PrepareCommand(DbCommand cmd, DbConnection Connection, DbTransaction trans, CommandType cmdType, string cmdText, DbParameter[] cmdParms) + public static void PrepareCommand(DbCommand cmd, DbConnection Connection, DbTransaction trans, CommandType cmdType, string cmdText, DbParameter[] cmdParms) { try {