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

c#oracle分页存储过程

admin
行业动态
2025-02-15
1

在C#中调用Oracle分页存储过程，可以使用 OracleCommand对象并设置其参数来实现。以下是一个示例代码片段：“

csharp，using Oracle.ManagedDataAccess.Client;public void GetPagedData(int pageNumber, int pageSize)，{， string connectionString = "your_connection_string";， using (OracleConnection conn = new OracleConnection(connectionString))， {， conn.Open();， using (OracleCommand cmd = new OracleCommand("YourStoredProcedureName", conn))， {， cmd.CommandType = System.Data.CommandType.StoredProcedure;， cmd.Parameters.Add(new OracleParameter("pageNumber", OracleDbType.Int32)).Value = pageNumber;， cmd.Parameters.Add(new OracleParameter("pageSize", OracleDbType.Int32)).Value = pageSize;， cmd.Parameters.Add(new OracleParameter("resultCursor", OracleDbType.RefCursor)).Direction = System.Data.ParameterDirection.Output; using (OracleDataReader reader = cmd.ExecuteReader())， {， while (reader.Read())， {， // Process your data here， }， }， }， }，}，

` 请确保将YourStoredProcedureName`替换为实际的存储过程名称，并根据需要调整连接字符串和参数类型。

在C#中调用Oracle分页存储过程是一个常见的需求，特别是在处理大量数据时，以下是详细的步骤和示例代码：

一、创建Oracle分页存储过程

需要在Oracle数据库中创建一个分页存储过程，假设我们有一个名为EMPLOYEES的表，包含以下列：EMPLOYEE_ID（员工ID）、FIRST_NAME（名字）和LAST_NAME（姓氏），我们将创建一个存储过程来按页获取员工信息。

CREATE OR REPLACE PROCEDURE GetEmployeesPaged(
    p_start_row IN NUMBER,
    p_page_size IN NUMBER,
    p_cursor OUT SYS_REFCURSOR
)
IS
BEGIN
    OPEN p_cursor FOR
    SELECT EMPLOYEE_ID, FIRST_NAME, LAST_NAME
    FROM (SELECT EMPLOYEE_ID, FIRST_NAME, LAST_NAME, ROWNUM AS rnum, COUNT(*) OVER () AS total_rows
          FROM EMPLOYEES)
    WHERE rnum > p_start_row AND rnum <= p_start_row + p_page_size;
END;
/

这个存储过程接受两个参数：p_start_row（起始行）和p_page_size（每页大小），并返回一个结果集（通过输出参数p_cursor）。

二、在C#中调用Oracle分页存储过程

在C#中，我们可以使用Oracle Data Provider for .NET (ODP.NET)来调用这个存储过程，以下是一个示例：

1、安装Oracle Data Provider：确保你已经安装了Oracle Data Provider for .NET，并在项目中添加了相应的引用。

2、**编写C#代码**：

using System;
using System.Data;
using Oracle.DataAccess.Client;
class Program
{
    static void Main()
    {
        string constr = "User Id=yourUsername;Password=yourPassword;Data Source=yourDataSource";
        using (OracleConnection con = new OracleConnection(constr))
        {
            try
            {
                con.Open();
                OracleCommand cmd = new OracleCommand("GetEmployeesPaged", con);
                cmd.CommandType = CommandType.StoredProcedure;
                // 添加输入参数
                OracleParameter startRowParam = new OracleParameter("p_start_row", OracleDbType.Int32);
                startRowParam.Value = 0; // 第一页
                cmd.Parameters.Add(startRowParam);
                OracleParameter pageSizeParam = new OracleParameter("p_page_size", OracleDbType.Int32);
                pageSizeParam.Value = 10; // 每页10条记录
                cmd.Parameters.Add(pageSizeParam);
                // 添加输出参数（游标）
                OracleParameter cursorParam = new OracleParameter("p_cursor", OracleDbType.RefCursor);
                cursorParam.Direction = ParameterDirection.Output;
                cmd.Parameters.Add(cursorParam);
                // 执行命令
                cmd.ExecuteNonQuery();
                // 读取结果集
                OracleRefCursor cursor = (OracleRefCursor)cmd.Parameters["p_cursor"].Value;
                using (OracleDataReader reader = cursor.GetDataReader())
                {
                    while (reader.Read())
                    {
                        Console.WriteLine($"{reader["EMPLOYEE_ID"]}, {reader["FIRST_NAME"]}, {reader["LAST_NAME"]}");
                    }
                }
            }
            catch (Exception ex)
            {
                Console.WriteLine(ex.Message);
            }
        }
    }
}

在这个示例中，我们首先建立了与Oracle数据库的连接，然后创建了一个OracleCommand对象来表示存储过程，我们为存储过程的输入参数和输出参数（游标）添加了相应的OracleParameter对象，并设置了它们的值和方向，执行命令后，我们从输出参数（游标）中获取结果集，并遍历它以打印每条记录。