- A+
所属分类：.NET技术
步骤1)引入该ORM库。
使用Nuget搜索"Dapper"安装或者直接从github上下载源码 (https://github.com/StackExchange/Dapper) 集成到项目中。
步骤2)初始化数据库连接配置.
using MySql.Data.MySqlClient; using System; using System.Collections.Generic; using System.Data; using System.Data.SqlClient; using System.Text; namespace CoreLab.DAL.Base { /// <summary> /// 功能简介：基于Dapper这个orm框架的数据库访问对象 /// 创建时间：2020-8-11 /// 创建人：ww /// </summary> public class DBaseForDapper { public static IDbConnection dbConnect_GmUser { get { return new MySqlConnection(SqlConnectManager.Instance.SqlConnectStr_Gateway);//SqlConnection默认是Sqlserver的,他们都实现了IDbConnnection } } } }
步骤3)从简单的CRUD来体验Dapper( 由于仅用于体验用法，因此直接写在controller中了).
using System; using System.Collections.Generic; using System.Linq; using System.Threading.Tasks; using Microsoft.AspNetCore.Mvc; using CoreLab.Model.ListPageModel; using CoreLab.Model.Configs; using Microsoft.Extensions.Options; using Microsoft.AspNetCore.Http; using System.Net.Http.Headers; using System.IO; using Microsoft.AspNetCore.Hosting;using Newtonsoft.Json;using System.Text; using CoreLab.DAL; using CoreLab.DAL.Base; using Dapper; using System.Data;namespace CoreLab.Web.Controllers { /// <summary> /// 功能简介：本控制器内的代码仅用于快速测试. /// 创建时间：2020-8-11 /// 创建人：ww /// </summary> public class DemoController : BaseController {
public string DapperTest_Add(string CardTypeId,string CardTypeName) { try { E_CardType eCardType = new E_CardType() { CardTypeId = CardTypeId, CardTypeName = CardTypeName, CreateTime = DateTime.Now, EnableStatus = 1 }; using (IDbConnection dbConnection = DBaseForDapper.dbConnect_GmUser) { int iReturn = dbConnection.Execute("insert into tb_cardtype(CardTypeId,CardTypeName,EnableStatus) values(@CardTypeId,@CardTypeName,@EnableStatus)", eCardType); return iReturn.ToString(); } } catch(Exception ex) { } return "-1"; } public IActionResult DapperTest_QueryList() { try { using (IDbConnection dbConnection = DBaseForDapper.dbConnect_GmUser) { IList<E_CardType> listCardType = dbConnection.Query<E_CardType>("select * from tb_cardtype",null).ToList(); return new JsonResult(listCardType); } } catch (Exception ex) { } return new JsonResult(null); } public IActionResult DapperTest_QueryEntity(string CardTypeId) { try { using (IDbConnection dbConnection = DBaseForDapper.dbConnect_GmUser) { //如果是in @ids 则对应一个数组而不是对象。 IEnumerable<E_CardType> listCardType = dbConnection.Query<E_CardType>("select * from tb_cardtype where CardTypeId=@CardTypeId", new E_CardType() { CardTypeId= CardTypeId }); if (listCardType != null && listCardType.Count() > 0) { return new JsonResult(listCardType.First()); } return new JsonResult(null); } } catch (Exception ex) { } return new JsonResult(null); } public string DapperTest_Update(string CardTypeId, int EnableStatus) { try { using (IDbConnection dbConnection = DBaseForDapper.dbConnect_GmUser) { int iReturn = dbConnection.Execute($"update tb_cardtype set EnableStatus={EnableStatus} where CardTypeId=@CardTypeId", new E_CardType() { CardTypeId=CardTypeId }); return iReturn.ToString(); } } catch (Exception ex) { } return "-1"; } public string DapperTest_Delete(string CardTypeId) { try { using (IDbConnection dbConnection = DBaseForDapper.dbConnect_GmUser) { int iReturn = dbConnection.Execute($"delete from tb_cardtype where CardTypeId=@CardTypeId", new E_CardType() { CardTypeId = CardTypeId }); return iReturn.ToString(); } } catch (Exception ex) { } return "-1"; } } /// <summary> /// 游戏卡类型 /// </summary> public class E_CardType { public string CardTypeId { get; set; } public string CardTypeName { get; set; } public DateTime CreateTime { get; set; } public int EnableStatus { get; set; } } }
