C#调用 Oracle 存储过程样例代码

-- 建表

CREATE TABLE sale_report (

     sale_date

DATE NOT NULL ,

     sale_item VARCHAR(2) NOT NULL ,

     sale_money DECIMAL(10,2) NOT NULL,

     PRIMARY KEY(sale_date, sale_item)

);

-- 測试数据

DECLARE

v_begin_day DATE;

v_end_day DATE;

BEGIN

v_begin_day := TO_DATE(‘2009-01-01‘, ‘YYYY-MM-DD‘);

v_end_day   :=

TO_DATE(‘2010-01-01‘, ‘YYYY-MM-DD‘);

WHILE v_begin_day < v_end_day LOOP

    INSERT INTO

SALE_REPORT VALUES(v_begin_day, ‘A‘,   1 );

INSERT INTO SALE_REPORT VALUES(v_begin_day, ‘B‘,   2 );

    INSERT INTO SALE_REPORT VALUES(v_begin_day, ‘C‘,  

3 );

    v_begin_day := v_begin_day + 1;

END LOOP;

END;

/

-- 測试函数

CREATE OR REPLACE FUNCTION HelloWorldFunc

RETURN VARCHAR2

AS

RETURN ‘Hello World!‘;

-- 測试存储过程

CREATE OR REPLACE PROCEDURE HelloWorld2 (

p_user_name

IN     VARCHAR2,

p_out_val  

OUT    VARCHAR2,

p_inout_val IN OUT VARCHAR2

) AS

   dbms_output.put_line(‘Hello ‘ || p_user_name ||

p_inout_val || ‘!‘);

   p_out_val := ‘A‘;

p_inout_val := ‘B‘;

END HelloWorld2;

-- 測试返回结果集的函数

create or replace package pkg_HelloWorld as

-- 定义ref

cursor类型

type myrctype is ref cursor;

--函数申明

function getHelloWorld

return myrctype;

end pkg_HelloWorld;

CREATE OR REPLACE package body pkg_HelloWorld as

return myrctype

IS

    return_cursor myrctype;

    OPEN return_cursor FOR ‘SELECT ‘‘Hello‘‘ AS a, ‘‘World‘‘ AS B

FROM dual‘;

    return return_cursor;

END

getHelloWorld;

以上为数据库表、測试数据、存储过程脚本

下面为 C#样例代码

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

using System.Data;

using System.Data.OracleClient;

namespace A0170_Oracle.Sample

{

    /// <summary>

    /// 用于 訪问

Oracle 数据库 存储过程与函数 的样例。

    ///

注意：这个样例所使用的 表 和 数据， 请參考项目下的 Schema.sql 文件。

    /// </summary>

    class

CallOracleFuncProc

    {

        /// <summary>

        /// Oracle 的数据库连接字符串.

        /// </summary>

        private const String connString =

            @"Data

Source=(DESCRIPTION=(ADDRESS=(PROTOCOL=TCP)(HOST=192.168.1.210)(PORT=1521))(CONNECT_DATA=(SERVICE_NAME=ORCL)));User

Id=TEST;Password=TEST123";

        public void

TestCallFuncProc()

        {

            //

建立数据库连接.

OracleConnection conn = new OracleConnection(connString);

打开连接.

conn.Open();

            // 调用

Oracle 函数.

CallFunc(conn);

Oracle 返回结果集的函数

CallFuncWithTable(conn);

调用存储过程

CallProcedure(conn);

关闭数据库连接.

conn.Close();

        }

        /// 測试 调用 Oracle 函数.

        private void

CallFunc(OracleConnection conn)

            // 创建一个

Command.

OracleCommand testCommand = conn.CreateCommand();

定义须要运行的SQL语句.

testCommand.CommandText = "SELECT HelloWorldFunc() FROM dual";

运行SQL命令，结果存储到Reader中.

OracleDataReader testReader = testCommand.ExecuteReader();

处理检索出来的每一条数据.

            while

(testReader.Read())

            {

// 将检索出来的数据，输出到屏幕上.

Console.WriteLine("调用函数:{0}; 返回:{1}",

testCommand.CommandText, testReader[0]

            }

关闭Reader.

testReader.Close();

        /// 測试 调用 Oracle 返回结果集的函数.

CallFuncWithTable(OracleConnection conn)

testCommand.CommandText = "pkg_HelloWorld.getHelloWorld";

定义好，本次运行的类型，是存储过程.

testCommand.CommandType = CommandType.StoredProcedure;

定义好，我这个參数，是 游标 + 返回值.

OracleParameter para = new OracleParameter("c", OracleType.Cursor);

para.Direction = ParameterDirection.ReturnValue;

testCommand.Parameters.Add(para);

Console.WriteLine("调用函数:{0}; 返回:{1} - {2}",

testCommand.CommandText, testReader[0], testReader[1]

        /// 測试运行存储过程.

        /// <param

name="conn"></param>

private void CallProcedure(OracleConnection conn)

testCommand.CommandText = "HelloWorld2";

定义要查询的參数.

// 第一个參数，是输入的.

testCommand.Parameters.Add(new OracleParameter("p_user_name", "HeiHei"));

第2个參数，是输出的.

OracleParameter para2 = new OracleParameter("p_out_val", OracleType.VarChar,

10);

para2.Direction = ParameterDirection.Output;

testCommand.Parameters.Add(para2);

第3个參数，是既输入又输出的.

OracleParameter para3 = new OracleParameter("p_inout_val", OracleType.VarChar,

20);

para3.Direction = ParameterDirection.InputOutput;

            para3.Value =

"HAHA";

testCommand.Parameters.Add(para3);

ExecuteNonQuery 方法，表明本次操作，不是一个查询的操作。将没有结果集合返回.

            // 返回的数据，将是

被影响的记录数.

int insertRowCount = testCommand.ExecuteNonQuery();

存储过程运行完成后，取得 output 出来的数据.

            String pa2 =

testCommand.Parameters["p_out_val"].Value.ToString();

            String pa3 =

testCommand.Parameters["p_inout_val"].Value.ToString();

Console.WriteLine("调用 {0} 存储过程之后， p_out_val={1}; p_inout_val={2}",

testCommand.CommandText, pa2, pa3);

    }

}