关于C#中使用Oracle存储过程返回结果集的问题

问题：

在mssqlserver中定义的存储过程可以直接返回一个数据集，如：

create procedure sp_getallemployees
as
select * from [northwnd].[dbo].[employees]

在oracle数据库中这样定义是错误的，怎么解决？

办法：

oracle中可以使用游标（cursor）对数据集进行操作，但在存储过程输出参数中直接使用cursor错误，此时的cursor应该是一个定义游标的关键字并非类型，所以先要定义一个包，在包中声明全局的自定义游标类型，如：

/**创建一个名为pkg_products的包**/
create or replace package pkg_products is
--定义一个公有的游标类型cursor_pdt
--ref 可以在程序间传递结果集
--一个程序里打开游标变量，在另外的程序里处理数据
type cursor_pdt is ref cursor;
--声明一个存储过程 ,游标类型参数为输出类型
procedure proc_getallproducts(cur_set out cursor_pdt);
end pkg_products;

这个包（package）有点类似oo中的接口，c++中的文件头，实现这个包时叫包体(package body),且名称要相同，如：

/**创建一个包体**/
create or replace package body pkg_products is
  --实现包中没有实现的存储过程
  procedure proc_getallproducts(cur_set out cursor_pdt) as
    begin 
      --打开游标，由于定义游标时使用ref处理游标可以推迟到客户端
      open cur_set for select id, name, producttype, price,picture, isout, mark, adddate from products;
      end;
end;

定义成功，且编译通过，就可以先在oracle中测试，如：

/**使用过程测试定义的存储过程**/
declare
--定义游标类型的变量
cur_set pkg_products.cursor_pdt;
--定义行类型
pdtrow products%rowtype;
begin
  --执行存储过程
  pkg_products.proc_getallproducts(cur_set);
  --遍历游标中的数据
       loop
         --取当前行数据存入pdtrow
           fetch cur_set into pdtrow;
           --如果未获取数据就结束循环
           exit when cur_set%notfound;
           --输出获取到的数据
           dbms_output.put_line (pdtrow.id||'，'||pdtrow.name);
         end loop;
         close cur_set;
  end;

如果运行上面的pl/sql过程脚本能取到结果，说明定义的包与包体的实现就成功了，可以使用.net,java或其它程序访问定义好的存储过程，如使用c#访问存储过程的脚本如下：

//定义连接对象
            oracleconnection conn = new oracleconnection("data source=orcl;persist security info=true;user id=t52;unicode=true;password=t52");
            //注意：包名.存储过程名的形式
            oraclecommand cmd = new oraclecommand("pkg_products.proc_getallproducts", conn);
            //设置命令类型为存储过程
            cmd.commandtype = commandtype.storedprocedure;
            //定义参数，注意参数名必须与存储过程定义时一致，且类型为oracletype.cursor
            oracleparameter cur_set =
                new oracleparameter("cur_set", oracletype.cursor);
            //设置参数为输出类型
            cur_set.direction = parameterdirection.output;
            //添加参数
            cmd.parameters.add(cur_set);
            //打开连接
            conn.open();
            //执行并返回oracledatareader，注意使用后释放
            return cmd.executereader(commandbehavior.closeconnection);

注意项目要添加引用程序集：system.data.oracleclient，代码中也要using；另外如果使用sql语句在c#中作为字符串出现时尽量不要换行，也不要以分号结尾。上面访问数据库的代码没有封装，返回dataset，datatable也可以，示例代码如下：

示例代码下载

求更好的办法。

到此这篇关于c#中使用oracle存储过程返回结果集的文章就介绍到这了,更多相关oracle存储过程返回结果集内容请搜索以前的文章或继续浏览下面的相关文章希望大家以后多多支持！