以文本方式查看主题

-  中文XML论坛 - 专业的XML技术讨论区  (http://bbs.xml.org.cn/index.asp)
--  『 Dot NET,C#,ASP,VB 』  (http://bbs.xml.org.cn/list.asp?boardid=43)
----  在C#中使用DataReader检索 Oracle 存储过程  (http://bbs.xml.org.cn/dispbbs.asp?boardid=43&rootid=&id=11806)


--  作者:admin
--  发布时间:11/9/2004 2:26:00 AM

--  在C#中使用DataReader检索 Oracle 存储过程


发信人: Nineteen (-_-#!), 信区: DotNET
标  题: 在C#中使用DataReader检索 Oracle 存储过程
发信站: BBS 水木清华站 (Fri Nov  7 08:23:59 2003), 转信

这是一些相关文章.


本文引用下面的 Microsoft .NET 框架类库名称空间:
System.Data.OleDb
本任务的内容
概要

要求
创建 Oracle 表
创建 Oracle 包
创建 Visual C# .NET 应用程序
其他信息
参考
概要
本分步指导文章使用 DataReader 对象从 Oracle 存储过程检索数据。您可以使用 DataReader 从数据库检索只读、只向前的数据流。因为内存中仅保留一行,所以使用 DataReader 可以提高应用程序的性能并降低系统开销。  

返回页首
要求
下面的列表列出了推荐使用的硬件、软件、网络结构以及所需的 Service Pack:
Microsoft Windows 2000 Professional、Windows 2000 Server、Windows 2000 Advanced Server 或 Windows NT 4.0 Server
Microsoft Visual Studio .NET
本文假定您熟悉下列主题:
Visual C# .NET  
ADO.NET 基础知识和语法
返回页首
创建 Oracle 表
本示例使用在 Oracle Scott/Tiger 架构中定义的表。Oracle Scott/Tiger 架构包含在默认的 Oracle 系统中。

如果该架构不存在,您必须运行下表并插入该表的脚本: CREATE TABLE DEPT
(DEPTNO NUMBER(2,0) NOT NULL,  
DNAME VARCHAR2(14) NULL,  
LOC VARCHAR2(13) NULL,
PRIMARY KEY (DEPTNO)
   );

INSERT INTO Dept VALUES(11,'Sales','Texas');
INSERT INTO Dept VALUES(22,'Accounting','Washington');
INSERT INTO Dept VALUES(33,'Finance','Maine');

CREATE TABLE EMP
(EMPNO NUMBER(4,0) NOT NULL,  
ENAME VARCHAR2(10) NULL,  
JOB VARCHAR2(9) NULL,  
MGR NUMBER(4,0) NULL,  
SAL NUMBER(7,2) NULL,  
COMM NUMBER(7,2) NULL,  
DEPTNO NUMBER(2,0) NULL,
FOREIGN KEY (DEPTNO) REFERENCES DEPT(DEPTNO),   
PRIMARY KEY (EMPNO)
   );

INSERT INTO Emp VALUES(123,'Bob','Sales',555,35000,12,11);
INSERT INTO Emp VALUES(321,'Sue','Finance',555,42000,12,33);
INSERT INTO Emp VALUES(234,'Mary','Account',555,33000,12,22);
返回页首
创建 Oracle 包
在 Oracle 服务器上创建以下 Oracle 包: CREATE OR REPLACE PACKAGE curspkg_join AS  
        TYPE t_cursor IS REF CURSOR ;  
        Procedure open_join_cursor1 (n_EMPNO IN NUMBER, io_cursor IN OUT t_cursor);  
END curspkg_join;
   /  
在 Oracle 服务器上创建以下 Oracle 包正文: CREATE OR REPLACE PACKAGE BODY curspkg_join AS
Procedure open_join_cursor1 (n_EMPNO IN NUMBER, io_cursor IN OUT t_cursor)  
IS
        v_cursor t_cursor;  
BEGIN
        IF n_EMPNO <> 0  
        THEN
                OPEN v_cursor FOR  
                SELECT EMP.EMPNO, EMP.ENAME, DEPT.DEPTNO, DEPT.DNAME  
                        FROM EMP, DEPT  
                        WHERE EMP.DEPTNO = DEPT.DEPTNO  
                        AND EMP.EMPNO = n_EMPNO;

        ELSE  
                OPEN v_cursor FOR  
                SELECT EMP.EMPNO, EMP.ENAME, DEPT.DEPTNO, DEPT.DNAME  
                        FROM EMP, DEPT  
                        WHERE EMP.DEPTNO = DEPT.DEPTNO;

        END IF;
        io_cursor := v_cursor;  
END open_join_cursor1;  
END curspkg_join;
   /  
返回页首
创建 Visual C# .NET 应用程序
新建一个 Visual C# Windows 应用程序项目。默认情况下会将 Form1 添加到项目中。
将下面的代码添加到"代码"窗口顶部: using System.Data.OleDb;
将下面的代码添加到 Form1 的 Form_Load 事件: OleDbConnection Oraclecon = new OleDbConnection("Provider=MSDAORA.1;Password=tiger;"
+ "User ID=scott;Data Source=OracleServer;Persist Security Info=True");
Oraclecon.Open();
OleDbCommand myCMD =  new OleDbCommand
("{call curspkg_join.open_join_cursor1(?, {resultset 0, io_cursor})}", Oraclecon);
myCMD.Parameters.Add("ID", OleDbType.Numeric, 4).Value = 0;
OleDbDataReader myReader;  
myReader = myCMD.ExecuteReader();
int x;  
int count;
count = 0;
while (myReader.Read())
                                 
{        
        for (x = 0; x <= myReader.FieldCount - 1; x++)  
                Console.Write(myReader.GetValue(x) + " ");

       
        Console.WriteLine();
        *Count = 1;
}


MessageBox.Show(count + " Rows Returned.");
myReader.Close();
Oraclecon.Close();
根据您的环境相应地修改 OleDbConnection 字符串。
按 F5 键编译和运行该应用程序。注意,来自 Oracle 存储过程的数据出现在"调试"窗口,并且在消息框中显示行数。  
返回页首
其他信息
注意,代码通过 DataReader 执行循环: while (myReader.Read())
这是因为 DataReader 一次只读取一行。  

返回页首  

--
——长夜漫漫,无心睡眠……难道狼妹妹也睡不着吗?


※ 来源:·BBS 水木清华站 smth.org·[FROM: 202.206.3.3]
上一篇
返回上一页
回到目录
回到页首
下一篇



W 3 C h i n a ( since 2003 ) 旗 下 站 点
苏ICP备05006046号《全国人大常委会关于维护互联网安全的决定》《计算机信息网络国际联网安全保护管理办法》
46.875ms