C# 数据操作系列 - 2. ADO.NET操作

本文涉及的产品
云数据库 RDS SQL Server,独享型 2核4GB
简介:

C# 数据操作系列 - 2. ADO.NET操作

0.前言
在上一篇中初略的介绍了一下SQL的基本写法,这一篇开始我们正式步入C#操作数据库的范围。通过这一系列的内容,我想大家能对于数据库交互有了一定的认识和基础。闲话不多说,先给大家介绍一个C#操作数据库的方式。

  1. ADO.NET的介绍
    在ADO.NET出现之前,C#连接数据库有很多种方式,各种框架琳琅满目。用户们饱受困扰,再加上乱七八糟的连接方式对语言的发展也是一种强有力的阻挠。所以微软决定搞一套标准化出来,之后ADO.NET诞生了。

ADO.NET定义了一系列操作数据库的接口和基类,而数据库厂商只需要根据自己的实际情况开发对应的实现类就可以了。

  1. 使用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 ();//开启与数据库的连接

  1. 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 ();//执行查询,并返回第一行第一列,其他数据忽略

  1. 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 文本命令。 (默认。)

  1. 如何使用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获取对应的值。

  1. 实践
    在大概讲解了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影响的表中数据行数。

  1. 删除记录

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();

  1. 查询

这里就先容我卖个关子,不过大家可以自己试试ADO.NET的查询

  1. 说明
    在第四小节里提到了连接字符串,对于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.cnblogs.com/c7jie/p/12868458.html

相关实践学习
使用SQL语句管理索引
本次实验主要介绍如何在RDS-SQLServer数据库中,使用SQL语句管理索引。
SQL Server on Linux入门教程
SQL Server数据库一直只提供Windows下的版本。2016年微软宣布推出可运行在Linux系统下的SQL Server数据库,该版本目前还是早期预览版本。本课程主要介绍SQLServer On Linux的基本知识。 相关的阿里云产品:云数据库RDS SQL Server版 RDS SQL Server不仅拥有高可用架构和任意时间点的数据恢复功能,强力支撑各种企业应用,同时也包含了微软的License费用,减少额外支出。 了解产品详情: https://www.aliyun.com/product/rds/sqlserver
相关文章
|
7天前
|
数据可视化 网络协议 C#
C#/.NET/.NET Core优秀项目和框架2024年3月简报
公众号每月定期推广和分享的C#/.NET/.NET Core优秀项目和框架(每周至少会推荐两个优秀的项目和框架当然节假日除外),公众号推文中有项目和框架的介绍、功能特点、使用方式以及部分功能截图等(打不开或者打开GitHub很慢的同学可以优先查看公众号推文,文末一定会附带项目和框架源码地址)。注意:排名不分先后,都是十分优秀的开源项目和框架,每周定期更新分享(欢迎关注公众号:追逐时光者,第一时间获取每周精选分享资讯🔔)。
|
1月前
|
SQL 数据库 C#
C# .NET面试系列十一:数据库SQL查询(附建表语句)
#### 第1题 用一条 SQL 语句 查询出每门课都大于80 分的学生姓名 建表语句: ```sql create table tableA ( name varchar(10), kecheng varchar(10), fenshu int(11) ) DEFAULT CHARSET = 'utf8'; ``` 插入数据 ```sql insert into tableA values ('张三', '语文', 81); insert into tableA values ('张三', '数学', 75); insert into tableA values ('李四',
61 2
C# .NET面试系列十一:数据库SQL查询(附建表语句)
|
1月前
|
开发框架 .NET C#
C#数据去重的这几种方式,你知道几种?
C#数据去重的这几种方式,你知道几种?
|
1月前
|
开发框架 算法 搜索推荐
C# .NET面试系列九:常见的算法
#### 1. 求质数 ```c# // 判断一个数是否为质数的方法 public static bool IsPrime(int number) { if (number < 2) { return false; } for (int i = 2; i <= Math.Sqrt(number); i++) { if (number % i == 0) { return false; } } return true; } class Progr
56 1
|
1月前
|
并行计算 安全 Java
C# .NET面试系列四:多线程
<h2>多线程 #### 1. 根据线程安全的相关知识,分析以下代码,当调用 test 方法时 i > 10 时是否会引起死锁? 并简要说明理由。 ```c# public void test(int i) { lock(this) { if (i > 10) { i--; test(i); } } } ``` 在给定的代码中,不会发生死锁。死锁通常是由于两个或多个线程互相等待对方释放锁而无法继续执行的情况。在这个代码中,只有一个线程持有锁,且没有其他线程参与,因此不
99 3
|
1天前
|
开发框架 前端开发 JavaScript
采用C#.Net +JavaScript 开发的云LIS系统源码 二级医院应用案例有演示
技术架构:Asp.NET CORE 3.1 MVC + SQLserver + Redis等 开发语言:C# 6.0、JavaScript 前端框架:JQuery、EasyUI、Bootstrap 后端框架:MVC、SQLSugar等 数 据 库:SQLserver 2012
|
22天前
|
SQL C# 数据库
C# 读取多条数据记录导出到 Word 标签模板
C# 读取多条数据记录导出到 Word 标签模板
|
22天前
|
安全 数据处理 C#
C# Post数据或文件到指定的服务器进行接收
C# Post数据或文件到指定的服务器进行接收
|
1月前
|
数据采集 存储 C#
抓取Instagram数据:Fizzler库带您进入C#程序的世界
在当今数字化的世界中,数据是无价之宝。社交媒体平台如Instagram成为了用户分享照片、视频和故事的热门场所。作为开发人员,我们可以利用爬虫技术来抓取这些平台上的数据,进行分析、挖掘和应用。本文将介绍如何使用C#编写一个简单的Instagram爬虫程序,使用Fizzler库来解析HTML页面,同时利用代理IP技术提高采集效率。
抓取Instagram数据:Fizzler库带您进入C#程序的世界
|
1月前
|
SQL 存储 关系型数据库
C# .NET面试系列十:数据库概念知识
#### 1. 为什么要一定要设置主键? 设置主键是数据库设计中的一个重要概念,有几个主要原因: 1、唯一性 ```c# 主键必须保证表中的每一行都有唯一的标识。这样可以避免数据冗余和不一致性。如果没有主键或者主键不唯一,就可能出现数据混乱或错误。 ``` 2、查询性能 ```c# 数据库系统通常会使用主键来加速数据检索。主键通常会被索引,这样可以更快速地找到特定行的数据,提高查询效率。 ``` 3、关联性 ```c# 主键常常用于建立表与表之间的关系。在关系数据库中,一个表的主键通常与其他表中的外键建立关联,这种关系对于数据的一致性和完整性非常重要。 ``` 4、数据完
129 1
C# .NET面试系列十:数据库概念知识