C调用Oracle存储过程例子代码 电脑资料

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(xx-01-01, YYYY-MM-DD); v_end_day := TO_DATE(xx-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 / class CallOracleFuncProc / private const String connString = Data Source=(DESCRIPTION=(ADDRESS=(PROTOCOL=TCP)(HOST=10)(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(); / 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, testReader0 ); / 关闭Reader. testReader.Close(); / 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, testReader0, testReader1 ); / 关闭Reader. testReader.Close(); / / private void CallProcedure(OracleConnection conn) / 创建一个 Command. OracleCommand testCommand = conn.CreateCommand(); / 定义需要执行的SQL语句. testCommand.CommandText = HelloWorld2; / 定义好，本次执行的类型，是存储过程. testCommand.CommandType = CommandType.StoredProcedure; / 定义要查询的参数. / 第一个参数，是输入的. 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 = testC