如何用C#实现数据库的存储过程异步调用？使用await？

畫卷琴夢

发布时间：2025-09-23 11:40:02

853人浏览过

来源于php中文网

原创

使用异步方法调用数据库存储过程需通过ExecuteReaderAsync、ExecuteNonQueryAsync或ExecuteScalarAsync配合SqlCommand，确保方法返回Task或Task，并用await实现非阻塞操作。1. 设置异步环境：定义async Task方法，使用SqlConnection.OpenAsync建立连接，SqlCommand配置存储过程名及参数类型；2. 处理输出参数和返回值：为输出参数创建SqlParameter并设置Direction为Output，ReturnValue接收返回值，执行ExecuteNonQueryAsync后读取结果；3. 读取结果集：对查询类存储过程使用ExecuteReaderAsync与SqlDataReader.ReadAsync逐行解析数据填充实体列表；4. ASP.NET Core中直接在控制器Action内await调用异步方法返回Ok结果。正确使用异步API可提升应用响应性能。

如何用c#实现数据库的存储过程异步调用？使用await？

在C#中调用数据库存储过程并实现异步操作，完全可以使用 await 和异步方法来完成。关键在于使用支持异步的 ADO.NET 方法，如 ExecuteReaderAsync、ExecuteNonQueryAsync 或 ExecuteScalarAsync，配合 SqlCommand 调用存储过程。

1. 设置异步调用环境

确保你的方法是异步的，并返回 Task 或 Task。例如：

public async Task CallStoredProcedureAsync(int userId)
{
    string connectionString = "your_connection_string";
    
    using (var connection = new SqlConnection(connectionString))
    {
        await connection.OpenAsync();

        using (var command = new SqlCommand("YourStoredProcedureName", connection))
        {
            command.CommandType = CommandType.StoredProcedure;

            // 添加参数
            command.Parameters.AddWithValue("@UserId", userId);
            command.Parameters.AddWithValue("@OtherParam", "value");

            // 执行并返回影响行数
            int result = await command.ExecuteNonQueryAsync();
            return result;
        }
    }
}

2. 获取返回值或输出参数

如果存储过程有输出参数或返回值，需要显式定义：

public async Task CallStoredProcedureWithOutputAsync(int input, out string outputValue)
{
    outputValue = string.Empty;
    string connectionString = "your_connection_string";

    using (var connection = new SqlConnection(connectionString))
    {
        await connection.OpenAsync();

        using (var command = new SqlCommand("ProcWithOutput", connection))
        {
            command.CommandType = CommandType.StoredProcedure;

            // 输入参数
            command.Parameters.AddWithValue("@InputParam", input);

            // 输出参数
            var outputParam = new SqlParameter("@OutputParam", SqlDbType.VarChar, 50)
            {
                Direction = ParameterDirection.Output
            };
            command.Parameters.Add(outputParam);

            // 返回值参数
            var returnParam = new SqlParameter("@ReturnVal", SqlDbType.Int)
            {
                Direction = ParameterDirection.ReturnValue
            };
            command.Parameters.Add(returnParam);

            await command.ExecuteNonQueryAsync();

            outputValue = outputParam.Value?.ToString();
            return (int)returnParam.Value;
        }
    }
}

3. 读取结果集（如查询类存储过程）

若存储过程返回数据，使用 ExecuteReaderAsync：

NetShop网店系统

