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 中还有一种更棒的方式操作数据库。这就是下篇内容要讲的。如果有需要的小伙伴，别忘了关注评论哈。

更多内容烦请关注我的博客《高先生小屋》