轻量型ORM框架Dapper的使用

在真实的项目开发中，可能有些人比较喜欢写SQL语句，但是对于EF这种ORM框架比较排斥，那么轻量型的Dapper就是一个不错的选择，即让你写sql语句了，有进行了关系对象映射。其实对于EF吧，我说下我个人的见解，EF是相对来说比较重的ORM框架，它是讲究通用性的框架，而非单纯的实现某种需求的框架，不得不否认的说，EF的开发效率要比用单纯的ADO.NET写sql语句的效率高的不是一点半点，可能很多人会说EF的性能低等等，针对这种问题有时候是需要折中的来讲，从另一个方面来讲，你用了ADO.NET写sql语句是性能好了，但是你得到的是弱类型的DataTable或者DataSet，常规在MVC的开发中，其实你难道不转换成集合或者单个对象吗？总不会拿着DataTable用吧，当你把弱类型的Datatable转换成List<T>的时候，一般来讲分两种转换，一种是利用反射，这其实也就成了关系对象映射了，跟ORM框架没什么区别了，第二种无非是循环赋值了，但是这种的开箱装箱的损耗也是很大的，最终你得到你想要的数据类型的时候其实折中算下来相比较EF直接得到，中间你又走了很多的弯路了，我在开发中一般EF打头镇，轻量的Dapper做辅助，因为有时候开发效率很重要，性能的问题我不会过多在SQL优化上下功夫，我一般会在中间缓存上做处理。下面是我简单的对Dapper的小包装，代码如下：

