助力产业智慧升级,云服务器首年88元起,更有千元代金券礼包免费领!

搜搜吧

查看: 101|回复: 0

[移动开发] Dapper-小型ORM之王(C#.NET)

[复制链接]
  • TA的每日心情
    擦汗
    昨天 17:25
  • 签到天数: 551 天

    [LV.9]以坛为家II

    硕士生

    1万

    主题

    1万

    帖子

    3万

    积分

    Rank: 8Rank: 8

    UID
    15343
    威望
    -561
    贡献
    7964
    在线时间
    245 小时
    注册时间
    2015-10-12
    发表于 2019-8-15 15:12:15 | 显示全部楼层 |阅读模式
    推广者专属福利,新客户无门槛领取总价值高达2775元代金券,每种代金券限量500张,先到先得。

    ORM:对象关系映射器,它直接将数据库映射到C#对象。

    有很多ORM框架可用,Dapper是其中之一,被称为ORM之王。

    下面是Dapper主要的一些功能:

    • 速度快,性能好;
    • 更少的代码行
    • 对象映射
    • 静态对象绑定
    • 动态对象绑定
    • 易于处理Sql语句
    • 易于处理存储过程
    • 直接操作IDBConnection类,该类直接向数据库提供平滑性和运行查询,而不是像在EF和ADO.NET中那样使用各种对象传递数据。
    • 多个查询支持
    • 支持存储过程
    • 批量处理数据插入
    • 允许基于多个输入获取多个数据

    为什么选择Dapper

    • Dapper是第二快的ORM

    图片参照: Dapper dotnet.

    20190815142942408939.jpg

    • 直接使用IDBConnection对象执行CRUD操作;
    • 通过数据库提供查询静态和动态数据;
    • 获取简单或复杂数据类型的通用结果;
    • Dapper允许同时存储批量数据。

    如何安装Dapper

    在Visual Studio中,创建一个新的控制台项目,并在解决方案资源管理器中右键单击引用,选择 “管理Nuget包...”包管理器,然后搜索Dapper,并使用NuGet包管理器控制台命令“install-package Dapper”,这将在项目中安装Dapper。

    Dapper如何工作

    主要包含三个步骤

    第一步:使用连接字符串创建一个IDBConnection对象;

    第二步:编写一个查询并将其存储在一个普通的字符串变量中;

    第三步:调用db.execute()并传递查询,完成。

    在下面的示例中,我们还将探索许多其他的方法。

    对于本例,我有一个名为“ContactDB”的数据库,库中包含一个名为“Contacts”的表,让我们使用Dapper对Contacts表进行CRUD操作。

    20190815142942531001.jpg

    创建一个控制台应用程序并安装Dapper,并包含Dapper的命名空间。


    using System;using System.Collections.Generic;using System.Linq;using System.Text;using System.Threading.Tasks;using Dapper;namespace DapperORMBlog{   public class Program    {        static void Main(string[] args)        {        }    }}

    示例1:

    获取所有数据并打印到控制台

    第一步:创建IDbConnection类的对象和SqlConnection的新实例。

    static IDbConnection db = new SqlConnection(ConfigurationManager.ConnectionStrings["SqlServerConnString"].ConnectionString);

    SqlServerConnString是连接字符串名称,可以配置在程序中的App.config中。

    <connectionStrings>    <add name="SqlServerConnString" providerName="System.Data.SqlClient" connectionString="Data Source=.\;Initial Catalog=ContactDB;Integrated Security=True;MultipleActiveResultSets=True" />  </connectionStrings>

    第二步:写一个查询,并将其存储到一个string类型的变量中

    String query = "select * from contacts";

    第三步:在db实例上启动查询,并将泛型返回类型转换为联系人实体List

    (List<Contact>)db.Query<Contact>(query)

    只要使用这三个步骤,我们就可以从Contacts表中检索出所有的数据,可以在需要的地方去填充这些数据。可以将整个列表打印到Winform程序的GridView或者WPF,更或者将整个列表传递给任何外部的WCF.

    对于这个示例,我们将其打印到控制台


    List<Contact> lstContact= (List<Contact>)db.Query<Contact>(query);            foreach (var item in lstContact)            {                Console.WriteLine(item.FirstName + " " + item.LastName+"\n");            }            Console.ReadKey();

    结果:

    20190815142942546625.jpg

    示例2:

    给Contacts表中插入数据,同样包含三步

    第一步:创建IDbConnection类的对象和SqlConnection的新实例。

    static IDbConnection db = new SqlConnection(ConfigurationManager.ConnectionStrings["SqlServerConnString"].ConnectionString);

    第二步:

      string query = @"Insert into contacts values (@FirstName, @LastName, @Email, @Company, @Title);  Select Cast (Scope_Identity() as int)";

    在这里,我们包含两个查询来获取Contacts表最后插入的id值。

    在db实例上启动查询,我们将获得一个int类型的返回值,因此将其存储到int变量中,并将contact对象和查询语句传递过去,如下所示。

    int id = db.Query<int>(query, contact).Single();

    在这三个简单步骤中,数据将被插入到数据库中。


    Contact contact = new Contact() { FirstName = "yixuan", LastName = "han", Email = "yixuanhan@aaa.com", Company = "BAT", Title = "PE" };            string query = @"Insert into contacts values (@FirstName, @LastName, @Email, @Company, @Title);  Select Cast (Scope_Identity() as int)";            int id = db.Query<int>(query, contact).Single();

    查看数据库多了一条记录,说明插入成功

    20190815142942562249.jpg

    示例3:现在,让我们通过在where子句中传递一个id,从Contacts表中获取一条记录

    第一步:创建IDbConnection类的对象和SqlConnection的新实例。

    static IDbConnection db = new SqlConnection(ConfigurationManager.ConnectionStrings["SqlServerConnString"].ConnectionString);

    第二步:

        string query = "select * from contacts where id = @id";

    第三步:在db实例上启动查询,我们将获得一条联系人记录,并将其传给contact对象进行保存

                Contact cont = (Contact)db.Query<Contact>(query, new { id = 7 }).SingleOrDefault();

    备注:同样的方法,我们可以对数据库进行Update和Delete操作

    我们甚至可以用db.Execute()

    db.Query()和db.Execute()之间主要的区别是,用db.Query()我们可以按照我们的设计获取返回值,因为它是一个通用的方法,而db.Execute()不是一个通用的方法,因此它只能返回int

    进一步使用Dapper

    • 我们也会遇到一次需要处理多个表的需求,例如一次查询多个表或者以外键获取数据
    • 我们可以用Dapper同时访问多个表,并且十分平滑
    • 传递对象列表,Dapper本事可以识别出是批量插入
    • 根据各种参数获取数据,Dapper会自动将数组转换成CSV,并返回一个List对象

    示例4:

    下面假如说我已经有另一张名为“Address”的表

    20190815142942575920.jpg

    我们将在两个表上同时执行CRUD操作,使用相同的ContactId,即Contacts表中的主键,Adress表中的外键

    现在让我们通过传递Id从Contacts表和Adress表中获取多条数据

    第一步和之前所有示例的第一步相同,我们从第二步开始

    第二步:

    string query = "select * from contacts where id = @id ; select * from address where ContactId = @id;";

    第三步:db实例上启动查询


    using (var multipleresult = db.QueryMultiple(query, new { id = 1 }))            {                var contact = multipleresult.Read<Contact>().SingleOrDefault();                var Addresses = multipleresult.Read<Address>().ToList();                if (contact != null && Addresses != null)                {                    contact.Addresses.AddRange(Addresses);                }            }

    以上三步你将 可以从多个表中获得多条记录

    示例5:

    让我们使用存储过程访问数据库

    我有一个存储过程,声明一个参数(ID),并且基于ID返回Contact数据和Address数据


    Use ContactDBSET ANSI_NULLS ONGOSET QUOTED_IDENTIFIER ONGOCREATE PROCEDURE [dbo].[sp_GetContact_Address]      @Id int ASBEGINselect * from contacts where id = @Id ;   select * from Address where ContactId = @Id; ENDGO

    用Dapper调用存储过程

    第一步同其他示例

    在这里我们不需要写任何的query语句,相反的我们将调用数据库内的存储过程

    在这里我们将做的更改是传递一个存储过程的名称而不是查询语句,并传递一个名称为command type的参数。

    第二步:在db实例上启动查询


    using (var multipleresult = db.QueryMultiple("sp_GetContact_Address", new { id = 1 }, commandType: CommandType.StoredProcedure))            {                var contact = multipleresult.Read<Contact>().SingleOrDefault();                var Addresses = multipleresult.Read<Address>().ToList();                if (contact != null && Addresses != null)                {                    contact.Addresses.AddRange(Addresses);                }            }

    仅仅两步,就 可以成功的调用数据库中的存储过程

    示例6:

    当我们需要处理运行时对象时,还可以将动态对象或者值传递给存储过程

    下面这个存储过程会给Contacts表里增加一条记录


    use ContactDBSET ANSI_NULLS ONGOSET QUOTED_IDENTIFIER ONGOCREATE PROCEDURE [dbo].[SaveContact]     @Id int output,    @FirstName nvarchar(50),    @LastName nvarchar(50),    @Email nvarchar(50),    @Company nvarchar(50),    @Title nvarchar(50)ASBEGIN    INSERT INTO [dbo].[Contacts]             ([FirstName],[LastName],[Company],[Title],[Email]) VALUES             (@FirstName, @LastName, @Company, @Title, @Email);          SET @Id = cast(scope_identity() as int)  ENDGO

    下面演示了如何使用Dapper通过传递动态参数调用存储过程

    第一步同其他示例

    第二步:创建一个动态对象并将值传递给该对象


    var parameter = new DynamiCPArameters();            parameter.Add("@Id", con.Id, dbType: DbType.Int32, direction: ParameterDirection.InputOutput);            parameter.Add("@FirstName", con.FirstName);            parameter.Add("@LastName", con.LastName);            parameter.Add("@Company", con.Company);            parameter.Add("@Title", con.Title);            parameter.Add("@Email", con.Email);

    第三步:用db.Execute()调用存储过程

    db.Execute("SaveContact",parameter,commandType:CommandType.StoredProcedure);    //To get newly created ID back  con.Id = parameter.Get<int>("@Id");  

    这些是使用c#动态对象操作数据库的方法。

    楼主热帖排行榜
    搜搜吧社区温馨提示:
    搜搜吧(www.sosoba.org)十分重视网络版权及其他知识产权的保护,针对网络侵权采取如下版权政策:
    1、本站有理由相信网友侵犯任何人的版权或作品,(图文,文字,下载,视频,非法传播),本站有权不事先通知即删除涉嫌侵权的作品和内容
    2、本站将采取必要的网络技术手段,确认为侵权作品或内容的用户有权进行警告、屏蔽、删除的行为,尽可能的防止侵权行为的发生
    3、搜搜吧影视资源均收集自互联网,没有提供影片资源存储,也未参与录制上传,若本站收录的资源涉及您的版权或知识产权或其他利益,我们会立即删除
    4、搜搜吧,删帖,投诉,举报,侵权,若本站侵犯您的权益,附上身份及权利证明,请直接发送邮件到 kefu-sosoba@qq.com 我们将在一个工作日内删除
    soso搜搜吧社区是聚合百度搜索,搜狗搜索,360搜索,新闻,教育,站长,广告,娱乐,影视,微信,网盘,营销,手机,汽车,游戏,论坛综合为一体的大型门户社区www.sosoba.org
    关闭

    搜搜吧社区公告上一条 /1 下一条

    Powered by www.sosoba.org X3.4© 2013-2019 搜搜吧社区 小黑屋|手机版|Archiver|地图|关于我们|腾讯云代金券|帮助中心|soso吧社区
    广告服务/项目合作: kefu-sosoba@qq.com  侵权举报邮箱: kefu-sosoba@qq.com  搜搜吧建站时间:创建于2013年07月23日
    免责声明:本站所有的内容均来自互联网以及第三方作者自由发布,版权归原作者版权所有,搜搜吧不承担任何的法律责任,若有侵权请来信告知,我们立即删除!
    本站热搜:搜搜吧,搜搜,搜搜网,搜一下,搜吧,soso,sousou,快搜,soso搜搜,好搜,搜索,soso问问,搜搜问问,搜搜小说,搜搜图片,搜狗搜索,微信搜索,图片搜索,百度搜索,手机搜索,网盘搜索

    GMT+8, 2019-10-22 13:44 , Processed in 1.140625 second(s), 11 queries , Gzip On, MemCache On.

    快速回复 返回顶部 返回列表