轻量级ORM框架初探-Dapper与PetaPoco的基本使用

一、EntityFramework

  EF是传统的ORM框架,也是一个比较重量级的ORM框架。这里仍然使用EF的原因在于为了突出轻量级ORM框架的性能,所谓有对比才有更优的选择。

1.1 准备一张数据库表

  (1)For MSSQL

CREATE TABLE [dbo].[Posts]
(
    [Id] INT NOT NULL PRIMARY KEY IDENTITY, 
    [CategoryId] INT NOT NULL, 
    [Slug] VARCHAR(120) NOT NULL,  
    [Title] NVARCHAR(100) NOT NULL, 
    [Published] DATETIME NOT NULL,
    [Excerpt] NVARCHAR(MAX) NOT NULL, 
    [Content] NVARCHAR(MAX) NOT NULL
);

  (2)For MySQL

CREATE TABLE Posts
(
    Id INT NOT NULL PRIMARY KEY AUTO_INCREMENT, 
    CategoryId INT NOT NULL, 
    Slug VARCHAR(120) NOT NULL,  
    Title NVARCHAR(100) NOT NULL, 
    Published DATETIME NOT NULL,
    Excerpt LONGTEXT NOT NULL, 
    Content LONGTEXT NOT NULL
);

1.2 使用Model First方式创建数据模型

  (1)通过nuget添加EF组件引用,然后创建edmx数据模型

  (2)由于EF首次使用存在效率问题,因此采用园子里推荐的EF暖机操作作为测试首次执行的代码

    static void WarmupEntityFramework()
    {
        // EF暖机操作
        using (var db = new MyAppDBContext())
        {
            var objectContext = ((IObjectContextAdapter)db).ObjectContext;
            var mappingCollection = (System.Data.Entity.Core.Mapping.StorageMappingItemCollection)objectContext.MetadataWorkspace.GetItemCollection(System.Data.Entity.Core.Metadata.Edm.DataSpace.CSSpace);
            mappingCollection.GenerateViews(new System.Collections.Generic.List<System.Data.Entity.Core.Metadata.Edm.EdmSchemaError>());
        }
    } 

  (3)写一个读取数据的方法,遍历读取Posts表记录(该表有1万行记录)

    static void ModelFirstReadPosts()
    {
        var dbContext = new MyAppDBContext();
        foreach (var item in dbContext.Posts)
        {
            Console.WriteLine("ID:{0},Title:{1}", item.Id, item.Title);
        }
    } 

  (4)编写入口方法,通过Stopwatch记录测试耗时

    class Program
    {
        static Program()
        {
            WarmupEntityFramework();
        }

        static void Main(string[] args)
        {
            Stopwatch watch = new Stopwatch();
            watch.Start();
            // EF:4.9s
            ModelFirstReadPosts();
            watch.Stop();
            Console.WriteLine("Time consumed : {0} ms", watch.ElapsedMilliseconds);

            Console.ReadKey();
        }

        #region Method01.EntityFramework暖机操作
        static void WarmupEntityFramework()
        {
            // EF暖机操作
            using (var db = new MyAppDBContext())
            {
                var objectContext = ((IObjectContextAdapter)db).ObjectContext;
                var mappingCollection = (System.Data.Entity.Core.Mapping.StorageMappingItemCollection)objectContext.MetadataWorkspace.GetItemCollection(System.Data.Entity.Core.Metadata.Edm.DataSpace.CSSpace);
                mappingCollection.GenerateViews(new System.Collections.Generic.List<System.Data.Entity.Core.Metadata.Edm.EdmSchemaError>());
            }
        } 
        #endregion

        #region Method02.Model First方式读取数据库表记录
        static void ModelFirstReadPosts()
        {
            var dbContext = new MyAppDBContext();
            foreach (var item in dbContext.Posts)
            {
                Console.WriteLine("ID:{0},Title:{1}", item.Id, item.Title);
            }
        } 
        #endregion
    }

  F5调试运行,首次查询结果如下图所示:

  五次查询之后平均耗时:4.9s

二、Dapper

2.1 关于Dapper

  Dapper是一个开源轻的量级的ORM,只有一个代码文件,完全开源,你可以放在项目里的任何位置,来实现数据到对象的ORM操作,体积小速度快。 

