C# 數據操作系列 - 2. ADO.NET操作

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

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