如何使用Dapper CURD操作(curd,dapper,开发技术)

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

usingSystem;usingSystem.Collections.Generic;usingSystem.Linq;usingSystem.Text;usingSystem.Threading.Tasks;namespaceDapperApplicationDemo.Model{publicclassUser{publicintUserId{get;set;}publicstringUserName{get;set;}publicstringEmail{get;set;}publicstringAddress{get;set;}}}

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

一、插入数据

1、使用匿名类插入数据

IDbConnectionconnection=newSqlConnection(conn);varresult=connection.Execute("InsertintoUsersvalues(@UserName,@Email,@Address)",new{UserName="Tom",Email="747954712@qq.com",Address="北京"});

查询数据库：

2、使用实体类插入数据

stringsqlCommandText="insertintoUsers(UserName,Email,Address)Values(@UserName,@Email,@Address)";using(IDbConnectionconnection=newSqlConnection(conn)){Useruser=newUser(){UserName="tim",Email="78415155@qq.com",Address="北京"};intresult=connection.Execute(sqlCommandText,user);if(result>0){Console.WriteLine("插入成功!");}else{Console.WriteLine("插入失败!");}}

查询数据库：

3、InsertBulk操作

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

using(IDbConnectionconnection=newSqlConnection(conn)){varuserList=Enumerable.Range(1012,100000).Select(i=>newUser(){Email=i+"qq.com",Address="北京",UserName="CK"+i,});varresult=connection.Execute("insertintoUsersvalues(@UserName,@Email,@Address)",userList);}

查询数据库：

二、查询数据

using(IDbConnectionconnection=newSqlConnection(conn)){//查询varquery=connection.Query<User>("SELECT*FROMUsers");query.AsList().ForEach(p=>{Console.WriteLine("Id:"+p.UserId+"UserName:"+p.UserName+"Email:"+p.Email+"Address:"+p.Address);});}

程序运行结果：

三、更新数据

1、使用匿名类更新

using(IDbConnectionconnection=newSqlConnection(conn)){varresult=connection.Execute("updateUserssetUserName='Tim',Address='上海'whereUserId=@UserId",new{UserId=2});}

查询数据库：

2、使用实体类更新

using(IDbConnectionconnection=newSqlConnection(conn)){Useruser=newUser();user.UserName="张无忌";user.UserId=1;varresult=connection.Execute("updateUserssetUserName=@UserNamewhereUserId=@UserId",user);}

查询数据库：

3、使用键值对更新

using(IDbConnectionconnection=newSqlConnection(conn)){List<KeyValuePair<string,object>>keys=newList<KeyValuePair<string,object>>();keys.Add(newKeyValuePair<string,object>("@UserName","风清扬"));keys.Add(newKeyValuePair<string,object>("@UserId",2));varresult=connection.Execute("updateUserssetUserName=@UserNamewhereUserId=@UserId",keys);}

查询数据库：

四、删除数据

1、使用匿名类删除数据

using(IDbConnectionconnection=newSqlConnection(conn)){varresult=connection.Execute("deletefromUserswhereUserId=@UserId",new{UserId=3});}

2、使用实体类删除数据

using(IDbConnectionconnection=newSqlConnection(conn)){Useruser=newUser();user.UserId=4;varresult=connection.Execute("deletefromUserswhereUserId=@UserId",user);}