c#學習筆記-----oracle資料庫操作、ADO.NET

来源:http://www.cnblogs.com/wuxinwuxin/archive/2017/11/14/7835026.html
-Advertisement-
Play Games

1.1 概述 c#程式開發中，資料庫操作無疑是舉足輕重的，資料庫部分的技術點可能占整個c#技術點的1/4。這幾天我一直在研究System.Data.OracleClient.dll反編譯之後的.CS，放棄c#的心都有了，底層代碼不僅全是英文註釋，而且有很多東西看都看不懂，讓我深刻體會封裝的重要性！此 ...


1.1 概述

　　c#程式開發中，資料庫操作無疑是舉足輕重的，資料庫部分的技術點可能占整個c#技術點的1/4。這幾天我一直在研究System.Data.OracleClient.dll反編譯之後的.CS，放棄c#的心都有了，底層代碼不僅全是英文註釋，而且有很多東西看都看不懂，讓我深刻體會封裝的重要性！此外在做sql語句參數化拼接時，我想在c#中效仿java中的PreparedStatement，但是實現起來困難重重，花了很多時間，最後效果也不理想！放棄繼續深入！這就說明用語言開發和開發語言是兩個不同層次的!

　　fhbds!

1.2 操作oracle資料庫

　　任何操作都是建立在先連接上資料庫，連接資料庫需要第三方類庫System.Data.OracleClient.dll，（我已經上傳至文件），添加引用即可使用其中的類和方法。可惜沒有找到關於這個類庫的API，要不然學習這個類庫的阻力就會小很多，雖然微軟官網有一個c#的幫助文檔，但是我看後感覺幫助不大，就像我之前說的不要糾結別人提供給我們的類庫底層到底如何實現的，只要會用就ok了！java中連接資料庫也要導包，連接資料庫的語句在java中叫註冊資料庫驅動！

 1 using System;
 2 using System.Collections.Generic;
 3 using System.ComponentModel;
 4 using System.Data;
 5 using System.Drawing;
 6 using System.Linq;
 7 using System.Text;
 8 using System.Threading.Tasks;
 9 using System.Windows.Forms;
10 using System.Configuration;
11 using Oracle.ManagedDataAccess.Client;
12 using System.Collections;
13 
14 
15  public static bool ConnectOracle()
16         {
17             bool linkFlag = false;
18             try
19             {
20                 //註冊驅動
21                 string dataSource = "Data Source=(DESCRIPTION=(ADDRESS=(PROTOCOL=TCP)(HOST=2013-20130829TH)(PORT=1521))(CONNECT_DATA=(SERVICE_NAME=oracle)));";
22                 string persistSecurityInfo = "Persist Security Info=True;";
23                 string userID = "User ID=SYSTEM;";
24                 string password = "Password=admin;";
25                 OracleConnection con = new OracleConnection(dataSource + persistSecurityInfo + userID + password);
26                 con.Open();
27                 linkFlag = true;
28                 return linkFlag;
29             }
30             catch (Exception ex)
31             {
32                  ex.ToString();
33                 return linkFlag;
34 
35             }
36         }

　　dataSource中一般只需要根據oracle安裝目錄下的tnsnames.ora文件修改HOST名和SERVICE_NAME就可以了，這個因人而異。第二個連接字元串不需要修改，usrid和password也是根據實際要
連接哪個資料庫來寫，以後可以寫到配置文檔中。
　　c#中操作資料庫主要用到以下三個類及其其中的方法，分別是：OracleConnection、 OracleDataAdapter、OracleCommand。此外還有一個OracleDataReader，基本上這四個對象就能完成我們
最基本的資料庫操作。
　　OracleConnection是用來連接資料庫的對象，最重要的2個方法就是open（）和close（）了。 OracleDataAdapter主要使用是用來執行select查詢語句的，返回時一個查詢的結果集。
下麵這個方法就是通過返回結果集，來獲取資料庫中的數據，c#中獲取數據的方式有點特殊，它是使用了二維數組的方式來存取的，很有一種坐標的感覺！

 1 public static string dataSource = "Data Source=(DESCRIPTION=(ADDRESS=(PROTOCOL=TCP)(HOST=2013-20130829TH)(PORT=1521))(CONNECT_DATA=(SERVICE_NAME=oracle)));";
 2         public static string persistSecurityInfo = "Persist Security Info=True;";
 3         public static string userID = "User ID=SYSTEM;";
 4         public static string password = "Password=admin;";
 5         public  static string connectionString = dataSource + persistSecurityInfo + userID + password;
 6         public static DataSet Query(string connectionString, string SQLString)
 7         {
 8             using (OracleConnection connection = new OracleConnection(connectionString))
 9             {
10                 DataSet ds = new DataSet();
11                 try
12                 {
13                     connection.Open();
14                     OracleDataAdapter command = new OracleDataAdapter(SQLString, connection);
15                     command.Fill(ds, "ds");
16                 }
17                 catch (OracleException ex)
18                 {
19                     throw new Exception(ex.Message);
20                 }
21                 finally
22                 {
23                     if (connection.State != ConnectionState.Closed)
24                     {
25                         connection.Close();
26                     }
27                 }
28                 return ds;
29             }
30         }

