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

C#执行orcale 存储过程

admin
行业动态
2025-02-04
1

C#执行Oracle存储过程：该文介绍了在C#中执行Oracle存储过程的方法，包括配置数据源、建立数据库连接、使用Command对象执行存储过程及处理结果等步骤，并提供了示例代码。

在C#中执行Oracle存储过程是一个常见的需求，特别是在企业级应用开发中，以下将详细介绍如何在C#中执行Oracle存储过程，包括配置连接、调用存储过程以及处理存储过程的输出参数等步骤：

1、添加必要的命名空间

在使用Oracle相关的类和方法时，需要引入System.Data.OracleClient命名空间，这个命名空间提供了与Oracle数据库交互所需的类和接口。

2、配置数据库连接字符串

要连接到Oracle数据库，首先需要配置一个有效的连接字符串，连接字符串通常包含服务器地址、端口号、用户名、密码以及数据库名称等信息。

string connectionString = "Data Source=serverAddress:port/serviceName;User Id=username;Password=password;"

3、创建Oracle连接对象并打开连接

使用配置好的连接字符串创建一个OracleConnection对象，并调用其Open方法打开与数据库的连接。

using (OracleConnection conn = new OracleConnection(connectionString)) { conn.Open(); }

4、创建Oracle命令对象并设置存储过程名称

创建一个OracleCommand对象，并将其CommandType属性设置为CommandType.StoredProcedure，表示将要执行的是一个存储过程，将存储过程的名称赋值给CommandText属性。

OracleCommand cmd = new OracleCommand("YourStoredProcedureName", conn); cmd.CommandType = CommandType.StoredProcedure;

5、添加输入参数（可选）

如果存储过程有输入参数，需要为每个输入参数创建一个OracleParameter对象，并设置其ParameterName、Value和OracleDbType等属性，然后将这些参数添加到OracleCommand对象的Parameters集合中。

OracleParameter p1 = new OracleParameter("param1", OracleDbType.Varchar2); p1.Value = "inputValue"; cmd.Parameters.Add(p1);

6、添加输出参数（可选）

如果存储过程有输出参数，同样需要为每个输出参数创建一个OracleParameter对象，将其ParameterName和OracleDbType等属性设置好，并将Direction属性设置为ParameterDirection.Output，然后将这些参数添加到OracleCommand对象的Parameters集合中。

OracleParameter p2 = new OracleParameter("param2", OracleDbType.Int32); p2.Direction = ParameterDirection.Output; cmd.Parameters.Add(p2);

7、执行存储过程

调用OracleCommand对象的ExecuteNonQuery方法来执行存储过程，如果存储过程有返回值或输出参数，可以在执行后通过访问Parameters集合中的相应参数来获取它们的值。

int result = cmd.ExecuteNonQuery(); int outputValue = (int)cmd.Parameters["param2"].Value;

8、关闭连接

存储过程执行完成后，需要关闭与数据库的连接，以释放资源，可以使用OracleConnection对象的Close方法或Dispose方法来关闭连接。

conn.Close();

以下是一个完整的示例代码，展示了如何在C#中执行一个简单的Oracle存储过程：

using System;
using System.Data;
using System.Data.OracleClient;
class Program
{
    static void Main()
    {
        string connectionString = "Data Source=serverAddress:port/serviceName;User Id=username;Password=password;";
        using (OracleConnection conn = new OracleConnection(connectionString))
        {
            conn.Open();
            OracleCommand cmd = new OracleCommand("YourStoredProcedureName", conn);
            cmd.CommandType = CommandType.StoredProcedure;
            // 添加输入参数（如果有）
            OracleParameter p1 = new OracleParameter("param1", OracleDbType.Varchar2);
            p1.Value = "inputValue";
            cmd.Parameters.Add(p1);
            // 添加输出参数（如果有）
            OracleParameter p2 = new OracleParameter("param2", OracleDbType.Int32);
            p2.Direction = ParameterDirection.Output;
            cmd.Parameters.Add(p2);
            // 执行存储过程
            int result = cmd.ExecuteNonQuery();
            // 获取输出参数的值（如果有）
            int outputValue = (int)cmd.Parameters["param2"].Value;
            Console.WriteLine("Output Value: " + outputValue);
        }
    }
}