From 8aad6ba8e082d1fb63bfdd947f7e9da1bc133611 Mon Sep 17 00:00:00 2001
From: yl <ykxkd@outlook.com>
Date: 星期五, 24 六月 2022 23:47:19 +0800
Subject: [PATCH] 工序定义接口开发、节拍工价接口开发
---
VueWebApi/Tools/DapperHelper.cs | 211 ++++++++++++++++++++++++++++++++++++----------------
1 files changed, 146 insertions(+), 65 deletions(-)
diff --git a/VueWebApi/Tools/DapperHelper.cs b/VueWebApi/Tools/DapperHelper.cs
index 2d4cf04..132be16 100644
--- a/VueWebApi/Tools/DapperHelper.cs
+++ b/VueWebApi/Tools/DapperHelper.cs
@@ -52,7 +52,12 @@
LogHelper.WriteLog(ex);
throw ex;
}
-
+ finally
+ {
+ conn.Dispose();
+ conn.Close();
+ }
+
}
return list;
}
@@ -81,6 +86,11 @@
LogHelper.WriteLog(ex);
throw ex;
}
+ finally
+ {
+ conn.Dispose();
+ conn.Close();
+ }
}
return result;
}
@@ -108,6 +118,11 @@
LogHelper.WriteLog(ex);
throw ex;
}
+ finally
+ {
+ conn.Dispose();
+ conn.Close();
+ }
}
return t;
}
@@ -122,25 +137,24 @@
/// <param name="pageSize">褰撳墠椤垫樉绀烘潯鏁�</param>
/// <param name="total">缁撴灉闆嗘�绘暟</param>
/// <returns></returns>
- public static IEnumerable<T> GetPageList<T>(string sql,Object parm, string orderBy,string sort, int pageIndex, int pageSize, out int total)
+ public static IEnumerable<T> GetPageList<T>(string sql, Object parm, string orderBy, string sort, int pageIndex, int pageSize, out int total)
{
- try
- {
- int skip = 1;
- if (pageIndex > 0)
- {
- skip = (pageIndex - 1) * pageSize + 1;
- }
-
- StringBuilder sb = new StringBuilder();
- sb.AppendFormat("SELECT COUNT(1) FROM ({0}) AS Result;", sql);
- sb.AppendFormat(@"SELECT *
+ //int skip = 1;
+ //if (pageIndex > 0)
+ //{
+ // skip = (pageIndex - 1) * pageSize + 1;
+ //}
+ StringBuilder sb = new StringBuilder();
+ sb.AppendFormat("SELECT COUNT(1) FROM ({0}) AS Result;", sql);
+ sb.AppendFormat(@"SELECT *
FROM(SELECT *,ROW_NUMBER() OVER(ORDER BY {1} {2}) AS RowNum
FROM ({0}) AS Temp) AS Result
WHERE RowNum >= {3} AND RowNum <= {4}
- ORDER BY {1} {2}", sql, orderBy, sort, skip, pageIndex * pageSize);
+ ORDER BY {1} {2}", sql, orderBy, sort, pageIndex, pageSize); //skip, pageIndex * pageSize
- using (IDbConnection conn = sqlConnection())
+ using (IDbConnection conn = sqlConnection())
+ {
+ try
{
using (var reader = conn.QueryMultiple(sb.ToString(), parm))
{
@@ -148,14 +162,19 @@
return reader.Read<T>();
}
}
+ catch (Exception ex)
+ {
+ //鍒涘缓鏃ュ織璁板綍缁勪欢瀹炰緥
+ LogHelper.WriteLog(ex);
+ throw ex;
+ }
+ finally
+ {
+ conn.Dispose();
+ conn.Close();
+ }
+
}
- catch (Exception ex)
- {
- //鍒涘缓鏃ュ織璁板綍缁勪欢瀹炰緥
- LogHelper.WriteLog(ex);
- throw ex;
- }
-
}
/// <summary>
@@ -167,23 +186,27 @@
public static DataTable selectdata(string sql, Object parm)
{
//sql璇彞
- try
+ using (IDbConnection conn = sqlConnection())
{
- using (IDbConnection conn = sqlConnection())
+ try
{
DataTable table = new DataTable();
var data = conn.ExecuteReader(sql, parm);
table.Load(data);
return table;
}
+ catch (Exception ex)
+ {
+ //鍒涘缓鏃ュ織璁板綍缁勪欢瀹炰緥
+ LogHelper.WriteLog(ex);
+ throw ex;
+ }
+ finally
+ {
+ conn.Dispose();
+ conn.Close();
+ }
}
- catch (Exception ex)
- {
- //鍒涘缓鏃ュ織璁板綍缁勪欢瀹炰緥
- LogHelper.WriteLog(ex);
- throw ex;
- }
-
}
/// <summary>
@@ -194,21 +217,59 @@
public static DataTable selecttable(string sql)
{
//sql璇彞
- try
+ using (IDbConnection conn = sqlConnection())
{
- using (IDbConnection conn = sqlConnection())
+ try
{
DataTable table = new DataTable();
var data = conn.ExecuteReader(sql);
table.Load(data);
return table;
}
+ catch (Exception ex)
+ {
+ //鍒涘缓鏃ュ織璁板綍缁勪欢瀹炰緥
+ LogHelper.WriteLog(ex);
+ throw ex;
+ }
+ finally
+ {
+ conn.Dispose();
+ conn.Close();
+ }
}
- catch (Exception ex)
+ }
+
+ /// <summary>
+ /// Dapper鎵ц瀛樺偍杩囩▼杩斿洖datatable鏁版嵁(甯﹀弬鏁�)
+ /// </summary>
+ /// <param name="sql">瀛樺偍杩囩▼鍚�</param>
+ /// <param name="parm">鍙傛暟</param>
+ /// <returns></returns>
+ public static DataTable selectProcedure(string sql, Object parm)
+ {
+ //sql璇彞
+ using (IDbConnection conn = sqlConnection())
{
- //鍒涘缓鏃ュ織璁板綍缁勪欢瀹炰緥
- LogHelper.WriteLog(ex);
- throw ex;
+ try
+ {
+ DataTable table = new DataTable();
+ //var data = conn.ExecuteReader(sql, parm);
+ var res = conn.ExecuteReader(sql, parm, commandType: CommandType.StoredProcedure);//sql 瀛樺偍杩囩▼
+ table.Load(res);
+ return table;
+ }
+ catch (Exception ex)
+ {
+ //鍒涘缓鏃ュ織璁板綍缁勪欢瀹炰緥
+ LogHelper.WriteLog(ex);
+ throw ex;
+ }
+ finally
+ {
+ conn.Dispose();
+ conn.Close();
+ }
}
}
@@ -223,19 +284,24 @@
{
//sql璇彞
int result = 0;
- try
+ using (IDbConnection conn = sqlConnection())
{
- using (IDbConnection conn = sqlConnection())
+ try
{
result = conn.Query(sql, parm).Count();
}
+ catch (Exception ex)
+ {
+ //鍒涘缓鏃ュ織璁板綍缁勪欢瀹炰緥
+ LogHelper.WriteLog(ex);
+ throw ex;
+ }
+ finally
+ {
+ conn.Dispose();
+ conn.Close();
+ }
return result;
- }
- catch (Exception ex)
- {
- //鍒涘缓鏃ュ織璁板綍缁勪欢瀹炰緥
- LogHelper.WriteLog(ex);
- throw ex;
}
}
@@ -245,24 +311,29 @@
/// <param name="sql"></param>
/// <param name="parametere"></param>
/// <returns></returns>
- public static int SQL(string sql,Object parametere)
+ public static int SQL(string sql, Object parametere)
{
//sql璇彞
int result = 0;
- try
+ using (IDbConnection conn = sqlConnection())
{
- using (IDbConnection conn = sqlConnection())
+ try
{
result = conn.Execute(sql, parametere);
}
- return result;
+ catch (Exception ex)
+ {
+ //鍒涘缓鏃ュ織璁板綍缁勪欢瀹炰緥
+ LogHelper.WriteLog(ex);
+ throw ex;
+ }
+ finally
+ {
+ conn.Dispose();
+ conn.Close();
+ }
}
- catch (Exception ex)
- {
- //鍒涘缓鏃ュ織璁板綍缁勪欢瀹炰緥
- LogHelper.WriteLog(ex);
- throw ex;
- }
+ return result;
}
/// <summary>
@@ -281,7 +352,7 @@
tranction = conn.BeginTransaction();
for (int i = 0; i < sqlList.Count; i++)
{
- conn.Execute(sqlList[i].GetType().GetProperty("str").GetValue(sqlList[i], null).ToString(), sqlList[i].GetType().GetProperty("parm").GetValue(sqlList[i], null),tranction);
+ conn.Execute(sqlList[i].GetType().GetProperty("str").GetValue(sqlList[i], null).ToString(), sqlList[i].GetType().GetProperty("parm").GetValue(sqlList[i], null), tranction);
}
tranction.Commit();
result = true;
@@ -293,6 +364,11 @@
result = false;
tranction.Rollback();
throw ex;
+ }
+ finally
+ {
+ conn.Dispose();
+ conn.Close();
}
return result;
}
@@ -310,9 +386,9 @@
{
int result = 0;
- try
+ using (IDbConnection conn = sqlConnection())
{
- using (IDbConnection conn = sqlConnection())
+ try
{
result = conn.Execute(sql, parameter);
if (result != 0)
@@ -320,14 +396,19 @@
result = conn.Query<int>("select ident_current(@table)", new { table = tableName }).Single<int>();
}
}
- return result;
+ catch (Exception ex)
+ {
+ //鍒涘缓鏃ュ織璁板綍缁勪欢瀹炰緥
+ LogHelper.WriteLog(ex);
+ throw ex;
+ }
+ finally
+ {
+ conn.Dispose();
+ conn.Close();
+ }
}
- catch (Exception ex)
- {
- //鍒涘缓鏃ュ織璁板綍缁勪欢瀹炰緥
- LogHelper.WriteLog(ex);
- throw ex;
- }
+ return result;
}
}
}
\ No newline at end of file
--
Gitblit v1.9.3