查漏补缺系列之dapper初体验

什么是dapper

在维护一些较老的项目的时候，往往我们会用很多sql那么这个时候我们要考虑优化这些项目的时候，我们就可以使用dapper

dapper 是一款轻量级的ORM框架，它的优势很多轻量级，速度快，而且还支持不同的数据库，github地址如下：

https://github.com/StackExchange/Dapper

准备工作

本次为了演示，我们引用NUnit做单测，通过SQL Server Profiler来监控生成的sql语句。

dapper引用也特别方面我们可以通过NuGet下载引用dapper程序包，然后我们在类里引用using Dapper;就可以了。

数据库表结构如下：

另外我们还要创建一个名为DapperTestModel 的实体

public class DapperTestModel

    {

         public int Id { get; set; }

         public  string Message { get; set; }

    }

让我们准备好链接字符串开始本次演示吧

private string connString =

            System.Configuration.ConfigurationManager.ConnectionStrings["sqlConnectionString"].ConnectionString;

编辑

编辑代码如下，我们把新增和修改的方法写在一起，通过判断ID是否为0来觉得是新增还是修改。首先我们演示新增方法

        [Test]

        public void Edit()

        {

            int ID = 0;

            string sql = "insert into dappertest([Message])values(@Message)";

            using (IDbConnection conn = new SqlConnection(connString))

            {

                if (ID > 0)

                {

                    sql = "update dappertest set [Message]=@Message where Id=@ID";

                    conn.Execute(sql, new {ID = ID, Message = "修改这句话"});

                }

                else

                {

                    conn.Execute(sql, new { Message = "添加一句话" });

                }

            }

        }

这里我们看到dapper很方便的一点就是我们可以使对象来代替参数，这里我们就可以通过匿名对象来传递参数

好了我们执行单测，看看数据库中执行的语句

exec sp_executesql N'insert into dappertest([Message])values(@Message)',N'@Message nvarchar(4000)',@Message=N'添加一句话'

我们在去数据库中查看一下数据

接着我们去修改ID来看看修改方法

exec sp_executesql N'update dappertest set [Message]=@Message where Id=@ID',N'@ID int,@Message nvarchar(4000)',@ID=10,@Message=N'修改这句话'

我们再去数据库中查看一下数据情况

查询

dapper的查询功能也很灵活，比如我们需要获取一个list列表，如果换成使用DBHelper类，我们可能需要先查询一个DateSet然后再将其转成list，那么使用dapper我们可以直接转成list，我们来看看具体的实现代码

        [Test]

        public void GetList()

        {

            using (IDbConnection conn = new SqlConnection(connString))

            {

                string sql = "select ID,[Message] from dappertest";

                List<DapperTestModel> dapperList = conn.Query<DapperTestModel>(sql).ToList();

            }

        }

我们在看看数据库中的执行情况

select ID,[Message] from dappertest

删除

删除和新增修改的方式一致，代码如下

        [Test]

        public void Delete()

        {

            int ID = 10;

            using (IDbConnection conn = new SqlConnection(connString))

            {

                int retrunCount = 0;

                string sql = "delete from dappertest where id=@ID";

                    retrunCount = conn.Execute(sql, new { ID = ID });

            }

        }

同样的我们看看数据库中的执行语句

exec sp_executesql N'delete from dappertest where id=@ID',N'@ID int',@ID=10

我们再查询看看

存储过程

我们再来看看存储过程的调用，首先我们在数据库中添加一个简单的存储过程

CREATE PROCEDURE DapperInsert

@Message nvarchar(200)

AS

insert into dappertest([message])

values(@Message)

然后我们去调用这个存储过程

        [Test]

        public void PInsert()

        {

            using (IDbConnection conn = new SqlConnection(connString))

            {

                conn.Execute("DapperInsert",new {Message="这是存储过程新增的"}, null, null,CommandType.StoredProcedure);

            }

        }

同样的我们看看数据库中的执行情况

exec DapperInsert @Message=N'这是存储过程新增的'

事务

在平常的业务系统中，我们或多或少会用到事务，那么接下来我们演示一下在dapper中事务的调用

       [Test]

        public void Insert()

        {

            using (IDbConnection conn = new SqlConnection(connString))

            {

                conn.Open();

                //开始事务

                IDbTransaction transaction = conn.BeginTransaction();

                try

                {

                    string sql = "insert into dappertest([Message])values(@Message)";

                    string sql2 = "insert into dappertest([Message])values(@Message)";

                     conn.Execute(sql, new { Message ="再次新增一句话" }, transaction);

                     conn.Execute(sql2, new { Message=""}, transaction);

                    //提交事务

                    transaction.Commit();

                }

                catch (Exception ex)

                {

                    //出现异常，事务Rollback

                    transaction.Rollback();

                    throw new Exception(ex.Message);

                }

            }

        }

我们故意使其在第二次新增的时候报错

我们看看数据库中的执行情况，这里数据库会执行了两次

第一次

exec sp_executesql N'insert into dappertest([Message])values(@Message)',N'@Message nvarchar(4000)',@Message=N'再次新增一句话'

第二次

insert into dappertest([Message])values()

这里我们失败回滚了，我们在看看数据库中的情框

我们看到数据库中果然没有新增数据，我们目的也达到了。

总结

本次我给大家带来了一些dapper的简单应用包括简单逻辑调用存储过程的调用，以及事务的调用，从我们的简单示例中我们看到，dapper是一款十分优秀的轻量级的ORM框架，如果我们需要维护那种sql语句特别多的项目时，可以考虑使用dapper，使用dapper我们可以通过对象很灵活的去给我们的sql语句或者存储过程传递参数，也可以很灵活的转换类型。

巴特西

查漏补缺系列之dapper初体验

什么是dapper

准备工作

编辑

查询

删除

存储过程

事务

总结

最新文章

热门文章