public class LiunianContext:IDisposable
    {
        private static readonly string _dbConnectionStr = ConfigurationManager.ConnectionStrings["XXXContext"].ConnectionString;

        private IDbConnection dbConnection;

        private IDbConnection DbConnection
        {
            get
            {
                if (_dbConnectionStr.IsNotNullOrEmpty())
                    dbConnection = new SqlConnection(_dbConnectionStr);
                else
                    throw new ArgumentNullException("dbConnectionStr");

                bool isClosed = dbConnection.State == ConnectionState.Closed;
                if (isClosed) dbConnection.Open();
                return dbConnection;
            }
        }

        /// <summary>
        /// 执行增删改操作(包括批量操作)
        /// </summary>
        /// <param name="sql">sql语句(有参数参数化)</param>
        /// <param name="param">参数化值</param>
        /// <returns></returns>
        public bool Execute(string sql, object param)
        {
            bool isSuccess = false;
            if (sql.IsNotNullOrEmpty())
            {
                try
                {
                    int result = DbConnection.Execute(sql, param);
                    isSuccess = result > 0 ? true : false;
                }
                catch
                {
                    isSuccess = false;
                }
            }
            return isSuccess;
        }

        /// <summary>
        /// 执行存储过程操作
        /// </summary>
        /// <param name="sql">存储过程名称</param>
        /// <param name="param">参数化值</param>
        /// <returns>返回存储过程是否执行成功</returns>
        public bool ExecuteStored(string storedName, object param)
        {
            bool isSuccess = false;
            if (storedName.IsNotNullOrEmpty())
            {
                try
                {
                    int result = DbConnection.Execute(storedName, param, commandType: CommandType.StoredProcedure);
                    isSuccess = result > 0 ? true : false;
                }
                catch
                {
                    isSuccess = false;
                }
            }
            return isSuccess;
        }

        /// <summary>
        /// 执行存储过程操作
        /// </summary>
        /// <param name="storedName">存储过程名称</param>
        /// <param name="param">存储过程参数</param>
        /// <returns>返回存储过程要返回的值</returns>
        public DynamicParameters ExecuteStored(string storedName, DynamicParameters param)
        {
            if (storedName.IsNotNullOrEmpty())
            {
                try
                {
                    DbConnection.Execute(storedName, param, commandType: CommandType.StoredProcedure);
                }
                catch { }
            }
            return param;
        }

        /// <summary>
        /// 查询操作
        /// </summary>
        /// <typeparam name="T">返回集合的类型</typeparam>
        /// <param name="sql">sql语句</param>
        /// <param name="param">参数化值</param>
        /// <returns></returns>
        public IEnumerable<T> Query<T>(string sql, object param)
        {
            IEnumerable<T> _list = default(IEnumerable<T>);
            if (!string.IsNullOrEmpty(sql))
            {
                try
                {
                    _list = DbConnection.Query<T>(sql, param);
                }
                catch { }
            }
            return _list;
        }

        /// <summary>
        /// 执行存储过程查询操作
        /// </summary>
        /// <typeparam name="T">返回集合的类型</typeparam>
        /// <param name="storedName">存储过程</param>
        /// <param name="param">参数化值</param>
        /// <returns></returns>
        public IEnumerable<T> QueryStored<T>(string storedName, object param)
        {
            IEnumerable<T> _list = default(IEnumerable<T>);
            if (!string.IsNullOrEmpty(storedName))
            {
                try
                {
                    _list = DbConnection.Query<T>(storedName,commandType: CommandType.StoredProcedure);
                }
                catch { }
            }
            return _list;
        }

        /// <summary>
        /// 查询操作返回默认第一条数据(如返回null则创建默认类型)
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="sql"></param>
        /// <param name="param"></param>
        /// <returns></returns>
        public T FirstOrDefault<T>(string sql, object param)
        {
            var model = default(T);
            if (!string.IsNullOrEmpty(sql))
            {
                try
                {
                    model = DbConnection.Query<T>(sql, param).FirstOrDefault();
                }
                catch { }
            }
            return model == null ? Activator.CreateInstance<T>() : model;
        }

        /// <summary>
        /// 查询一组SQL语句并返回值
        /// </summary>
        /// <typeparam name="T1">第一条语句返回集合类型</typeparam>
        /// <typeparam name="T2">第二条语句返回集合类型</typeparam>
        /// <param name="sql">sql语句</param>
        /// <param name="param">参数化值</param>
        /// <returns></returns>
        public Tuple<IEnumerable<T1>, IEnumerable<T2>> Query<T1, T2>(string sql, object param)
        {
            IEnumerable<T1> _item1 = null; IEnumerable<T2> _item2 = null;
            if (!string.IsNullOrEmpty(sql))
            {
                try
                {
                    using (var multi = DbConnection.QueryMultiple(sql, param))
                    {
                        _item1 = multi.Read<T1>();
                        _item2 = multi.Read<T2>();
                    }
                }
                catch { }
            }
            return Tuple.Create<IEnumerable<T1>, IEnumerable<T2>>(_item1, _item2);
        }

        /// <summary>
        /// 查询一组SQL语句并返回值
        /// </summary>
        /// <typeparam name="T1">第一条语句返回集合类型</typeparam>
        /// <typeparam name="T2">第二条语句返回集合类型</typeparam>
        /// <typeparam name="T3">第三条语句返回集合类型</typeparam>
        /// <param name="sql">sql语句</param>
        /// <param name="param">参数化值</param>
        /// <returns></returns>
        public Tuple<IEnumerable<T1>, IEnumerable<T2>, IEnumerable<T3>> Query<T1, T2, T3>(string sql, object param)
        {
            IEnumerable<T1> _item1 = null; IEnumerable<T2> _item2 = null; IEnumerable<T3> _item3 = null;
            if (!string.IsNullOrEmpty(sql))
            {
                try
                {
                    using (var multi = DbConnection.QueryMultiple(sql, param))
                    {
                        _item1 = multi.Read<T1>();
                        _item2 = multi.Read<T2>();
                        _item3 = multi.Read<T3>();
                    }
                }
                catch { }
            }
            return Tuple.Create<IEnumerable<T1>, IEnumerable<T2>, IEnumerable<T3>>(_item1, _item2, _item3);
        }

        public void Dispose()
        {
            if (dbConnection != null)
            {
                try
                {
                    bool isClosed = dbConnection.State == ConnectionState.Closed;
                    if (!isClosed) dbConnection.Close();
                    //dbConnection.Dispose();
                }
                catch { }
            }
        }
    }

调用示例如下：

