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 是一個枚舉狀態，表示數據連接狀態，其屬性值如下：

CommandType 用來指定如何解釋命令字元串，屬性值如下：

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中還有一種更棒的方式操作資料庫。這就是下篇內容要講的。如果有需要的小伙伴，別忘了關註評論哈。

更多內容煩請關註我的博客《高先生小屋》