C#中使用Dapper进行数据库访问的流程步骤

2024-12-11 10:52:22 作者：AitTech

在C#中,Dapper是一个非常流行的ORM（对象关系映射）工具,它提供了一个轻量级的方式来访问数据库,Dapper通过SQL语句与数据库进行交互,并将结果映射到.NET对象中,以下是如何在C#中使用Dapper进行数据库访问的基本步骤,需要的朋友可以参考下

1. 安装Dapper

首先，需要通过NuGet包管理器安装Dapper。可以使用NuGet包管理器控制台来执行以下命令：

Install-Package Dapper

如果使用的是.NET Core或.NET 5/6/7等较新版本，Dapper也支持这些平台。

2. 配置数据库连接

接下来，需要配置数据库连接。这通常涉及到设置数据库连接字符串，并创建一个到数据库的连接对象。Dapper本身并不处理连接管理，但可以使用System.Data.SqlClient（对于SQL Server）或其他数据库提供程序来创建连接。

string connectionString = "数据库链接";
using (var connection = new SqlConnection(connectionString))
{
    // 在这里执行数据库操作
}

3. 执行SQL查询

使用Dapper，可以执行SQL查询并将结果映射到对象。例如，假设有一个名为Users的数据库表，想要查询所有用户：

string sql = "SELECT * FROM Users";
using (var connection = new SqlConnection(connectionString))
{
    var users = connection.Query<User>(sql); // User是一个与数据库表结构相匹配的类
    foreach (var user in users)
    {
        Console.WriteLine(user.Name);
    }
}

在上面的代码中，Query方法执行SQL查询，并将每一行结果映射到一个User对象。User类应该有一个与数据库表中的列相匹配的属性。

4. 执行参数化查询

为了防止SQL注入攻击，应该始终使用参数化查询。Dapper支持命名参数和匿名对象作为参数：

string sql = "SELECT * FROM Users WHERE Age > @Age";
int ageThreshold = 30;
using (var connection = new SqlConnection(connectionString))
{
    var users = connection.Query<User>(sql, new { Age = ageThreshold });
    foreach (var user in users)
    {
        Console.WriteLine(user.Name);
    }
}

或者，可以使用命名参数：

string sql = "SELECT * FROM Users WHERE Age > @age";
using (var connection = new SqlConnection(connectionString))
{
    var users = connection.Query<User>(sql, new { age = 30 });
    foreach (var user in users)
    {
        Console.WriteLine(user.Name);
    }
}

注意，Dapper对参数名称是大小写不敏感的，但最好保持一致性。

5. 执行插入、更新和删除操作

除了查询之外，Dapper还支持执行插入、更新和删除操作。可以使用Execute方法来执行这些操作：

string insertSql = "INSERT INTO Users (Name, Age) VALUES (@Name, @Age)";
using (var connection = new SqlConnection(connectionString))
{
    var rowsAffected = connection.Execute(insertSql, new { Name = "John Doe", Age = 25 });
    Console.WriteLine($"Rows affected: {rowsAffected}");
}

6. 使用事务

Dapper也支持事务。可以使用BeginTransaction方法来开始一个事务，并在完成后提交或回滚：

using (var connection = new SqlConnection(connectionString))
{
    using (var transaction = connection.BeginTransaction())
    {
        try
        {
            // 执行一系列数据库操作
            // ...

            // 提交事务
            transaction.Commit();
        }
        catch
        {
            // 回滚事务
            transaction.Rollback();
            throw;
        }
    }
}

到此这篇关于C#中使用Dapper进行数据库访问的流程步骤的文章就介绍到这了,更多相关C# Dapper数据库访问内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！