測試腳本：

 1 SET DEFINE OFF;
 2 Insert into STUDENT
 3    (SID, SNAME, SAGE, SPASS)
 4  Values
 5    ('100', '李四', '18', '123456');
 6 Insert into STUDENT
 7    (SID, SNAME, SAGE, SPASS)
 8  Values
 9    ('003', '王五', '18', '123456');
10 Insert into STUDENT
11    (SID, SNAME, SAGE, SPASS)
12  Values
13    ('004', '趙六', '18', '123456');
14 Insert into STUDENT
15    (SID, SNAME, SAGE, SPASS)
16  Values
17    ('005', '張光烈', '18', '123456');
18 Insert into STUDENT
19    (SID, SNAME, SAGE, SPASS)
20  Values
21    ('006', '魏大勇', '18', '123456');
22 Insert into STUDENT
23    (SID, SNAME, SAGE, SPASS)
24  Values
25    ('007', '朱永博', '18', '123456');
26 Insert into STUDENT
27    (SID, SNAME, SAGE, SPASS)
28  Values
29    ('001', '張三', '18', '123456');
30 Insert into STUDENT
31    (SID, SNAME, SAGE, SPASS)
32  Values
33    ('520', '李雲龍', '100', '1314');
34 COMMIT;

測試代碼：

 1 private void button2_Click(object sender, EventArgs e)
 2         {
 3             string sql1 = "select * from student where sid='520'";
 4             DataSet ds1 = new DataSet();
 5             ds1 = Query(connectionString, sql1);
 6             textBox1.Text += "此查詢語句一共查到["+ds1.Tables[0].Rows.Count.ToString()+"]條記錄！";
 7             textBox1.Text += "此查詢語句一共查到[" + ds1.Tables[0].Columns.Count.ToString() + "]個欄位！";
 8             textBox1.Text += "此查詢語句查到第一張表，第一條記錄的欄位“SNAME”的值是[" + ds1.Tables[0].Rows[0]["SNAME"].ToString().Trim()+"]！";
 9             textBox1.Text += "此查詢語句查到的第二個欄位是[" + ds1.Tables[0].Columns[1].ToString() + "]！";
10           
11 
12         }

輸出：

         其中ds1.Tables[0].Rows.Count就能實現查詢語句返回的記錄數，不需要另外想什麼方式！

　　OracleCommand是用來執行insert 、update、delete語句的，返回值是影響的行數！主要發揮作用的是OracleCommand的ExecuteNonQuery()方法。

 1 //執行update insert delete語句，失敗了返回-1，成功了返回影響的行數,註意：自動commit
 2         public static int ExecuteNonQuery(string connectionString, string SQLString)
 3         {
 4             
 5             using (OracleConnection connection = new OracleConnection(connectionString))
 6             {
 7                     int val = -1;
 8                     try
 9                     {
10                           connection.Open();
11                           OracleCommand cmd = new OracleCommand(SQLString, connection);
12                          val = cmd.ExecuteNonQuery();
13                          cmd.Parameters.Clear();
14                     }
15                     catch (OracleException ex) {
16                         throw new Exception(ex.Message);
17                     }
18                     finally
19                     {
20                         if (connection.State != ConnectionState.Closed)
21                         {
22                             connection.Close();
23                         }
24                     }
25                     return val;
26                 }
27         }

測試代碼：

 1 private void button3_Click(object sender, EventArgs e)
 2         {
 3 
 4             string sid = "520";
 5             string sname = "李雲龍";
 6             int age = 100;
 7             string password = "1314";
 8 
 9             try
10             {
11                  string sql = @"Insert into STUDENT(SID, SNAME, SAGE, SPASS)Values('001', '張三', '18', '123456')";
12                 //string sql = @"update student set sname='韓信' where sid='001'";
13                //string sql = @"delete student  where sid='001'";
14                // string sql = "insert into student(SID,SNAME,SAGE,SPASS) values('" + sid + "','" + sname + "','" + age + "','" +password+ "')";
15                 int count = ExecuteNonQuery(connectionString, sql);
16                 textBox1.Text = count.ToString();
17             } catch(Exception ex){
18                textBox1.Text= ex.Message;
19             }    
20         }

 

　　此外OracleCommand還有一個ExecuteScalar()方法，返回的是object對象，返回的是查詢到的第一條記錄的第一個欄位的值，這個作用主要是用來精確查找的，也就是不會出現select *，

