0.前言
在上一篇中初略的介紹了一下SQL的基本寫法,這一篇開始我們正式步入C#操作資料庫的范圍,通過這一系列的內容,我想大家能對于資料庫互動有了一定的認識和基礎,閑話不多說,先給大家介紹一個C#操作資料庫的方式,
1. ADO.NET的介紹
在ADO.NET出現之前,C#連接資料庫有很多種方式,各種框架琳瑯滿目,用戶們飽受困擾,再加上亂七八糟的連接方式對語言的發展也是一種強有力的阻撓,所以微軟決定搞一套標準化出來,之后ADO.NET誕生了,
ADO.NET定義了一系列操作資料庫的介面和基類,而資料庫廠商只需要根據自己的實際情況開發對應的實作類就可以了,
2. 使用ADO.NET 操作需要的步驟
使用ADO.NET操作資料庫,先需要一個連接也就是 IDbConnection實體,然后使用IDbCommand執行,通過 IDataReader讀取資料,
先來簡單介紹一下上面提到的介面:
a.IDbConnection
表示一個與資料源的開放連接,并由訪問關系資料庫的.NET 資料提供程式實作,也就是說這只是一個介面,具體的實作得看具體的資料庫,
我們先看一下,具體的屬性和方法吧:
public string ConnectionString { get; set; }// 獲取或設定用于打開資料庫的連接字串
public string Database { get; }//獲取當前連接或即將連接的資料庫名稱
public System.Data.ConnectionState State { get; }//獲取當前連接的狀態
public System.Data.IDbTransaction BeginTransaction ();//開啟一項資料庫事務
public void ChangeDatabase (string databaseName);//修改已打開連接的當前資料庫
public void Close ();//關閉當前連接
public System.Data.IDbCommand CreateCommand ();//創建并獲取與該連接關聯的命令物件
public void Open ();//開啟與資料庫的連接
b. IDbCommand
表示連接到資料源時執行的SQL命令,并由訪問關系資料庫的.NET資料提供程式實作,與IDbConnection一致,也是一個介面,
這個介面的屬性和方法如下:
public string CommandText { get; set; } //獲取或設定要對資料源運行的文本命令,也就是SQL陳述句
public int CommandTimeout { get; set; } //獲取或設定在終止嘗試執行命令并生成錯誤之前的等待時間
public System.Data.CommandType CommandType { get; set; }//指定或者獲取解釋CommandText屬性的方式
public System.Data.IDbConnection Connection { get; set; }//獲取或設定執行該命令的連接
public System.Data.IDataParameterCollection Parameters { get; }//獲取命令的引數化串列
public System.Data.IDbTransaction Transaction { get; set; }//獲取或設定該命令關聯的事務
public void Cancel ();//嘗試取消執行命令
public System.Data.IDbDataParameter CreateParameter ();//創建一個引數
public int ExecuteNonQuery ();//執行一個陳述句,并回傳受影響的行數
public System.Data.IDataReader ExecuteReader ();//在Connect上執行CommandText,并回傳一個IDataReader
public object ExecuteScalar ();//執行查詢,并回傳第一行第一列,其他資料忽略
c. IDataReader
提供一種讀取結果集(通過對資料源執行命令獲取)的一個或多個只進流的方法,具體實作由訪問關系資料庫的.NET 資料提供程式實作,
這里的只進流的意思類似于只讀流,也就是說它是一種單向的流,從資料庫傳向程式的流,
這個介面的屬性和方法如下:
public int Depth { get; }//獲取一個值,該值指示當前行的嵌套深度
public bool IsClosed { get; }// 獲取該讀取器的是否關閉
public int RecordsAffected { get; }//獲取由執行 SQL 陳述句而更改、插入或洗掉的行數
public void Close ();//關閉IDataReader物件
public System.Data.DataTable GetSchemaTable ();//獲取一個描述該讀取器關聯的列元資料
public bool NextResult ();//顯示是否有下一行,如果有則在下次讀取的時候,讀取下一行的資料
public bool Read ();//與NextResult類似
同時,IDataReader 繼承了介面 IDataRecord,也就是說IDataReader也能直接回傳當前行的資料,
來,我們看看它從IDataRecord繼承了哪些吧(也就是IDataRecord有的屬性和方法),
public int FieldCount { get; }//獲取當前行中的列數
public object this[int i] { get; }//獲取位于指定索引處的列
public object this[string name] { get; }//獲取具有指定名稱的列
public System.Data.IDataReader GetData (int i);//獲取指定列序號的DataReader
public Type GetFieldType (int i);//獲取對應于會從 Type 回傳的 Object 型別的 GetValue(Int32) 資訊
public string GetDataTypeName (int i);//獲取指定欄位的資料型別資訊
public string GetName (int i);//獲取要查找的欄位的名稱
public int GetOrdinal (string name);//回傳命名欄位的索引
public bool GetBoolean (int i);//作為布林值獲取指定列的值
public byte GetByte (int i);//獲取指定列的 8 位無符號整數值
public char GetChar (int i);//獲取指定列的字符值
public DateTime GetDateTime (int i);//獲取指定欄位的日期和時間資料值
public decimal GetDecimal (int i);//獲取指定欄位的數值
public double GetDouble (int i);//獲取指定欄位的雙精度浮點數
public float GetFloat (int i);//獲取指定欄位的單精度浮點數
public Guid GetGuid (int i);//獲取指定欄位的GUID值
public short GetInt16 (int i);//獲取指定欄位的 16 位帶符號整數值
public long GetInt64 (int i);//獲取指定欄位的 64 位帶符號整數值
public string GetString (int i);//獲取指定欄位的字串值
public object GetValue (int i);//回傳指定欄位的值
public int GetValues (object[] values);// 將當前記錄的值按順序填充到陣列中,并回傳實際的數目
public bool IsDBNull (int i);//回傳指定欄位是否設定為 null
特別補充說明
ConnectionState 是一個列舉狀態,表示資料連接狀態,其屬性值如下:
| 欄位 | 值 | 說明 |
|---|---|---|
| Broken | 16 | 與資料源的連接中斷, 只有在連接打開之后才可能發生這種情況, 可以關閉處于這種狀態的連接,然后重新打開, (該值是為此產品的未來版本保留的,) |
| Closed | 0 | 連接已關閉, |
| Executing | 4 | 連接物件正在執行命令, (該值是為此產品的未來版本保留的,) |
| Fetching | 8 | 連接物件正在檢索資料, (該值是為此產品的未來版本保留的,) |
| Open | 1 | 連接處于打開狀態, |
CommandType 用來指定如何解釋命令字串,屬性值如下:
| 欄位 | 值 | 說明 |
|---|---|---|
| StoredProcedure | 4 | 存盤程序的名稱, |
| TableDirect | 512 | 表的名稱, |
| Text | 1 | SQL 文本命令, (默認,) |
3. 如何使用ADO.NET操作資料庫
以SQLServer為例,創建一個Connection:
using System.Data;
using System.Data.SqlClient;//Sql Server的命名空間
string connectStr = "";
IDbConnection connection = new SqlConnection(connectStr);
在.NET Framework中,以上代碼是正確的,因為.NET Framework內置了SQL Server的資料訪問程式,也就是資料驅動,但是在.NET Core中,需要為專案添加如下包的參考:
System.Data.SqlClient
這里簡單介紹一下如何使用Visual Studio安裝包:

