首页 / C# / C# Dapper 基本使用增删改查事务等

C# Dapper 基本使用增删改查事务等

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了C# Dapper 基本使用增删改查事务等，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含10751字，纯文字阅读大概需要16分钟。

内容图文

  1 using DapperTest.Models;
  2 using System.Collections.Generic;
  3 using System.Web.Http;
  4 using Dapper;
  5 using System.Data;
  6 using System.Data.SqlClient;
  7 using System.Linq;
  8 using System.Configuration;
  9  
 10 namespace DapperTest.Controllers
 11 {
 12     public class HomeController : ApiController
 13     {
 14         #region 查询
 15  
 16         /// <summary>
 17         /// 查询所有数据
 18         /// </summary>
 19         /// <returns></returns>
 20         [HttpGet]
 21         public IHttpActionResult GetStudentList()
 22         {
 23             string conStr = ConfigurationManager.AppSettings["SqlConnStr"];
 24             string sql = @"SELECT * FROM STUDENT";
 25             using (IDbConnection conn = new SqlConnection(conStr))
 26             {
 27                 var result = conn.Query<StudentInfo>(sql).ToList();
 28                 return Ok(ReturnJsonResult.GetJsonResult(RequestResult.请求成功, result));
 29             }
 30         }
 31  
 32         /// <summary>
 33         /// 查询指定ID单条数据(带参数)
 34         /// </summary>
 35         /// <returns></returns>
 36         [HttpGet]
 37         public IHttpActionResult GetStudentInfo(string ID)
 38         {
 39             string conStr = ConfigurationManager.AppSettings["SqlConnStr"];
 40             string sql = @"SELECT * FROM STUDENT WHERE STUID in @STUID";
 41             using (IDbConnection conn = new SqlConnection(conStr))
 42             {
 43                 var result = conn.Query<StudentInfo>(sql, new { STUID = ID });
 44                 return Ok(ReturnJsonResult.GetJsonResult(RequestResult.请求成功, result));
 45             }
 46         }
 47  
 48         /// <summary>
 49         /// IN查询
 50         /// </summary>
 51         /// <returns></returns>
 52         [HttpGet]
 53         public IHttpActionResult GetStudentInfos(string IDStr)
 54         {
 55             string conStr = ConfigurationManager.AppSettings["SqlConnStr"];
 56             string sql = @"SELECT * FROM STUDENT WHERE STUID in @STUIDStr";
 57             var IDArr = IDStr.Split(',');
 58             using (IDbConnection conn = new SqlConnection(conStr))
 59             {
 60                 var result = conn.Query<StudentInfo>(sql, new { STUIDStr = IDArr });
 61                 return Ok(ReturnJsonResult.GetJsonResult(RequestResult.请求成功, result));
 62             }
 63         }
 64  
 65         /// <summary>
 66         /// 两表联合查询
 67         /// </summary>
 68         /// <returns></returns>
 69         [HttpGet]
 70         public IHttpActionResult GetStudentAndClass()
 71         {
 72             string conStr = ConfigurationManager.AppSettings["SqlConnStr"];
 73             string sql = @"SELECT * FROM STUDENT A JOIN CLASS B ON A.FK_CLASSID = B.ID";
 74             using (IDbConnection conn = new SqlConnection(conStr))
 75             {
 76                 var result = conn.Query(sql);
 77                 return Ok(ReturnJsonResult.GetJsonResult(RequestResult.请求成功, result));
 78             }
 79         }
 80  
 81         #endregion
 82  
 83         #region 新增
 84  
 85  
 86         /// <summary>
 87         /// 插入单条数据(带参数)
 88         /// </summary>
 89         /// <returns></returns>
 90         [HttpPost]
 91         public IHttpActionResult AddStudent()
 92         {
 93             string conStr = ConfigurationManager.AppSettings["SqlConnStr"];
 94             string sql = @"INSERT INTO STUDENT (NAME,AGE,FK_CLASSID) VALUES (@NAME,@AGE,@CLASSID)";
 95  
 96             StudentInfo student = new StudentInfo
 97             {
 98                 Name = "恩格斯",
 99                 Age = 55,
100                 FK_ClassID = 1
101             };
102  
103             using (IDbConnection conn = new SqlConnection(conStr))
104             {
105                 var result = conn.Execute(sql, new { NAME = student.Name, AGE = student.Age, CLASSID = student.FK_ClassID });
106                 return Ok(ReturnJsonResult.GetJsonResult(RequestResult.请求成功, result));
107             }
108         }
109  
110  
111         /// <summary>
112         /// 插入单条数据(直接插入整个实体)
113         /// </summary>
114         /// <returns></returns>
115         [HttpPost]
116         public IHttpActionResult AddStudentInfo()
117         {
118             string conStr = ConfigurationManager.AppSettings["SqlConnStr"];
119             string sql = @"INSERT INTO STUDENT (NAME,AGE,FK_CLASSID) VALUES (@NAME,@AGE,@FK_CLASSID)";
120  
121             StudentInfo student = new StudentInfo
122             {
123                 Name = "马克思",
124                 Age = 55,
125                 FK_ClassID = 1
126             };
127  
128             using (IDbConnection conn = new SqlConnection(conStr))
129             {
130                 var result = conn.Execute(sql, student);
131                 return Ok(ReturnJsonResult.GetJsonResult(RequestResult.请求成功, result));
132             }
133         }
134  
135         /// <summary>
136         /// 插入多条数据(实体)
137         /// </summary>
138         /// <returns></returns>
139         [HttpPost]
140         public IHttpActionResult AddStudentList()
141         {
142             string conStr = ConfigurationManager.AppSettings["SqlConnStr"];
143             string sql = @"INSERT INTO STUDENT (NAME,AGE,FK_CLASSID) VALUES (@NAME,@AGE,@FK_CLASSID)";
144  
145             List<StudentInfo> list = new List<StudentInfo>();
146             for (int i = 0; i < 3; i++)
147             {
148                 StudentInfo student = new StudentInfo
149                 {
150                     Name = "强森" + i.ToString(),
151                     Age = 55,
152                     FK_ClassID = 1
153                 };
154                 list.Add(student);
155             }
156  
157             using (IDbConnection conn = new SqlConnection(conStr))
158             {
159                 var result = conn.Execute(sql, list);
160                 return Ok(ReturnJsonResult.GetJsonResult(RequestResult.请求成功, result));
161             }
162         }
163  
164         /// <summary>
165         /// 插入数据后返回自增主键
166         /// </summary>
167         /// <returns></returns>
168         [HttpPost]
169         public IHttpActionResult AddReturnID()
170         {
171             string conStr = ConfigurationManager.AppSettings["SqlConnStr"];
172             string sql = @"INSERT INTO STUDENT (NAME,AGE,FK_CLASSID) VALUES (@NAME,@AGE,@CLASSID)";
173  
174             StudentInfo student = new StudentInfo
175             {
176                 Name = "恩格斯",
177                 Age = 55,
178                 FK_ClassID = 1
179             };
180  
181             using (IDbConnection conn = new SqlConnection(conStr))
182             {
183                 sql += "SELECT SCOPE_IDENTITY()";
184                 var result = conn.Execute(sql, new { NAME = student.Name, AGE = student.Age, CLASSID = student.FK_ClassID });
185                 var id = conn.QueryFirstOrDefault<int>(sql, new { NAME = student.Name, AGE = student.Age, CLASSID = student.FK_ClassID });
186                 return Ok(ReturnJsonResult.GetJsonResult(RequestResult.请求成功, id));
187             }
188         }
189         #endregion
190  
191         #region 更新
192         /// <summary>
193         /// 使用实体更新
194         /// </summary>
195         /// <returns></returns>
196         [HttpPost]
197         public IHttpActionResult UpdateStudetInfo()
198         {
199             string conStr = ConfigurationManager.AppSettings["SqlConnStr"];
200             string sql = @"UPDATE STUDENT SET NAME=@NAME,AGE=@AGE,FK_CLASSID=@FK_CLASSID WHERE STUID = @StuID";
201             StudentInfo student = new StudentInfo
202             {
203                 StuID = 1,
204                 Name = "老夫子",
205                 Age = 59,
206                 FK_ClassID = 2
207             };
208             using (IDbConnection conn = new SqlConnection(conStr))
209             {
210                 var result = conn.Execute(sql, student);
211                 return Ok(ReturnJsonResult.GetJsonResult(RequestResult.请求成功, result));
212             }
213         }
214  
215         /// <summary>
216         /// 参数更新
217         /// </summary>
218         /// <returns></returns>
219         [HttpPost]
220         public IHttpActionResult UpdateStudet(int ID)
221         {
222             string conStr = ConfigurationManager.AppSettings["SqlConnStr"];
223             string sql = @"UPDATE STUDENT SET NAME=@NAME,AGE=@AGE,FK_CLASSID=@FK_CLASSID WHERE STUID = @StuID";
224             using (IDbConnection conn = new SqlConnection(conStr))
225             {
226                 var result = conn.Execute(sql, new {NAME = "尼古拉斯赵四",AGE = 1,StuID = ID});
227                 return Ok(ReturnJsonResult.GetJsonResult(RequestResult.请求成功, result));
228             }
229         }
230         #endregion
231  
232         #region 删除
233         public IHttpActionResult Delete(int ID)
234         {
235             string conStr = ConfigurationManager.AppSettings["SqlConnStr"];
236             string sql = @"DELETE STUDENT  WHERE STUID = @StuID";
237             using (IDbConnection conn = new SqlConnection(conStr))
238             {
239                 var result = conn.Execute(sql, new { StuID = ID });
240                 return Ok(ReturnJsonResult.GetJsonResult(RequestResult.请求成功, result));
241             }
242         }
243         #endregion
244  
245         #region 事务
246         [HttpPost]
247         public IHttpActionResult AddStudentT()
248         {
249             string conStr = ConfigurationManager.AppSettings["SqlConnStr"];
250             string sql = @"INSERT INTO STUDENT (NAME,AGE,FK_CLASSID) VALUES (@NAME,@AGE,@CLASSID)";
251  
252             StudentInfo student = new StudentInfo
253             {
254                 Name = "恩格斯",
255                 Age = 55,
256                 FK_ClassID = 1
257             };
258  
259             StudentInfo student2 = new StudentInfo
260             {
261                 Name = "恩格斯2",
262                 Age = 55,
263                 FK_ClassID = 1
264             };
265            
266             try
267             {
268                 using (IDbConnection conn = new SqlConnection(conStr))
269                 {
270                     IDbTransaction transaction = conn.BeginTransaction();
271                     var result = conn.Execute(sql, student);
272                     var result1 = conn.Execute(sql, student2);
273                     transaction.Commit();
274                     return Ok(ReturnJsonResult.GetJsonResult(RequestResult.请求成功, result));
275                 }
276             }
277             catch (System.Exception)
278             {
279                 throw;
280             }
281            
282         }
283         #endregion
284     }
285 }