否則意義何在？

 1 //返回查詢到第一個對象
 2         public static object GetCount(string connectionString, string SQLString)
 3         {
 4             using (OracleConnection connection = new OracleConnection(connectionString))
 5             {
 6                 using (OracleCommand cmd = new OracleCommand(SQLString, connection))
 7                 {
 8                     try
 9                     {
10                         connection.Open();
11                         object obj = cmd.ExecuteScalar();
12                         if ((Object.Equals(obj, null)) || (Object.Equals(obj, System.DBNull.Value)))
13                         {
14                             return null;
15                         }
16                         else
17                         {
18                             return obj;
19                         }
20                     }
21                     catch (OracleException ex)
22                     {
23                         throw new Exception(ex.Message);
24                     }
25                     finally
26                     {
27                         if (connection.State != ConnectionState.Closed)
28                         {
29                             connection.Close();
30                         }
31                     }
32                 }
33             }
34         }

測試代碼：

1             string sql1 = "select spass from student";
2             object count = GetCount(connectionString,sql1);
3             textBox1.Text = count.ToString();

　　有時候我們並不在意查到的值是什麼，在意查不查的到只要稍微修改就可以了！

 1 //判斷某個對象是否存在
 2         public static bool Exists(string connectionString, string strSql)
 3         {
 4             object obj =GetCount(connectionString, strSql);
 5             int cmdresult;
 6             if ((Object.Equals(obj, null)) || (Object.Equals(obj, System.DBNull.Value)))
 7             {
 8                 cmdresult = 0;
 9             }
10             else
11             {
12                 cmdresult = int.Parse(obj.ToString());
13             }
14             if (cmdresult == 0)
15             {
16                 return false;
17             }
18             else
19             {
20                 return true;
21             }
22         }

測試代碼：

1             string sql1 =@"select spass from student where sname='劉邦'";
2             bool flag = Exists(connectionString, sql1);
3             textBox1.Text = flag.ToString();

1.3 參數化拼接SQL語句

< not end >






您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • file中private_data
    這個是Linux下連接VFS文件系統框架和不同文件/文件系統底層實現之間的一個核心數據結構，雖然它只是一個指針，但是一個指針可以解決所有問題，有了它，媽媽再也不用擔心我的學習。我們回想一下用戶態線程的創建結構，函數的入口同樣是一個void*指針，而千言萬語彙成一根指針，詩可以興、可以觀、可以群、可以 ...
  • C# 使用Queue<T>代替遞歸演算法遍歷樹
    遞歸時候每次調用自身在堆棧上要記錄返回地址，而堆棧的空間很少，調用次數多了後會產生堆棧溢出，以下代碼是實際項目中，通過Queue<T>來避免遞歸演算法的代碼： /// <summary> /// 獲取某個節點下特定屬性的所有子孫節點 /// </summary> /// <param name="gr ...
  • 在已有的資料庫中修改數據類型步驟
    UNIT_PRICE ：資料庫原先類型為： NUMBER(18,4) AMOUNT ： 資料庫原先類型為： NUMBER(18,4) 如果直接進行修改會報錯，因為原先欄位中已經有數據了。 ALTER TABLE CLOUD_RELEASE.CONTRACT_PRODUCT_ITEM MODIFY(U ...
  • ASP.NET Core 與 Vue.js 服務端渲染
    我真的很喜歡在前端使用 Vue.js，Vue 服務端渲染直到第二個版本才被支持。 在本例中，我想展示如何將 Vue.js 2 服務端渲染功能整合 ASP.NET Core ...
  • Navi.Soft31.產品.登錄器(永久免費)
    電商平臺和傳統店鋪相比，確實方便不少，直接在網上下單，快遞直接送貨到家。這其中，做電商平臺的童鞋表示壓力很大，因為可能同時開很多店鋪，每個店鋪都要登錄、查看訂單量、發貨揀貨等，非常辛苦。 多店鋪同時操作，需要打開很多瀏覽器，每個店鋪的帳號和密碼也要記清楚，腦子一定要夠用，不然就會頭暈腦漲。 ...
  • Docker & ASP.NET Core 2.0 微服務跨平臺實踐
    相關博文： "Ubuntu 簡單安裝 Docker" "Mac OS、Ubuntu 安裝及使用 Consul" "Consul 服務註冊與服務發現" "Fabio 安裝和簡單使用" 閱讀目錄： Docker 運行 Consul 環境 Docker 運行 Fabio 環境 使用 Consul 註冊 A ...
  • MongDB .Net工具庫MongoRepository的簡單使用
    MongDB .Net工具庫MongoRepository的簡單使用 最近研究了一下MongoDB資料庫，並使用了開源的在.net環境下的一個類庫，Mongo倉庫。對於數據的一些簡單的操作非常好用，特記錄供後期參考。 具體的使用過程如下： 一、新建項目，在Nuget上獲取庫。 二、在配置文件中設置數 ...
  • 在ASP.NET Core Web API中為RESTful服務增加對HAL的支持
    HAL（Hypertext Application Language，超文本應用語言）是一種RESTful API的數據格式風格，為RESTful API的設計提供了介面規範，同時也降低了客戶端與服務端介面的耦合度。很多當今流行的RESTful API開發框架，包括Spring REST，也都預設支 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類