轻量级ORM框架Dapper应用之实现CURD操作

在上一篇文章中,讲解了如何安装Dapper,这篇文章中将会讲解如何使用Dapper使用CURD操作。

例子中使用到的实体类定义如下:

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace DapperApplicationDemo.Model
{
   public class User
    {
        public int UserId { get; set; }

        public string UserName { get; set; }

        public string Email { get; set; }

        public string Address { get; set; }
    }
}

注意:在使用下面的方法之前要首先引入Dapper的命名空间:Using Dapper;

一、插入数据

1、使用匿名类插入数据

IDbConnection connection = new SqlConnection(conn);
var result = connection.Execute(
"Insert into Users values (@UserName, @Email, @Address)",
new { UserName = "Tom", Email = "747954712@qq.com", Address = "北京" });

查询数据库:

2、使用实体类插入数据

string sqlCommandText = "insert into Users(UserName,Email,Address) Values (@UserName,@Email,@Address)";
using (IDbConnection connection = new SqlConnection(conn))
{
      User user = new User()
      {
           UserName = "tim",
           Email = "78415155@qq.com",
           Address = "北京"
       };
      int result = connection.Execute(sqlCommandText,user);
      if (result > 0)
      {
          Console.WriteLine("插入成功!");
      }
      else
      {
          Console.WriteLine("插入失败!");
      }
}

查询数据库:

3、InsertBulk操作

既然是Bulk操作,那肯定就是批量插入了,我们要做的就是将上面使用到的“匿名对象”变成“匿名对象集合”就可以了,代码如下:

using (IDbConnection connection = new SqlConnection(conn))
{
         var userList = Enumerable.Range(1012, 100000).Select(i => new User()
         {
                Email = i + "qq.com",
                Address = "北京",
                UserName = "CK" + i,
          });
          var result = connection.Execute("insert into Users values(@UserName,@Email,@Address)", userList);
}

查询数据库:

二、查询数据

using (IDbConnection connection = new SqlConnection(conn))
{
        // 查询
        var query = connection.Query<User>("SELECT * FROM Users");
        query.AsList().ForEach(p =>
        {
              Console.WriteLine("Id:"+p.UserId+" UserName:"+p.UserName+" Email:"+p.Email+" Address:"+p.Address);
        });
}

程序运行结果:

三、更新数据

1、使用匿名类更新

using (IDbConnection connection = new SqlConnection(conn))
{
       var result = connection.Execute("update Users set UserName='Tim',Address='上海' where UserId=@UserId", new { UserId = 2 });
}

查询数据库:

2、使用实体类更新

using (IDbConnection connection = new SqlConnection(conn))
{
        User user = new User();
        user.UserName = "张无忌";
        user.UserId = 1;
        var result = connection.Execute("update Users set UserName=@UserName where UserId=@UserId", user);
}

查询数据库:

3、使用键值对更新

using (IDbConnection connection = new SqlConnection(conn))
{
       List<KeyValuePair<string, object>> keys = new List<KeyValuePair<string, object>>();
       keys.Add(new KeyValuePair<string, object>("@UserName", "风清扬"));
       keys.Add(new KeyValuePair<string, object>("@UserId", 2));
       var result = connection.Execute("update Users set UserName=@UserName where UserId=@UserId", keys);
}

查询数据库:

四、删除数据

1、使用匿名类删除数据

using (IDbConnection connection = new SqlConnection(conn))
{
       var result = connection.Execute("delete from Users where UserId=@UserId", new { UserId = 3 });
}

2、使用实体类删除数据

using (IDbConnection connection = new SqlConnection(conn))
{
        User user = new User();
        user.UserId = 4;
        var result = connection.Execute("delete from Users where UserId=@UserId", user);
}

示例程序代码下载地址:点此下载

到此这篇关于使用Dapper实现CURD操作的文章就介绍到这了。希望对大家的学习有所帮助,也希望大家多多支持我们。

(0)

