如何將 Dapper 換成 SqlSugar ORM
阿新 • • 發佈：2020-12-15
Dapper 介紹
Dapper是一個輕量級開源的ORM類，他是通過擴充套件IDbConnection提供一些有用的擴充套件方法去查詢您的資料庫，所以Ado.Net支援的資料庫，他都可以支援。
在速度方面具有“King of Micro ORM”的頭銜，幾乎與使用原始的ADO.NET資料讀取器一樣快。很多人第一次使用了他之後，就深深的喜歡上他了。
SqlSugar 介紹
SqlSugar 同樣輕量級小巧，功能方面更加全面，需求都是來自1000多開發人員的真實專案需求，在這些需求上進行完美的設計，經過5年多的積累，
可以完美滿足企業級的所有需求特別是查詢功能，支援了各種型別的返回例如DataTable、List、字典等，還支援各種查詢，
例如一次查詢多個結果集，當然也支援儲存過程
效能對比
在基礎功能查詢上效能雙方是相當接近的，並且在不同CPU多臺電腦上進行過大量測試，效能SqlSugar一點不佔下風，甚至更好，
在SqlSugar原始碼中有對比程式碼，這邊我就不多介紹了，效能永遠是自個比才是真實的，別人比都是虛假的
移植教程
1、Sql加引數查詢
Dapper 使用Sql加引數查詢
/// <summary> /// 查詢列表 /// </summary> /// <param name="sql">查詢的sql</param> /// <param name="param">替換引數</param> /// <returns></returns> public static List<T> Query(string sql, object param) { using (SqlConnection con = new SqlConnection(connectionString)) { return con.Query<T>(sql, param).ToList(); } }
SqlSugar 使用Sql加引數查詢
/// <summary> /// 查詢列表 /// </summary> /// <param name="sql">查詢的sql</param> /// <param name="param">替換引數</param> /// <returns></returns> public static List<T> Query(string sql, object param) { using (SqlSugarClient con =new SqlSugar.SqlSugarClient(connectionConfig)) { return con.Ado.SqlQuery<T>(sql, param); } }
其中Object param支援3種類型
1、new {id=1} 匿名物件
2、SugarParameter
3、SugarParameter[] 或者List<SugarParameter >
2、根據Sql查詢單條
Dapper根據Sql查詢單條
/// <summary>
/// 查詢第一個資料
/// </summary>
/// <param name="sql"></param>
/// <param name="param"></param>
/// <returns></returns>
public static T QueryFirst(string sql, object param)
{
using (SqlConnection con = new SqlConnection(connectionString))
{
return con.QueryFirst<T>(sql, param);
}
}
SqlSugar根據Sql查詢單條
/// <summary>
/// 查詢列表
/// </summary>
/// <param name="sql">查詢的sql</param>
/// <param name="param">替換引數</param>
/// <returns></returns>
public static List<T> Query(string sql, object param)
{
using (SqlSugarClient con =new SqlSugar.SqlSugarClient(connectionConfig))
{
return con.Ado.SqlQuerySingle<T>(sql, param);
}
}
3、增、刪、改
Dapper增、刪、改
/// <summary>
/// 增刪改
/// </summary>
/// <param name="sql"></param>
/// <param name="param"></param>
/// <returns></returns>
public static int Execute(string sql, object param)
{
using (SqlConnection con = new SqlConnection(connectionString))
{
return con.Execute(sql, param);
}
}
SqlSugar增、刪、改
/// <summary>
/// 增、刪、改
/// </summary>
/// <param name="sql">查詢的sql</param>
/// <param name="param">替換引數</param>
/// <returns></returns>
public static int Query(string sql, object param)
{
using (SqlSugarClient con =new SqlSugar.SqlSugarClient(connectionConfig))
{
return con.Ado.ExecuteCommand(sql, param);
}
}
4、DataReader讀取資料
Dapper DataReader讀取資料
/// <summary>
/// Reader獲取資料
/// </summary>
/// <param name="sql"></param>
/// <param name="param"></param>
/// <returns></returns>
public static IDataReader ExecuteReader(string sql, object param)
{
using (SqlConnection con = new SqlConnection(connectionString))
{
return con.ExecuteReader(sql, param);
}
}
SqlSugar DataReader讀取資料
/// <summary>
/// 獲取DataReader
/// </summary>
/// <param name="sql">查詢的sql</param>
/// <param name="param">替換引數</param>
/// <returns></returns>
public static IDataReader Query(string sql, object param)
{
using (SqlSugarClient con =new SqlSugar.SqlSugarClient(connectionConfig))
{
return con.Ado.GetDataReader(sql, param);
}
}
5、獲取首行首列
Dapper獲取首行首列
/// <summary>
/// Scalar獲取資料
/// </summary>
/// <param name="sql"></param>
/// <param name="param"></param>
/// <returns></returns>
public static object ExecuteScalar(string sql, object param)
{
using (SqlConnection con = new SqlConnection(connectionString))
{
return con.ExecuteScalar(sql, param);
}
}
SqlSugar獲取首行首列
/// <summary>
/// 獲取首行首列
/// </summary>
/// <param name="sql">查詢的sql</param>
/// <param name="param">替換引數</param>
/// <returns></returns>
public static object ExecuteScalar(string sql, object param)
{
using (SqlSugarClient con =new SqlSugar.SqlSugarClient(connectionConfig))
{
return con.Ado.GetScalar(sql, param);
}
}
6、獲取儲存過程
Dapper獲取儲存過程
/// <summary>
/// 帶引數的儲存過程
/// </summary>
/// <param name="sql"></param>
/// <param name="param"></param>
/// <returns></returns>
public static List<T> ExecutePro(string proc, object param)
{
using (SqlConnection con = new SqlConnection(connectionString))
{
List<T> list = con.Query<T>(proc,
param,
null,
true,
null,
CommandType.StoredProcedure).ToList();
return list;
}
}
SqlSugar獲取儲存過程
/// <summary>
/// 獲取儲存過程
/// </summary>
/// <param name="sql">查詢的sql</param>
/// <param name="param">替換引數</param>
/// <returns></returns>
public static object ExecutePro<T>(string proc, object param) 8 {
using (SqlSugarClient con =new SqlSugar.SqlSugarClient(connectionConfig))
{
return con.Ado.UseStoredProcedure().SqlQuery<T>(proc, param);12
}
}
7、事務執行多個Sql
Dapper事務執行多個Sql
/// <summary>
/// 事務1 - 全SQL
/// </summary>
/// <param name="sqlarr">多條SQL</param>
/// <param name="param">param</param>
/// <returns></returns>
public static int ExecuteTransaction(string[] sqlarr)
{
using (SqlConnection con = new SqlConnection(connectionString))
{
using (var transaction = con.BeginTransaction())
{
try
{
int result = 0;
foreach (var sql in sqlarr)
{
result += con.Execute(sql, null, transaction);
}
transaction.Commit();
return result;
}
catch (Exception ex)
{
transaction.Rollback();
return 0;
}
}
}
}
Sugar事務執行多個Sql
/// <summary>
/// 事務1 - 全SQL
/// </summary>
/// <param name="sqlarr">多條SQL</param>
/// <param name="param">param</param>
/// <returns></returns>
public static int ExecuteTransaction(string[] sqlarr)
{
using (SqlSugarClient con = new SqlSugarClient(connectionConfig))
{
con.Ado.BeginTran();
using (var transaction = con.Ado.Transaction)
{
try
{
int result = 0;
foreach (var sql in sqlarr)
{
result += con.Ado.ExecuteCommand(sql);
}
transaction.Commit();
return result;
}
catch (Exception ex)
{
transaction.Rollback();
return 0;
}
}
}
}
SqlSugar引數詳解
SqlSugar同樣支援遊標 、Output、 ReturnValue
var nameP=new SugarParameter("@name", "張三", typeof(string),ParameterDirection.ReturnValue);
移植成SqlSugar ORM有哪些優點
同樣是寫Sql但是SqlSugar提供了AOP、效能監控、返回多個結果集、SQL分頁、一對多、一對一操作、JSON型別 等
1、SqlSugar支援AOP等事件操作
db.Aop.OnLogExecuted = (sql, pars) => //SQL執行完
{
Console.Write("time:" + db.Ado.SqlExecutionTime.ToString());//輸出SQL執行時間
};
db.Aop.OnLogExecuting = (sql, pars) => //SQL執行前
{
};
db.Aop.OnError = (exp) =>//SQL報錯
{
//exp.sql 這樣可以拿到錯誤SQL
};
db.Aop.OnExecutingChangeSql = (sql, pars) => //可以修改SQL和引數的值
{
return new KeyValuePair<string, SugarParameter[]>(sql,pars);
};
除了這些事件外 SqlSugar還支援了效能監控，對於效能差的Sql或者儲存過程都能很好的跟蹤
SqlSugarClient db = new SqlSugarClient(new ConnectionConfig()
{
DbType = DbType.SqlServer,
ConnectionString = Config.ConnectionString,
InitKeyType = InitKeyType.Attribute,
IsAutoCloseConnection = true
});
db.Aop.OnLogExecuted = (sql, p) =>
{
//執行時間超過1秒
if (db.Ado.SqlExecutionTime.TotalSeconds > 1)
{
//程式碼CS檔名
var fileName= db.Ado.SqlStackTrace.FirstFileName;
//程式碼行數
var fileLine = db.Ado.SqlStackTrace.FirstLine;
//方法名
var FirstMethodName = db.Ado.SqlStackTrace.FirstMethodName;
//db.Ado.SqlStackTrace.MyStackTraceList[1].xxx 獲取上層方法的資訊
}
};
因為內容比較多一下子寫不完 ,沒關注的點一波關注
2、Json型別的查詢
public class UnitJsonTest
{
[SqlSugar.SugarColumn(IsPrimaryKey = true, IsIdentity = true)]
public int Id { get; set; }
[IsJson = true)]//其中IsJson是必填
public Order Order { get; set; }
public string Name{get;set;}
}
var list = Db.Ado.SqlQuery<UnitJsonTest>().ToList();//資料庫是一個json字串3、Sql分頁
var list= db.SqlQueryable<Student>("select * from student").Where("id=@id",new { id=1}).ToPageList(1, 2);