内容总结

以上是互联网集市为您收集整理的C# Dapper 基本使用增删改查事务等全部内容，希望文章能够帮你解决C# Dapper 基本使用增删改查事务等所遇到的程序开发问题。如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容，请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/844329.html

来源：【匿名】

【上一篇】C# winform调用类似按钮点击的事件时自带参数该怎么写【下一篇】assemblyinfo.csC#Assembly类访问程序集信息

更多 ►

【C# Dapper 基本使用增删改查事务等】教程文章相关的互联网学习教程文章

C# MySQL ADO.Net Dapper query dynamic IDictionary<string,object>【代码】【图】

using MySql.Data.MySqlClient; using Dapper;staticvoid MySqlDapperDemo(){string connString = "Server=localhost;Port=3306;Database=firstSchema;Uid=UserName;Pwd=UserPwd;";using (MySqlConnection conn = new MySqlConnection(connString)){conn.Open();string querySQL = "select * from firstSchema.MyTB order by age;";var queryResult = conn.Query<dynamic>(querySQL).ToList();int queryCount = queryResult.Count(...

在C#的控制台应用中使用Dapper链接MySQL并执行一些增删改查【代码】【图】

一、首先先创建一个C#的控制台应用二、然后添加上必要的命名空间using System;using System.Collections.Generic;using MySql.Data.MySqlClient;using System.Data;using Dapper;using System.Linq; 三、首先配置好一个数据库中存在的类表：class Info{publicint action_id { get; set; }publicint parent_id { get; set; }publicstring action_code { get; set; }publicstring relevance { get; set; }} 四、添加Dapper和MYSQL的...

Dapper C# 访问SQLite【代码】

1.以操作SQLite为例.先下载Dapper,项目引用添加Dapper.dll，然后入下 SQLiteConnectionStringBuilder sb = new SQLiteConnectionStringBuilder(); sb.DataSource = @"D:sqlite.db"; SQLiteConnection con = new SQLiteConnection(sb.ToString()); con.Open(); string sql = "select * from user"; foreach( User u in con.Query<User>(sql)) {Console.WriteLine(u.Name); } con.Close(); 原文：http://www.cnblogs.com/bqh10086/p/...

C# Dapper 轻量ORM调试对SQLServer【代码】

Dapper简介Dapper只有一个代码文件，完全开源，你可以放在项目里的任何位置，来实现数据到对象的ORM操作，体积小速度快。使用ORM的好处是增、删、改很快，不用自己写sql，因为这都是重复技术含量低的工作，还有就是程序中大量的从数据库中读数据然后创建model,并为model字段赋值。这些ORM都可以轻松给你搞定。ORM给我们开发带来便利时，性能也是一个让我们不得不考虑的问题。一般的ORM性能和直接写原生的sql比都差不少，但是Dappe...

[LINQ2Dapper]最完整Dapper To Linq框架---基础查询

(一)Model实体类实体类层需要安装Kogel.Dapper.Extension表名字段特性。[更多特性详情请点击]using Kogel.Dapper.Extension.Attributes; public class users { /// <summary> /// 用户id(特性Identity标识该字段为主键) /// </summary> [Identity] public int id { get; set; } /// <summary> /// code /// </summary> public string code { get; se...

C# 数据操作系列 - 18 让Dapper更强的插件【图】

0. 前言在前一篇中我们讲到了Dapper的应用，但是给我们的感觉Dapper不像个ORM更像一个IDbConnection的扩展。是的，没错。在实际开发中我们经常用Dapper作为对EF Core的补充。当然了Dapper并不仅仅只有这些，就让我们通过这一篇文章去让Dapper更像一个ORM吧。1. Dapper ContribDapper Contrib 扩展了Dapper对于实体类的CRUD方法：安装方法：命令行：dotnet add package Dapper.ContribNuGet：Install-Package Dapper.Contrib使用：u...

C# 数据操作系列 - 17 Dapper ——号称可以与ADO.NET 同台飙车的ORM【图】

0. 前言之前四篇介绍了一个国内开发者开发的优秀框架SqlSugar，给我们眼前一亮的感觉。这一篇，我们将试试另一个出镜率比较高的ORM框架-Dapper。Dapper是一个轻量级的ORM框架，其以高速、简单易用为特点。在某些时候，效率甚至可以与ADO.NET 媲美。那么，吹得天花乱坠，就让我们实际看看它的表现吧。1. 开始使用照例，先创建一个项目：DapperDemodotnet new console --name DapperDemo然后切换到目录里：cd DapperDemo添加包支持：...

C# 数据操作系列 - 18 让Dapper更强的插件【代码】【图】

0. 前言在前一篇中我们讲到了Dapper的应用，但是给我们的感觉Dapper不像个ORM更像一个IDbConnection的扩展。是的，没错。在实际开发中我们经常用Dapper作为对EF Core的补充。当然了Dapper并不仅仅只有这些，就让我们通过这一篇文章去让Dapper更像一个ORM吧。 1. Dapper Contrib Dapper Contrib 扩展了Dapper对于实体类的CRUD方法：安装方法：命令行： dotnet add package Dapper.ContribNuGet： Install-Package Dapper.Contri...

使用C#的DAPPER 进行增删改查操作（一）【代码】【图】

如何在C＃中使用Dapper ORM从SQL数据库插入，更新，删除和查看学生资料数据首先准备测试数据创建数据表CREATE TABLE [dbo].[UserInfo]([Id] [int] IDENTITY(1,1) NOT NULL,[FirstName] [nvarchar](50) NULL,[LastName] [nvarchar](50) NULL,[Email] [nvarchar](50) NULL,[Gender] [nvarchar](50) NULL,[IpAddress] [nvarchar](50) NULL,CONSTRAINT [PK_User] PRIMARY KEY CLUSTERED ([Id] ASC )WITH (PAD_INDEX = OFF, STATIST...

c#-Dapper查询结果在对象中将表的Pk设置为空【代码】

我正在尝试使用dapper从mysql数据库检索数据,但结果将id(主键)和外键设置为null.其他属性具有值. 我试图将SQL查询从选择*从课程更改为完整形式,作为选择ID,名称,从课程的ID.Course{public Course(){}public string Id { get; set; }public string Title { get; set; }public int Credits { get; set; }public bool Is_Elective { get; set; }public string DId { get; set; }public int Sem { get; set; }}class CourseDAO{private...

c#-Dapper和Varbinary(max)流参数【代码】

我正在尝试将二进制Blob存储在数据库表中并从中获取输出.数据存储在MemoryStream对象中.我正在尝试使用查询异步将此保存到sql server 2012表中.调用成功,但是没有数据插入到列中. (例如,查询回来时得到0x0条目). 果不其然,实际上检查了一条轨迹,我发现小巧玲珑发送0x0.内存流有长度,所以我做错了什么吗？还是dapper不支持这种情况？我的查询字符串只是一个简单的插入,并且返回ID和插入时间. 我正在使用以下电话using(var conn=new ...

c#-Dapper-将具有未知列数的结果集映射到具有数组属性的对象【代码】

我正在使用Dapper将来自SQL Server数据库的对象映射到C#类.根据上下文,我需要从中获取结果的存储过程之一可以具有可变数量的列.该结果集将始终具有一个主键列,然后具有0至30个其他列,它们都将具有相同的数据类型. 结果集列基本上是这样的：CustomerID | Email1 | Email2 | Email3 | ...电子邮件*列的数量取决于查询中客户对文件的最高电子邮件地址数量. 用C#捕获这种情况的自然方法是使用这样的类：class Customer {int ID { get; ...

C#-Dapper版本1.12.0.0 XML参数不再起作用【代码】

通过dapper将xml字符串传递到SQL Server 2008时,dapper似乎正在为xml字符串中的每个字符创建一个参数. 例如,如果字符串是< outer>< / outer&gt ;,它似乎正在创建一个参数每个字符(“<”,“ o”,“ u”,“ t”等).在旧版本中,代码会将一个参数(即指定的xml参数)传递到存储过程中.设置代码如下所示- var xml = @" <OuterElement><InnerElement>1</InnerElement><InnerElement>2</InnerElement><InnerElement>3</InnerElement><InnerE...

C#-表值参数与Dapper的存储过程【代码】

我正在尝试调用一个接受表值参数的存储过程. 我正在遵循有关this问题的准则,实现了自定义参数类型：internal class IntDynamicParam {string name;IEnumerable<int> numbers;public IntDynamicParam(string name,IEnumerable<int> numbers){this.name = name;this.numbers = numbers;}public void AddParameters(IDbCommand command){var sqlCommand = (SqlCommand)command;sqlCommand.CommandType = CommandType.StoredProcedure;...

c#-Dapper构建参数列表【代码】

我有这个课：public class Parameters {public string UserId {get;set;}public string OrgId {get;set;}public string Roles {get;set;} }它从JSON字符串反序列化.因此,某些属性为null. 建立参数列表以传递给Dapper的最佳方法是什么. 目前,我在SQL语句末尾建立要标记的params字符串的逻辑如下：var parameters = string.Empty; var parametersObj = new { }; if (query.Parameters != null) {if (!string.IsNullOrWhiteSpace(quer...

首页 / C# / C# Dapper 基本使用 增删改查事务等

C# Dapper 基本使用 增删改查事务等

内容导读

内容图文

内容总结

内容备注

内容手机端

【C# Dapper 基本使用 增删改查事务等】教程文章相关的互联网学习教程文章

DAPPER - 相关标签

事务 - 相关标签

C# - 技术教程分类

C# - 最新教程

C# - 最热教程

首页 / C# / C# Dapper 基本使用增删改查事务等

C# Dapper 基本使用增删改查事务等

【C# Dapper 基本使用增删改查事务等】教程文章相关的互联网学习教程文章