如圖所示,在【工具】->【NuGet 包管理器】下找到 管理解決方案的NuGet程式包,點擊,然后會出現類似于下圖:

然后點擊瀏覽,輸入:System.Data.SqlClient

選中第一項,然后在右側勾選要添加包的專案,然后點擊安裝,
OK,現在假設你們都已經安裝好了,然后繼續下一步操作:
執行一個查詢陳述句:
select name from demo;
創建一個Command:
這時候創建Command有這樣幾種方式:
IDbCommand command = connection.CreateCommand();// 通過 connection創建一個命令
IDbCommand command = new SqlCommand();//簡單創建一個命令物件
IDbCommand command = new SqlCommand(sql,connection);//在初始化的時候,指定要執行的SQL和連接的Connection
如果在創建Command的時候,沒有指定連接和要執行的SQL陳述句,那么必須在獲取Reader之前,手動設定,
現在獲取一個Reader:
IDataReader reader = command.ExecuteReader();
如果只是想執行SQL,不關心回傳內容的話,可以呼叫以下方法:
int lines = command.ExecuteNonQuery();// 獲取受影響的行數
該方法適合于SQL是DML型別的SQL陳述句或者增刪改的SQL陳述句,
如果是查詢陳述句,則需要獲取Reader,然后通過Reader獲取對應的值,
4. 實踐
在大概講解了SQL,我們通過實踐練習把之前了解到的內容串聯起來,
a.創建一個表
var connectStr = "";
var sql = @"create table demo
(
[key] int identity primary key,
[name] varchar(20)
)";
IDbConnection connection = new SqlConnection(connectStr);
IDbCommand command = connection.CreateCommand();
connection.Open();//開啟鏈接
command.CommandText = sql;//賦值sql
var result = command.ExecuteNonQuery();//獲取回傳的int值,是-1
connection.Close();//用完了記得把鏈接關閉
對于 ExcuteNonQuery的回傳值,微軟在官方檔案中給出了這樣的描述:
對于 UPDATE、INSERT 和 DELETE 陳述句,回傳值為該命令所影響的行數, 對于所有其他型別的陳述句,回傳值是 -1,
所以這里的回傳值是-1,
b.添加一條資料
與創建表類似,區別在于使用的SQL陳述句不同,在C#中,使用ADO.NET 向資料庫添加值,需要手動拼接SQL陳述句來操作,
代碼如下:(假設使用在上一個示例里創建的表)
拼接SQL:
var value1 = "測驗";
var sql = @$"insert into demo(name) values('{value1}');";
//====或者
var sql = string.Format("insert into demo(name) values('{0}');", "測驗");
注意SQL陳述句拼接程序中的單引號,這在SQL中表示中間是字串,SQL有很強的將字串轉換成對應欄位型別的能力,所以可以統一傳給資料庫字串,
執行SQL:
var connectStr = "";
IDbConnection connection = new SqlConnection(connectStr);
IDbCommand command = connection.CreateCommand();
connection.Open();
command.CommandText = sql;
var result = command.ExecuteNonQuery();
connection.Close();
這次如果沒有執行錯誤的話,會回傳一個1,
c.修改記錄
例如修改demo里name為測驗的資料,將其name修改為demo:
var connectStr = "";
var sql = "update demo set name = 'demo' where name = ‘測驗’";
IDbConnection connection = new SqlConnection(connectStr);
IDbCommand command = connection.CreateCommand();
connection.Open();
command.CommandText = sql;
var result = command.ExecuteNonQuery();
Console.WriteLine(result);
connection.Close();
其中result表示SQL影響的表中資料行數,
d. 洗掉記錄
var sql = "delete table demo where name = ‘測驗’";
IDbConnection connection = new SqlConnection(connectStr);
IDbCommand command = connection.CreateCommand();
connection.Open();
command.CommandText = sql;
var result = command.ExecuteNonQuery();
Console.WriteLine(result);
connection.Close();
e. 查詢
這里就先容我賣個關子,不過大家可以自己試試ADO.NET的查詢
5. 說明
在第四小節里提到了連接字串,對于C#來說,不同資料庫應當有不同的連接字串,因為這是C#連接資料庫的一種指令或者是密鑰,
簡單介紹一下連接字串,它是用分號隔開的鍵值對串列,格式如下:
keyword1=value; keyword2=value;
以下是一個標準的SQL Server連接字串:
Persist Security Info=False;User ID=*****;Password=*****;Initial Catalog=AdventureWorks;Server=MySqlServer
其中:
- Persist Security Info=False 表示使用賬戶密碼連接資料庫
- User ID 表示用戶名
- Password 表示密碼
- Initial Catalog=AdventureWorks 表示連接的資料庫是 AdventureWorks ,可根據自己需要修改
- Server=MySqlServer 表示資料庫在 MySqlServer 這個服務器上,可以是IP地址或者域名等
之所以留下了查詢沒有說,因為在ADO.NET中還有一種更棒的方式操作資料庫,這就是下篇內容要講的,如果有需要的小伙伴,別忘了關注評論哈,
更多內容煩請關注我的博客《高先生小屋》

轉載請註明出處,本文鏈接:https://www.uj5u.com/net/40644.html
標籤:C#
上一篇:閑來無事做個C#小專案——2
