c# 调存储过程 赋值

C# 调用存储过程并赋值

在C#中，调用存储过程并为其参数赋值是一项常见的数据库操作，存储过程是一组为了完成特定功能的SQL语句集合，它们可以在服务器端进行预编译和优化，从而提高执行效率，下面将详细介绍如何在C#中调用存储过程并为参数赋值。

一、准备工作

1、引入命名空间

using System.Data;：提供对数据相关类的基本支持。

using System.Data.SqlClient;：用于连接和操作SQL Server数据库，如果是其他类型的数据库，如Oracle（System.Data.OracleClient）或MySQL（MySql.Data.MySqlClient），需要引入相应的命名空间。

2、建立数据库连接字符串

连接字符串包含了连接到数据库所需的信息，例如服务器地址、数据库名称、用户名和密码等，以下是一个典型的SQL Server连接字符串示例：

   string connectionString = "Server=192.168.1.100;Database=TestDB;User Id=sa;Password=password123;";

连接字符串键	说明	示例值
Server	服务器地址，可以是IP地址或服务器名称	192.168.1.100
Database	要连接的数据库名称	TestDB
User Id	连接数据库的用户名	sa
Password	连接数据库的密码	password123

二、创建SqlConnection对象

使用连接字符串创建SqlConnection对象，该对象表示与数据库的连接。

SqlConnection connection = new SqlConnection(connectionString);

三、打开连接

在调用存储过程之前，需要打开数据库连接，可以使用Open方法打开连接。

connection.Open();

四、创建SqlCommand对象

SqlCommand对象用于执行存储过程，需要指定存储过程的名称，并将其CommandType属性设置为CommandType.StoredProcedure。

SqlCommand command = new SqlCommand("存储过程名称", connection);
command.CommandType = CommandType.StoredProcedure;

五、为存储过程参数赋值

1、确定参数名称和类型

首先需要了解存储过程的定义，包括其参数的名称、类型和是否为输出参数等信息，假设有一个存储过程InsertEmployee，它有三个参数：@EmployeeName（输入参数，类型为nvarchar）、@Age（输入参数，类型为int）和@IsActive（输出参数，类型为bit）。

2、添加参数并赋值

对于输入参数，可以通过Parameters.AddWithValue方法添加参数并赋值。

command.Parameters.AddWithValue("@EmployeeName", "John Doe");
command.Parameters.AddWithValue("@Age", 30);

对于输出参数，除了添加参数值外，还需要将参数的Direction属性设置为ParameterDirection.Output。

SqlParameter isActiveParam = new SqlParameter("@IsActive", SqlDbType.Bit);
isActiveParam.Direction = ParameterDirection.Output;
command.Parameters.Add(isActiveParam);

六、执行存储过程

可以使用ExecuteNonQuery方法执行存储过程，该方法适用于不返回结果集的存储过程，如插入、更新或删除操作。

int rowsAffected = command.ExecuteNonQuery();

如果存储过程返回结果集，可以使用ExecuteReader方法获取结果。

SqlDataReader reader = command.ExecuteReader();
while (reader.Read())
{
    // 读取结果集中的数据，
    string employeeName = reader["EmployeeName"].ToString();
    int age = reader["Age"].ToInt32();
}
reader.Close();

七、处理输出参数

在执行完存储过程后，可以处理输出参数的值。

bool isActive = (bool)command.Parameters["@IsActive"].Value;
Console.WriteLine("Employee is active: " + isActive);

八、关闭连接

完成存储过程的调用后，需要关闭数据库连接以释放资源。

connection.Close();

以下是一个完整的示例代码，展示了如何在C#中调用一个带有输入和输出参数的存储过程：

using System;
using System.Data;
using System.Data.SqlClient;
class Program
{
    static void Main()
    {
        string connectionString = "Server=192.168.1.100;Database=TestDB;User Id=sa;Password=password123;";
        using (SqlConnection connection = new SqlConnection(connectionString))
        {
            try
            {
                connection.Open();
                using (SqlCommand command = new SqlCommand("InsertEmployee", connection))
                {
                    command.CommandType = CommandType.StoredProcedure;
                    command.Parameters.AddWithValue("@EmployeeName", "John Doe");
                    command.Parameters.AddWithValue("@Age", 30);
                    SqlParameter isActiveParam = new SqlParameter("@IsActive", SqlDbType.Bit);
                    isActiveParam.Direction = ParameterDirection.Output;
                    command.Parameters.Add(isActiveParam);
                    int rowsAffected = command.ExecuteNonQuery();
                    if (rowsAffected > 0)
                    {
                        bool isActive = (bool)command.Parameters["@IsActive"].Value;
                        Console.WriteLine("Employee inserted successfully. Is active: " + isActive);
                    }
                    else
                    {
                        Console.WriteLine("No rows affected.");
                    }
                }
            }
            catch (Exception ex)
            {
                Console.WriteLine("An error occurred: " + ex.Message);
            }
        }
    }
}

九、错误处理

在实际应用中，应该添加适当的错误处理机制，例如使用try catch块来捕获和处理可能出现的异常，如数据库连接失败、存储过程执行错误等，这样可以提高程序的健壮性和稳定性。

十、FAQs

问题1：如果存储过程有多个输入参数，如何确保参数的顺序正确？

在C#中调用存储过程并添加参数时，参数的顺序并不重要，只要参数名称与存储过程定义中的参数名称匹配即可，为了代码的可读性和维护性，建议按照存储过程定义中的参数顺序来添加参数。

问题2：如何处理存储过程返回的结果集？

如果存储过程返回结果集，可以使用SqlDataReader对象来读取结果集中的数据，在读取过程中，可以通过列名或索引来访问每一行的数据，读取完成后，需要关闭SqlDataReader对象以释放资源。