使用Dapper框架进行SQL操作的C#示例

一、查询操作

在这个示例中，我们将使用Dapper框架来执行数据库查询操作。以下是查询操作的实现步骤：

1. 准备所需的命名空间

确保在代码文件中包含以下命名空间引用：

using Dapper;

using Microsoft.AspNetCore.Mvc;

using Newtonsoft.Json;

using System;

using System.Collections.Generic;

using System.Data;

using System.Data.SqlClient;

using System.Linq;

using System.Security.Cryptography;

using System.Text.Json;

using System.Threading.Tasks;

using TP.Domain;

using TP.Infrastructure;

using TPAPI.ModelsVue;

2. 创建SQL控制器

创建一个新的控制器类，继承自Controller类，并添加以下特性：

[Route("api/[controller]")]
[ApiController]
[ApiExplorerSettings(GroupName = "yw")]
public class SqlController : Controller
{
    // 其他方法...
}

3. 实现查询方法

以下是查询操作的实现代码：

[HttpPost("/[controller]/testSelselect")]
public string testSelselect(string person)
{
    try
    {
        using (SqlConnection connection = new SqlConnection(TPConfig.conn_Main))
        {
            connection.Open();
            string sql = "SELECT * FROM testTable where person=@person";
            var resClassSet = connection.Query(sql, new { person = person }).ToList();
            return JsonConvert.SerializeObject(resClassSet);
        }
    }
    catch (Exception)
    {
        throw;
    }
}

4. 使用Dapper执行查询

在代码中，connection.Query方法用于执行SQL查询，@person参数将传递到数据库中。返回结果通过JsonConvert.SerializeObject转换为JSON格式。

二、CRUD操作

接下来，我们将实现CRUD（创建、读取、更新、删除）操作，分别对应于testInsert、testDelete、testUpdate方法。

1. 插入操作

以下是插入操作的实现代码：

[HttpPost("/[controller]/testInsert")]
public string testInsert([FromBody] object data)
{
    try
    {
        using (SqlConnection connection = new SqlConnection(TPConfig.conn_Main))
        {
            connection.Open();
            var result = (JObject)JsonConvert.DeserializeObject(data.ToString());
            string sql = "insert into testTable (code,name,person) values (@code,@name,@person)";
            connection.Execute(sql, new { 
                code = result["code"].ToString(), 
                name = result["name"].ToString(), 
                person = result["person"].ToString() 
            });
            return "OK!";
        }
    }
    catch (Exception)
    {
        throw;
    }
}

2. 删除操作

以下是删除操作的实现代码：

[HttpPost("/[controller]/testDelete")]
public string testDelete([FromBody] object data)
{
    try
    {
        using (SqlConnection connection = new SqlConnection(TPConfig.conn_Main))
        {
            connection.Open();
            var result = (JObject)JsonConvert.DeserializeObject(data.ToString());
            string sql = "delete from testTable where Id=@id";
            connection.Execute(sql, new { id = result["id"].ToString() });
            return "OK!";
        }
    }
    catch (Exception)
    {
        throw;
    }
}

3. 更新操作

以下是更新操作的实现代码：

[HttpPost("/[controller]/testUpdate")]
public string testUpdate([FromBody] object data)
{
    try
    {
        using (SqlConnection connection = new SqlConnection(TPConfig.conn_Main))
        {
            connection.Open();
            var result = (JObject)JsonConvert.DeserializeObject(data.ToString());
            string sql = "update testTable set name=@name where ID=@Id";
            connection.Execute(sql, new { 
                name = result["name"].ToString(), 
                Id = result["Id"].ToString() 
            });
            return "OK!";
        }
    }
    catch (Exception)
    {
        throw;
    }
}

4. 参数处理

在以上方法中，我们使用了[FromBody] object data来接收来自客户端的数据。为了确保数据的安全性和完整性，可以在处理数据之前进行参数验证和过滤。

5. 错误处理

每个方法都包含了try-catch块，以确保在发生异常时能够及时捕获并抛出错误信息。

通过以上实现，可以轻松地使用Dapper框架对SQL数据库进行CRUD操作，并将结果返回给客户端。

转载地址：http://pkvp.baihongyu.com/

你可能感兴趣的文章