亚洲免费在线-亚洲免费在线播放-亚洲免费在线观看-亚洲免费在线观看视频-亚洲免费在线看-亚洲免费在线视频

C#調用 Oracle 存儲過程樣例代碼

系統 2010 0

-- 建表
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
{


??? /// <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();
??????? }

??????? /// <summary>
??????? /// 測試 調用 Oracle 函數.
??????? /// </summary>
??????? 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();
??????? }


??????? /// <summary>
??????? /// 測試 調用 Oracle 返回結果集的函數.
??????? /// </summary>
??????? 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, testReader[0], testReader[1]
??????????????????? );
??????????? }

??????????? // 關閉Reader.
??????????? testReader.Close();
??????? }

??????? /// <summary>
??????? /// 測試運行存儲過程.
??????? /// </summary>
??????? /// <param name="conn"></param>
??????? 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 = 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);

??????? }

??? }
}

C#調用 Oracle 存儲過程樣例代碼


更多文章、技術交流、商務合作、聯系博主

微信掃碼或搜索:z360901061

微信掃一掃加我為好友

QQ號聯系: 360901061

您的支持是博主寫作最大的動力,如果您喜歡我的文章,感覺我的文章對您有幫助,請用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧,狠狠點擊下面給點支持吧,站長非常感激您!手機微信長按不能支付解決辦法:請將微信支付二維碼保存到相冊,切換到微信,然后點擊微信右上角掃一掃功能,選擇支付二維碼完成支付。

【本文對您有幫助就好】

您的支持是博主寫作最大的動力,如果您喜歡我的文章,感覺我的文章對您有幫助,請用微信掃描上面二維碼支持博主2元、5元、10元、自定義金額等您想捐的金額吧,站長會非常 感謝您的哦!!!

發表我的評論
最新評論 總共0條評論
主站蜘蛛池模板: 九九色在线视频 | 乱人伦中文视频在线 | 13一14周岁毛片免费 | 日日摸夜夜添夜夜添一区二区 | 国产女人综合久久精品视 | 九色 91| 私人影院免费 | 青青青在线视频播放免费 | 亚洲国产精品久久久天堂 | 日本工番囗番全彩本子大全 | 国产在线视频不卡 | 久久99精品久久久久久青青日本 | 免费国产一区二区在免费观看 | a网站免费 | 国产精品久久久久影院 | 色婷婷亚洲 | 久久精品国产免费看久久精品 | 一级毛片高清大全免费观看 | 国产成人精品无缓存在线播放 | 四虎影院海外永久 | 亚洲国产精品久久久久网站 | 色吧综合 | 欧美日韩一级黄色片 | 日本一级毛片a免费播放 | 亚洲欧美人成综合在线最新 | 日韩在线第三页 | 国产精品国产欧美综合一区 | 日本草草影院 | 四虎国产精品一区二区 | 视频黄在线观看 | 国产视频www| 欧美在线视频播放 | 九九热播视频 | 在线观看自拍视频 | 久久中文字幕在线观看 | 成人欧美在线观看免费视频 | 国内精品久久久久影院免费 | 韩国xxxx色视频在线观看 | 久久综合欧美成人 | 视频在线观看91 | 久久99国产精品 |