NetShop软件特点介绍： 1、使用ASP.Net(c#)2.0、多层结构开发 2、前台设计不采用任何.NET内置控件读取数据，完全标签化模板处理，加快读取速度3、安全的数据添加删除读取操作，利用存储过程模式彻底防制SQL注入式攻击4、前台架构DIV+CSS兼容IE6,IE7,FF等，有利于搜索引挚收录5、后台内置强大的功能，整合多家网店系统的功能，加以优化。6、支持三种类型的数据库：Acces

下载

public async Task> GetUsersFromStoredProcedureAsync()
{
    var users = new List();
    string connectionString = "your_connection_string";

    using (var connection = new SqlConnection(connectionString))
    {
        await connection.OpenAsync();

        using (var command = new SqlCommand("GetUsers", connection))
        {
            command.CommandType = CommandType.StoredProcedure;

            using (var reader = await command.ExecuteReaderAsync())
            {
                while (await reader.ReadAsync())
                {
                    users.Add(new User
                    {
                        Id = reader.GetInt32("Id"),
                        Name = reader.GetString("Name")
                    });
                }
            }
        }
    }

    return users;
}

4. 在 ASP.NET Core 中调用示例

控制器中可以直接 await 异步方法：

[HttpGet]
public async Task GetUsers()
{
    var users = await _repository.GetUsersFromStoredProcedureAsync();
    return Ok(users);
}

基本上就这些。只要使用正确的异步 ADO.NET 方法，配合 await，就能高效地异步调用存储过程，避免阻塞线程，提升应用响应能力。

.NET 8有哪些新特性？一份给开发者的全面功能解读

.NET开发者薪资水平报告：你在行业中处于什么位置？

C#进行机器学习开发有哪些工具？ML.NET框架入门与实例

Unity游戏开发：C#实现3D物理引擎与AI行为树

c#可以做哪些项目

相关专题

线程和进程的区别

线程和进程的区别：线程是进程的一部分，用于实现并发和并行操作，而线程共享进程的资源，通信更方便快捷，切换开销较小。本专题为大家提供线程和进程区别相关的各种文章、以及下载和课程。

482

2023.08.10

数据库三范式

数据库三范式是一种设计规范，用于规范化关系型数据库中的数据结构，它通过消除冗余数据、提高数据库性能和数据一致性，提供了一种有效的数据库设计方法。本专题提供数据库三范式相关的文章、下载和课程。

352

2023.06.29

如何删除数据库

删除数据库是指在MySQL中完全移除一个数据库及其所包含的所有数据和结构，作用包括：1、释放存储空间；2、确保数据的安全性；3、提高数据库的整体性能，加速查询和操作的执行速度。尽管删除数据库具有一些好处，但在执行任何删除操作之前，务必谨慎操作，并备份重要的数据。删除数据库将永久性地删除所有相关数据和结构，无法回滚。

2075

2023.08.14

vb怎么连接数据库

在VB中，连接数据库通常使用ADO（ActiveX 数据对象）或 DAO（Data Access Objects）这两个技术来实现：1、引入ADO库；2、创建ADO连接对象；3、配置连接字符串；4、打开连接；5、执行SQL语句；6、处理查询结果；7、关闭连接即可。

347

2023.08.31

MySQL恢复数据库

MySQL恢复数据库的方法有使用物理备份恢复、使用逻辑备份恢复、使用二进制日志恢复和使用数据库复制进行恢复等。本专题为大家提供MySQL数据库相关的文章、下载、课程内容，供大家免费下载体验。

255

2023.09.05

vb中怎么连接access数据库

vb中连接access数据库的步骤包括引用必要的命名空间、创建连接字符串、创建连接对象、打开连接、执行SQL语句和关闭连接。本专题为大家提供连接access数据库相关的文章、下载、课程内容，供大家免费下载体验。

324

2023.10.09

数据库对象名无效怎么解决

数据库对象名无效解决办法：1、检查使用的对象名是否正确，确保没有拼写错误；2、检查数据库中是否已存在具有相同名称的对象，如果是，请更改对象名为一个不同的名称，然后重新创建；3、确保在连接数据库时使用了正确的用户名、密码和数据库名称；4、尝试重启数据库服务，然后再次尝试创建或使用对象；5、尝试更新驱动程序，然后再次尝试创建或使用对象。

410

2023.10.16

vb连接access数据库的方法

vb连接access数据库方法：1、使用ADO连接，首先导入System.Data.OleDb模块，然后定义一个连接字符串，接着创建一个OleDbConnection对象并使用Open() 方法打开连接；2、使用DAO连接，首先导入 Microsoft.Jet.OLEDB模块，然后定义一个连接字符串，接着创建一个JetConnection对象并使用Open()方法打开连接即可。

401

2023.10.16