2.2 使用Dapper

  (1)通过nuget添加Dapper组件

  (2)针对MSSQL的查询和新增操作

    #region Method01.读取MSSQL单张表
    // 2.7s
    static void DapperReadPosts()
    {
        using (SqlConnection connection = new SqlConnection(connStr))
        {
            var postList = connection.Query<Post>("select * from Posts");
            foreach (var item in postList)
            {
                Console.WriteLine("ID:{0},Title:{1}", item.Id, item.Title);
            }
        }
    }
    #endregion

    #region Method02.读取MSSQL连接查询
    // 2.6s
    static void DapperReadJoin()
    {
        using (SqlConnection connection = new SqlConnection(connStr))
        {
            // 这里查询结果是动态语言类型
            var postList = connection.Query("select Id,Title,GETDATE() as PostDate from Posts");
            foreach (var item in postList)
            {
                Console.WriteLine("ID:{0},PostDate:{1}", item.Id, item.PostDate);
            }
        }
    }
    #endregion

    #region Method03.读取MSSQL多个结果集
    // 2.8s
    static void DapperReadMultiResultSet()
    {
        using (SqlConnection connection = new SqlConnection(connStr))
        {
            using (var reader = connection.QueryMultiple("select * from Posts;select 1000 as Number;"))
            {
                var postList = reader.Read<Post>();
                foreach (var item in postList)
                {
                    Console.WriteLine("ID:{0},Title:{1}", item.Id, item.Title);
                }
            }
        }
    }
    #endregion

    #region Method04.插入MSSQL新记录
    // 0.37s
    static void InsertPostRecord()
    {
        using (SqlConnection connection = new SqlConnection(connStr))
        {
            // 多次插入单条记录
            int count = connection.Execute("insert into Posts values(@CategoryId, @Slug, @Title, @Published, @Excerpt, @Content);", new { CategoryId = 10, Slug = "BOOK", Title = "大话设计模式", Published = DateTime.Now.AddDays(1), Excerpt = "ChengJie", Content = "Design Patterns" });
            Console.WriteLine("受影响行数:{0}", count);

            count = connection.Execute("insert into Posts values(@CategoryId, @Slug, @Title, @Published, @Excerpt, @Content);", new Post() { CategoryId = 10, Slug = "BOOK", Title = "大话数据结构", Published = DateTime.Now.AddDays(1), Excerpt = "ChengJie", Content = "Data Structure" });

            Console.WriteLine("受影响行数:{0}", count);

            // 一次插入多条记录
            IList<Post> postRecords = new List<Post>();
            postRecords.Add(new Post() { CategoryId = 10, Slug = "BOOK", Title = "构建之法-现代软件工程", Published = DateTime.Now.AddDays(1), Excerpt = "ZouXin", Content = "Software Engineering" });
            postRecords.Add(new Post() { CategoryId = 10, Slug = "BOOK", Title = "编程之美", Published = DateTime.Now.AddDays(1), Excerpt = "ZouXin", Content = "I Love Coding" });
            count = connection.Execute("insert into Posts values(@CategoryId, @Slug, @Title, @Published, @Excerpt, @Content);", postRecords);

            Console.WriteLine("受影响行数:{0}", count);
        }
    }
    #endregion

  ① 棒棒哒的地方1:读取多表连接查询

        // 这里查询结果是动态语言类型
        var postList = connection.Query("select Id,Title,GETDATE() as PostDate from Posts");
        foreach (var item in postList)
        {
            Console.WriteLine("ID:{0},PostDate:{1}", item.Id, item.PostDate);
        }

  ② 棒棒哒的地方2:读取多个查询结果集

        using (var reader = connection.QueryMultiple("select * from Posts;select 1000 as Number;"))
        {
            var postList = reader.Read<Post>();
            foreach (var item in postList)
            {
                Console.WriteLine("ID:{0},Title:{1}", item.Id, item.Title);
            }
        }

  ③ 棒棒哒的地方3:一次插入多条数据记录

    // 一次插入多条记录
    IList<Post> postRecords = new List<Post>();
    postRecords.Add(new Post() { CategoryId = 10, Slug = "BOOK", Title = "构建之法-现代软件工程", Published = DateTime.Now.AddDays(1), Excerpt = "ZouXin", Content = "Software Engineering" });
    postRecords.Add(new Post() { CategoryId = 10, Slug = "BOOK", Title = "编程之美", Published = DateTime.Now.AddDays(1), Excerpt = "ZouXin", Content = "I Love Coding" });
    count = connection.Execute("insert into Posts values(@CategoryId, @Slug, @Title, @Published, @Excerpt, @Content);", postRecords);

  ④ 如何跨数据库读取数据记录:依赖于抽象,不依赖于具体

    static void GetPostsCrossMultiDB()
    {
        // 依赖于抽象,不依赖于具体
        using (IDbConnection connection = DbProviderFactories.GetFactory(connSetting.ProviderName).CreateConnection())
        {
            connection.ConnectionString = connSetting.ConnectionString;
            // 使用标准SQL语句屏蔽差异
            var postList = connection.Query<Post>("select * from Posts");
            foreach (var item in postList)
            {
                Console.WriteLine("ID:{0},Title:{1}", item.Id, item.Title);
            }
        }
    } 

  (3)测试结果:

