当前位置：首页 > 行业动态 > 正文

c#中如何调取存储过程

admin
行业动态
2025-03-21
2

在C#中调取存储过程，通常使用 SqlCommand对象。首先创建 SqlConnection连接数据库，然后通过 SqlCommand设置命令类型为 StoredProcedure并指定存储过程名称，最后执行命令。

在C#中调取存储过程是一个常见的操作，特别是在需要与数据库进行交互时，以下是如何实现这一操作的详细步骤：

一、准备工作

1、创建存储过程

在数据库中创建存储过程：首先需要在数据库中创建一个存储过程，在SQL Server中，可以使用以下SQL语句创建一个名为GetEmployeeById的存储过程，该存储过程接受一个员工ID作为参数，并返回该员工的详细信息：

 CREATE PROCEDURE GetEmployeeById
   @EmployeeId INT
   AS
   SELECT  FROM Employees WHERE EmployeeId = @EmployeeId

2、配置数据库连接

添加数据库引用：确保你的C#项目中已经添加了对相应数据库（如SQL Server、MySQL等）的引用，这通常通过NuGet包管理器完成，例如对于SQL Server，可以安装System.Data.SqlClient包。

配置连接字符串：在C#项目中，你需要配置数据库的连接字符串，这通常在App.config或Web.config文件中进行配置，也可以直接在代码中指定，对于SQL Server，连接字符串可能如下所示：

c#中如何调取存储过程

 <connectionStrings>
     <add name="MyDbConnection" connectionString="Server=myServerAddress;Database=myDataBase;User Id=myUsername;Password=myPassword;" />
   </connectionStrings>

二、调用存储过程

1、使用SqlCommand调用存储过程

创建SqlConnection对象：使用配置好的连接字符串创建SqlConnection对象，以建立与数据库的连接。

创建SqlCommand对象：使用SqlCommand对象来表示要对数据库执行的命令，将命令类型设置为StoredProcedure，并指定存储过程的名称。

添加参数：如果存储过程需要参数，使用Parameters属性向SqlCommand对象添加参数，并设置参数的值，参数的名称应与存储过程中定义的参数名称相匹配。

执行命令：调用SqlCommand对象的ExecuteReader方法执行存储过程，并获取返回的结果集，也可以使用ExecuteNonQuery方法执行不返回结果集的存储过程。

c#中如何调取存储过程

处理结果：如果存储过程返回结果集，可以使用SqlDataReader对象遍历结果集，并读取每一行的数据。

2、示例代码

完整的C#代码示例：以下是一个使用C#调用上述GetEmployeeById存储过程的完整示例代码：

 using System;
   using System.Data;
   using System.Data.SqlClient;
   class Program
   {
       static void Main()
       {
           string connectionString = "Server=myServerAddress;Database=myDataBase;User Id=myUsername;Password=myPassword;";
           using (SqlConnection connection = new SqlConnection(connectionString))
           {
               try
               {
                   connection.Open();
                   SqlCommand command = new SqlCommand("GetEmployeeById", connection);
                   command.CommandType = CommandType.StoredProcedure;
                   command.Parameters.AddWithValue("@EmployeeId", 1); // 假设要查询的员工ID为1
                   using (SqlDataReader reader = command.ExecuteReader())
                   {
                       while (reader.Read())
                       {
                           Console.WriteLine($"{reader["EmployeeId"]}, {reader["FirstName"]}, {reader["LastName"]}");
                       }
                   }
               }
               catch (Exception ex)
               {
                   Console.WriteLine($"Error: {ex.Message}");
               }
           }
       }
   }