设为首页 加入收藏

TOP

C#调用Oracle存储过程例子代码(一)
2014-11-23 21:48:54 来源: 作者: 【 】 浏览:14
Tags:调用 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
BEGIN
RETURN 'Hello World!';
END;
/

-- 测试存储过程
CREATE OR REPLACE PROCEDURE HelloWorld2 (
p_user_name IN VARCHAR2,
p_out_val OUT VARCHAR2,
p_inout_val IN OUT VARCHAR2
) AS
BEGIN
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
function getHelloWorld return myrctype
IS
return_cursor myrctype;
BEGIN
OPEN return_cursor FOR 'SELECT ''Hello'' AS a, ''World'' AS B FROM dual';
return return_cursor;
END getHelloWorld;
end pkg_HelloWorld;
/

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

以下为 C#例子代码

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Data;
using System.Data.OracleClient;

namespace A0170_Oracle.Sample
{


///


/// 用于 访问 Oracle 数据库 存储过程与函数 的例子。
///
/// 注意:这个例子所使用的 表 和 数据, 请参考项目下的 Schema.sql 文件。
///
///

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

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 返回结果集的函数.
///

private void CallFuncWithTable(OracleConnection conn)
{
// 创建一个 Command.
OracleCommand testCommand = conn.CreateCommand();

// 定义需要执行的SQL语句.
testCommand.CommandText = "pkg_HelloWorld.getHelloWorld";

// 定义好,本次执行的类型,是存储过程.
testCommand.CommandType = CommandType.StoredProcedure;

// 定义好,我这个参数,是 游标 + 返回值.
OracleParameter para = new OracleParameter("c", OracleType.Cursor);
para.Direction = ParameterDirection.ReturnValue;
testCommand.Parameters.Add(para);


// 执行SQL命令,结果存储到Reader中.
OracleDataReader testReader = testCommand.ExecuteReader();

// 处理检索出来的每一条数据.
while (testReader.Read())
{
// 将检索出来的数据,输出到屏幕上.
Console.WriteLine("调用函数:{0}; 返回:{1} - {2}",
testCommand.CommandText,

首页 上一页 1 2 下一页 尾页 1/2/2
】【打印繁体】【投稿】【收藏】 【推荐】【举报】【评论】 【关闭】 【返回顶部
分享到: 
上一篇Oracle学习笔记12--序列、索引、.. 下一篇Oracle学习笔记13--控制用户权限

评论

帐  号: 密码: (新用户注册)
验 证 码:
表  情:
内  容: