在上一篇中初略的介紹了一下sql的基本寫法，這一篇開始我們正式步入C#操作數據庫的範圍。通過這一系列的内容，我想大家能對于數據庫交互有了一定的認識和基礎。閑話不多說，先給大家介紹一個C#操作數據庫的方式。

在ADO.NET出現之前，C#連接數據庫有很多種方式，各種框架琳琅滿目。用戶們飽受困擾，再加上亂七八糟的連接方式對語言的發展也是一種強有力的阻撓。所以微軟決定搞一套标準化出來，之後ADO.NET誕生了。

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 用來指定如何解釋命令字符串，屬性值如下：

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

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

,

更多精彩资讯请关注tft每日頭條，我们将持续为您更新最新资讯!

查看全部