public abstract class BaseProvide
    {
        public Lazy<LiunianContext> lazyContext;

        protected LiunianContextDb
        {
            get
            {
                return lazyContext.Value;
            }
        }

    }

   public class EmployeeProvide : BaseProvide
    {
        /// <summary>
        /// 获取数据
        /// </summary>
        /// <returns></returns>
        public List<Employee> ListEmployeeByParam(int[] param)
        {
            string sql = "select * from Employee where ID in @Ids";
            return Db.Query<Employee>(sql, new { Ids = param }).ToList();
        }

        /// <summary>
        /// 获取全部数据
        /// </summary>
        /// <returns></returns>
        public List<Employee> ListEmployee()
        {
            string sql = "select * from Employee";
            return Db.Query<Employee>(sql,null).ToList();
        }

        /// <summary>
        /// 查询单个实体
        /// </summary>
        /// <param name="Id"></param>
        /// <returns></returns>
        public Employee loadEmployee(int Id)
        {
            string sql = "select * from Employee where ID= @Id";
            return Db.FirstOrDefault<Employee>(sql, new { Id = Id });
        }

        /// <summary>
        /// 插入操作
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public bool InsertEmployee(Employee model)
        {
            StringBuilder sql = new StringBuilder();
            sql.Append("insert into Employee values (@UpdateTime,@CreateTime,@State,@LoginName,@UserName,");
            sql.Append("@RoleId,@IsUse)");
            return Db.Execute(sql.ToString(), model);
        }

        /// <summary>
        /// 更新操作
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public bool UpdateEmployee(Employee model)
        {
            StringBuilder sql = new StringBuilder();
            sql.Append("update Employee set UpdateTime = @UpdateTime where  ID = @ID");
            return Db.Execute(sql.ToString(), model);
        }

        /// <summary>
        /// 删除操作
        /// </summary>
        /// <param name="Id"></param>
        /// <returns></returns>
        public bool DeleteEmployeeById(int Id)
        {
            string sql = "delete from Employee where ID = @Id";
            return Db.Execute(sql.ToString(), new { Id = Id });
        }

        /// <summary>
        /// 执行多个语句返回多个结果
        /// </summary>
        /// <param name="Id"></param>
        /// <returns></returns>
        public Tuple<int,IEnumerable<Employee>> ListGroupEmployee()
        {
            string sql = "select Count(*) from Employee select * from Employee";
            Tuple<IEnumerable<int>, IEnumerable<Employee>> queryGroup = Db.Query<int, Employee>(sql, null);
            return Tuple.Create<int, IEnumerable<Employee>>(queryGroup.Item1.FirstOrDefault(),queryGroup.Item2);
        }

    }

除了没把事务加上之外其他的增删改查都有了，同时在传对象的时候Dapper也解决了sql注入的问题，在性能上也是比较好的ORM框架，需要的拿去！

时间： 2024-10-09 23:14:38

轻量型ORM框架Dapper的使用的相关文章

五款轻量型bug管理工具横向测评

最近正在使用的本地bug管理软件又出问题了,已经记不清这是第几次了,每次出现问题都要耗费大量的时间精力去网上寻找解决方案,劳心劳力.为了避免再次出现这样的情况,我决定从线下转到线上,使用轻量型的在线bug管理工具,在选择工具时有以下几个要求: 1．不用在本地安装部署,配置环境,即开即用: 2．方便bug管理,bug属性设置: 3．可以跨团队沟通,方便和开发协作: 4．随时掌握bug状态,修复进展等. 花费了一个星期的时间试用了五款在线bug管理工具,其评测结果如下: 1.   Teambitio

.NET轻量级ORM框架Dapper入门精通

一.课程介绍 本次分享课程包含两个部分<.NET轻量级ORM框架Dapper修炼手册>和<.NET轻量级ORM框架Dapper葵花宝典>,阿笨将带领大家一起领略轻量级ORM框架Dapper的魅力. 本次分享课程适合人群范围: 一.<.NET轻量级ORM框架Dapper修炼手册>适合人群如下: 1.我是一个新手,主要工作面向的是MS SQL Server数据库,那么选择修炼手册一定没错. 2.对Dapper从没有过了解或者了解不全面的同学,想通过学习进一步提升对Dappe