方法

耗时

读取MSSQL单张表

2.7s

读取MSSQL连接查询

2.6s

读取MSSQL多个结果集

2.8s

多次插入MSSQL新记录

148ms

三、PetaPoco

3.1 关于PetaPoco

  PetaPoco是一款适用于.NET应用程序的轻型对象关系映射器。与那些功能完备的ORM(如NHibernate或Entity Framework)不同的是,PetaPoco更注重易用性和性能,而非丰富的功能。使用PetaPoco只需要引入一个C#文件,可以使用强类型的 POCO(Plain Old CLR Object),并支持使用T4模板生成的类等等。

3.2 使用PetaPoco

  (1)通过nuget添加PetaPoco组件

  (2)编辑Database.tt模板文件,前提是首先将连接字符串配置正确

  (3)针对MSSQL的读取和插入操作

    private static void ReadAllPostData()
    {
        using (var context = new MyAppDBContext())
        {
            var postList = context.Query<Post>("select * from Posts");
            foreach (var item in postList)
            {
                Console.WriteLine("ID:{0},Title:{1}", item.Id, item.Title);
            }
        }
    }

    private static void InsertNewPostData()
    {
        var post = new Post
        {
            CategoryId = 1,
            Slug = "BOOK",
            Title = "Microsoft SQL Server 2008技术内幕",
            Content = Guid.NewGuid().ToString(),
            Excerpt = Guid.NewGuid().ToString(),
            Published = DateTime.Now
        };

        var count = post.Insert();

        Console.WriteLine("受影响行数:{0}", count);
    }

  (4)测试结果:

方法

耗时

读取MSSQL单张表

2.7s

插入MSSQL新纪录

30ms

SourceCode

(1)ORMDemo:http://pan.baidu.com/s/1pJAEf0n

Reference

(1)Dapper.NET:https://github.com/StackExchange/dapper-dot-net

作者:周旭龙

出处:http://edisonchou.cnblogs.com

本文版权归作者和博客园共有,欢迎转载,但未经作者同意必须保留此段声明,且在文章页面明显位置给出原文链接。

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏乐沙弥的世界

Oracle RAC环境下配置statspack

    Statspack是Oracle 9i时代的产物,对于监控与分析数据库性能有着跨里程碑的意义,是AWR的前身。在Oracle 10g后AWR取代了sta...

693
来自专栏杨建荣的学习笔记

原来Oracle也不喜欢“蜀黍"(r6笔记第54天)

今天在部署一个脚本的时候,碰到了一个奇怪的问题,脚本运行过程中报了一个ora错误 ORA-01756: quoted string not properly t...

2795
来自专栏大内老A

谈谈基于SQL Server 的Exception Handling[中篇]

三、TRY CATCH & Return 在上面一节中,我通过RAISERROR重写了创建User的Stored procedure,实际上上面的Stored ...

1846
来自专栏菩提树下的杨过

mybatis 使用经验小结

一、多数据源问题 主要思路是把dataSource、sqlSesstionFactory、MapperScannerConfigurer在配置中区分开,各Map...

2896
来自专栏数据小魔方

时间&日期函数

今天要跟大家简要介绍一下excel中经常会用到的日期与时间函数! 日期与时间类的函数虽然算所有函数中最难掌握的,但是因为格式众多,形式多样,而且作为其他高级函数...

3297
来自专栏飞扬的花生

文件方法

C# 获取指定目录下所有文件信息、移动目录、拷贝目录 /// <summary> /// 获取目录下的所有文件夹和文件的path ...

1915
来自专栏Hadoop数据仓库

Oracle 索引的分类

看到 itpub 论坛上的一个帖子,对 Oracle 的索引分类总结得言简意赅,于是收藏过来。又补充了一点RAC用到的反向索引的东西。 逻辑上:  Single...

1939
来自专栏杨建荣的学习笔记

记一次数据库重启后归档急剧增加的问题(98天)

在本地的环境中测试外部表的性能,由于空间有限,不一会儿归档的空间就爆了。然后文件貌似出现了系统级的问题,刚刚rm掉的归档日志文件。隔了几秒钟再ls,就出现了。怎...

3574
来自专栏张善友的专栏

微博内容长度计算函数(C#)

微博内容长度的计算方法(不一定完全无误,仅提供一个思路):        public static int GetWeiboContentLength(str...

2446
来自专栏分布式系统和大数据处理

Hive中分区和分桶的概念和操作

在使用传统的RDBMS数据库(关系数据库),例如MySql时,对于一些大表,我们通常会进行分表操作,以提升查询效率。在Hive中也提供了类似的概念和操作,本文将...

1641

扫码关注云+社区

领取腾讯云代金券