相关推荐

  • 轻量级ORM框架Dapper应用之安装Dapper

    一.Dapper简介 Dapper是一款轻量级ORM框架,为解决网站访问流量极高而产生的性能问题而构造,主要通过执行TSQL表达式而实现数据库的CQRS. 如果你在项目中遇到性能访问问题,选择Dapper作为ORM框架可能是明智之举,当然也可以使用Entity Framework或NHibernate来处理大数据访问及关系映射. 二.为什么选择Dapper 1.轻量:只有一个文件(SqlMapper.cs),编译完成之后只有140K. 2.速度快:Dapper的速度接近于IDataReader,

  • 轻量级ORM框架Dapper应用之实现CURD操作

    在上一篇文章中,讲解了如何安装Dapper,这篇文章中将会讲解如何使用Dapper使用CURD操作. 例子中使用到的实体类定义如下: using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading.Tasks; namespace DapperApplicationDemo.Model { public class User { public

  • 轻量级ORM框架Dapper应用之实现Join操作

    在这篇文章中,讲解如何使用Dapper使用Inner join的操作 1.新创建两张表:Users表和Product表 Users表定义如下: CREATE TABLE [dbo].[Users]( [UserId] [int] IDENTITY(1,1) NOT NULL, [UserName] [varchar](16) NULL, [Email] [varchar](32) NULL, [Address] [varchar](128) NULL, PRIMARY KEY CLUSTERED

  • 轻量级ORM框架Dapper应用之实现In操作

    IN 操作符允许我们在 WHERE 子句中规定多个值. 本篇文章中,还是使用和上篇文章中同样的实体类和数据库,Dapper使用in操作符的代码如下: using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading.Tasks; using System.Configuration; using Dapper; using System.Data

  • 轻量级ORM框架Dapper应用支持操作函数和事物

    dapper除了支持基础的CURD.存储过程以外,还支持操作函数和事物. dapper操作函数的代码如下: using Dapper; using System; using System.Collections.Generic; using System.Configuration; using System.Data; using System.Data.SqlClient; using System.Linq; using System.Text; using System.Threadi

  • 轻量级ORM框架Dapper应用之返回多个结果集

    使用Dapper的QueryMultiple方法可以一次执行多条SQL语句,返回多个结果集,代码如下 using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading.Tasks; using System.Configuration; using Dapper; using System.Data; using System.Data.SqlC

  • 轻量级ORM框架Dapper应用之Dapper支持存储过程

    在Entity Framework中讲解了EF如何支持存储过程,同样,Dapper也支持存储过程,只需要在Query()方法的CommandType中标记使用的是存储过程就可以了.在Users表上面创建如下的存储过程: CREATE proc sp_GetUserByUserName @UserName varchar(16) as begin select * FROM Users WHERE UserName=@UserName end GO 调用存储过程的代码如下: using Syste

  • 轻量级ORM框架Dapper应用之实现DTO

    一.什么是DTO 先来看看百度百科的解释: 数据传输对象(DTO)(Data Transfer Object),是一种设计模式之间传输数据的软件应用系统.数据传输目标往往是数据访问对象从数据库中检索数据.数据传输对象与数据交互对象或数据访问对象之间的差异是一个以不具有任何行为除了存储和检索的数据(访问和存取器). 二.为什么需要DTO 在一个软件系统的实现中,我们常常需要访问数据库,并将从数据库中所取得的数据显示在用户界面上.这样做的一个问题是:用于在用户界面上展示的数据模型和从数据库中取得的数

  • Python轻量级ORM框架Peewee访问sqlite数据库的方法详解

    本文实例讲述了Python轻量级ORM框架Peewee访问sqlite数据库的方法.分享给大家供大家参考,具体如下: ORM框架就是 object relation model,对象关系模型,用来实现把数据库中的表 映射到 面向对象编程语言中的类,不需要写sql,通过操作对象就能实现 增删改查. ORM的基本技术有3种: (1)映射技术 数据类型映射:就是把数据库中的数据类型,映射到编程语言中的数据类型.比如,把数据库的int类型映射到Python中的integer 类型. 类映射:把数据库中的

  • Python的轻量级ORM框架peewee使用教程

    ORM框架使用最广泛的就是SQLAlchemy和Django自带的ORM框架,但是SQLAlchemy的语法显然相对Django的ORM框架麻烦一点. 而Django本身是一个web框架,比较重量级,仅仅为了使用Django的ORM框架的功能,而安装Django有点导致系统臃肿.而peewee这个框架语法几乎与Django的ORM框架一致,而又非常轻量. 它的安装非常简单: pip install peewee 如果你在使用mysql数据库的过程中报出如下错误: peewee.Improperl

随机推荐