Metricbeat 轻量型指标采集器

一.介绍 用于从系统和服务收集指标.从 CPU 到内存,从 Redis 到 Nginx,Metricbeat 能够以一种轻量型的方式,输送各种系统和服务统计数据. 1.系统级监控,更简洁(轻量型指标采集器) 将 Metricbeat 部署到您所有的 Linux.Windows 和 Mac 主机,并将它连接到 Elasticsearch 就大功告成啦:您可以获取系统级的 CPU 使用率.内存.文件系统.磁盘 IO 和网络 IO 统计数据,以及获得如同系统上 top 命令类似的各个进程的统计数据.

轻量的web框架Bottle

简洁的web框架Bottle 简介 Bottle是一个非常简洁,轻量web框架,与django形成鲜明的对比,它只由一个单文件组成,文件总共只有3700多行代码,依赖只有python标准库.但是麻雀虽小五脏俱全,基本的功能都有实现,很适合做一些小的web应用 开始使用 首先使用pip install bottle安装然后是一个官方文档中的例子: from bottle import route, run @route('/hello') def hello(): return "Hello Wo

.NET轻量级ORM框架Dapper修炼手册

一.摘要 1.1.为什么叫本次的分享课叫<修炼手册>? 阿笨希望本次的分享课中涉及覆盖的一些小技巧.小技能给您带来一些帮助.希望您在日后工作中把它作为一本实际技能手册进行储备,以备不时之需,一旦当手头遇到与Dapper修炼手册中相似用法的地方和场景,可以直接拿来进行翻阅并灵活的运用到项目中.最后阿笨建议您可以根据自己在工作中碰到的不同的使用场景,不断的完善此本修炼手册. 废话不多说,直接上干货,我们不生产干货,我们只是干货的搬运工. 四.涉及覆盖的知识点 1.C# Linq To Xml技术.

基于轻量级ORM框架Dapper的扩展说明

这里简单的介绍一下本人基于Dapper作的一些简单的扩展,供大家参考. 为何要使用这款框架,相信大家看到下面排名就清楚了 其实在各大网站上,我们大概都会看到这样的一个对比效果图,在超过500次poco serialization的过程中所表现的性能,我们发现dapper是第二名, 当然第一名谁也无法超越,越底层的当然久越快,同时也就越麻烦. 至于如何使用进行基本的数据操作,我这里就不再阐述,http://www.cnblogs.com/Sinte-Beuve/p/4231053.html这里介绍

微型orm框架--dapper的简单使用

1.安装 首先使用nuget安装dapper,因为这里的示例是使用mysql,所以还要安装mysql的驱动.如下图: 2 数据库表 脚本 SET FOREIGN_KEY_CHECKS=0; -- ---------------------------- -- Table structure for class -- ---------------------------- DROP TABLE IF EXISTS `class`; CREATE TABLE `class` ( `id` int(

Sharepoint构建轻量型应用之InfoPath的简单应用案例！

1.   很遗憾,在office 2016 版本中已经将表单功能移除,office 2013 版本已经成了infopath 绝唱,所以我们必须安装office 2013 版本的office Professional plus来完成我们的表单组件安装: 2.   点开infopath Deisgner,我们可以看到可以创建的组件: 3.   这里我们可以创建多种表单,我们这次做一个简单的案例,建立一个标准的空白表单后点击设计后进入到相应的表单设计界面,我们先设计好整个页面的布局: 4.   基于简

轻量级ORM框架 Dapper快速学习

好在有师兄师姐一起带着做,所以开始没那么困难,但是由于大学涉猎范围有限,往往有很尴尬的时候,不懂构造方法重载,去“请教”,本来以为师兄会帮忙写好,结果“我念,你来写”,被深深的激励了一把,后来就早出晚归补习练习,java有所成长.实验室的项目是以Elipse插件形式给某研究所做一个工具,所以当时对Eclipse的了解很是深入,用到GEF图形编辑框架,SWT来做界面.自己用XML做存储来实现复制粘贴,还第一次用到了设计模式,visitor.实验室的节奏一直是“时间紧,任务重,成败在此一举”的节奏,