PGzxc的博客

纸上得来终觉浅 绝知此事要躬行

0%

C#开发之——操作数据库(15.6)

一 概述

  • 在上一节 C# Connection中我们讲解了 C#语言连接数据库的方法,在与数据库建立连接之后即可开始操作数据库中的对象。
  • 操作数据库需则要用到 Command 类中提供的属性和方法。下面来介绍一下如何使用 Command 类来操作数据表中的数据

二 Command 类概述

在 System.Data.SqlClient 命名空间下,对应的 Command 类为 SqlCommand,在创建 SqlCommand 实例前必须已经创建了与数据库的连接。

2.1 常用构造方法

构造方法 说明
SqlCommand() 无参构造方法
SqlCommand(string commandText,SqlConnection conn) 带参的构造方法,第 1 个参数是要执行的 SQL 语句,第 2 个参数是数据库的连接对象

2.2 常用属性和方法

对数据库中对象的操作不仅包括对数据表的操作,还包括对数据库、视图、存储过程等数据库对象的操作,接下来主要介绍的是对数据表和存储过程的操作。

在对不同数据库对象进行操作时,SqlCommand 类提供了不同的属性和方法,常用的属性和方法如下表所示

属性或方法 说明
CommandText 属性,Command 对象中要执行的 SQL 语句
Connection 属性,获取或设置数据库的连接对象
CommandType 属性,获取或设置命令类型
Parameters 属性,设置 Command 对象中 SQL 语句的参数
ExecuteReader() 方法,获取执行查询语句的结果
ExecuteScalar() 方法,返回查询结果中第 1 行第 1 列的值
ExecuteNonQuery() 方法,执行对数据表的增加、删除、修改操作

三 使用 Command 类操作数据库

  • Command 类中提供了 3 种命令类型,分别是 Text、TableDirect 以及 StoredProcedure,默认情况下是 Text。
  • 所谓 Text 类型是指使用 SQL 语句的形式,包括增加、删除、修改以及查询的SQL语句。
  • StoredProcedure 用于执行存储过程;TableDirect 仅在 OLE DB 驱动程序中有效
  • 在使用 Command 类操作数据库时需要通过以下步骤完成

3.1 创建 SqlCommand 类的实例

创建 SqlCommand 类的实例分两种情况,一种是命令类型为 Text 的,一种是命令类型为 StoredProcedure 的。

3.1.1 命令类型为 Text

1
SqlCommand SqlCommand 类的实例名 = new SqlCommand(SQL语句 , 数据库连接类的实例 );

其中:

  • SQL语句:指该SqlCommand类的实例要执行的SQL语句
  • 数据库连接类的实例: 指使用 SqlConnection 类创建的实例,通常数据库连接类的实例处于打开的状态

3.1.2 命令类型为 StoredProcedure

1
SqlCommand SqlCommand 类的实例名 = new SqlCommand( 存储过程名称 , 数据库连接类的实例 );

需要注意的是:

  • 存储过程必须是当前数据库实例中的存储过程,并且在调用带参数的存储过程时,还需要在 SqlCommand 类的实例中添加对应的存储过程参数

    为存储过程添加参数,需要使用 SqlCommand 类实例的 Parameters 属性来设置,具体的代码如下

1
SqlCommand 类实例 .Parameters.Add( 参数名 , 参数值 );

在这里,参数名与存储过程中定义的参数名要一致

3.2 执行对数据表的操作

在执行对数据表的操作时通常分为两种情况,一种是执行非查询 SQL 语句的操作,即增加、修改、删除的操作,一种是执行查询 SQL 语句的操作

3.2.1 执行非查询 SQL 语句的操作

在执行非查询 SQL 语句时并不需要返回表中的数据,直接使用 SqlCommand 类的 ExecuteNonQuery 方法即可,该方法的返回值是一个整数,用于返回 SqlCommand 类在执行 SQL 语句后,对表中数据影响的行数

当该方法的返回值为 -1 时,代表 SQL 语句执行失败,当该方法的返回值为 0 时,代表 SQL 语句对当前数据表中的数据没有影响

例如 要删除学号为 1100 的学生的信息,而表中不存在该学号的学生的信息,SQL语句可以正常执行,但对表中的影响行数是 0

1
SqlCommand 类的实例 .ExecuteNonQuery();

需要注意的是,如果执行的 SQL 语句在数据库中执行错误,则会产生异常,因此该部分需要进行异常处理

3.2.2 执行查询语句的操作

在执行查询语句时通常需要返回查询结果,SqlCommand 类中提供的 ExecuteReader 方法在执行查询 SQL 语句后,会返回一个 SqlDataReader 类型的值,通过遍历 SqlDataReader 类中的结果即可得到返回值。

具体的代码如下

1
SqlDataReader dr = SqlCommand 类的实例 .ExecuteReader();

此外,如果在执行查询语句后并不需要返回所有的查询结果,而仅需要返回一个值,例如查询表中的记录行数,这时可以使用 ExecuteScalar 方法。具体的代码如下。

1
int returnvalue = SqlCommand 类的实例 .ExecuteScalar();

五 实例(表的创建见15.5)

5.1 实例一 制作一个用户注册界面,使用 SqlCommand 类向用户信息表中添加一条记录

5.1.1 效果图

5.1.2 代码

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
//“注册”按钮的单击事件
private void button1_Click(object sender, EventArgs e)
{
//编写数据库连接串
string connStr = "Data Source=.;Initial Catalog=test;User ID=sa;Password=root";
//创建 SqlConnection的实例
SqlConnection conn = null;
try
{
conn = new SqlConnection(connStr);
//打开数据库连接
conn.Open();
string sql = "insert into userinfo(name,password) values('{0}','{1}')";
//填充SQL语句
sql = string.Format(sql, textBox1.Text, textBox2.Text);
//创建SqlCommand对象
SqlCommand cmd = new SqlCommand(sql, conn);
//执行SQL语句
int returnvalue = cmd.ExecuteNonQuery();
//判断SQL语句是否执行成功
if(returnvalue != -1)
{
MessageBox.Show("注册成功!");
}
}
catch(Exception ex)
{
MessageBox.Show("注册失败!"+ex.Message);
}
finally
{
if (conn != null)
{
//关闭数据库连接
conn.Close();
}
}
}

5.2 实例二 制作一个登录界面,使用 SqlCommand 类判断用户是否登录成功

5.2.1 效果图

5.2.2 代码

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
//"登录"按钮的单击事件
private void button1_Click(object sender, EventArgs e)
{
//编写数据库连接串
string connStr = "Data Source=.;Initial Catalog=test;User ID=sa;Password=root";
//创建SQLConnection的实例
SqlConnection conn = null;
try
{
conn = new SqlConnection(connStr);
//打开数据库连接
conn.Open();
string sql = "Select count(*) from userinfo where name='{0}' and password='{1}'";
//填充SQL语句
sql = string.Format(sql, textBox1.Text, textBox2.Text);
//创建SqlCommand对象
SqlCommand cmd = new SqlCommand(sql, conn);
//执行SQL语句
int returnvalue = (int)cmd.ExecuteScalar();
//判断SQL语句是否执行成功
if (returnvalue != 0)
{
MessageBox.Show("登录成功!");
}
else
{
MessageBox.Show("登录失败!");
}
}
catch (Exception ex)
{
MessageBox.Show("注册失败!" + ex.Message);
}
finally
{
if (conn != null)
{
//关闭数据库连接
conn.Close();
}
}
}
//“取消”按钮的单击事件
private void button2_Click(object sender, EventArgs e)
{
this.Close();
}

5.3 实例三 改进用户注册功能,使用户在注册时用户名唯一

5.3.1 效果图

5.3.2 代码

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
//“注册”按钮的单击事件
private void button1_Click(object sender, EventArgs e)
{
//编写数据库连接串
string connStr = "Data Source=.;Initial Catalog=test;User ID=sa;Password=root";
//创建 SqlConnection的实例
SqlConnection conn = null;
try
{
conn = new SqlConnection(connStr);
//打开数据库连接
conn.Open();
//判断用户名是否重复
string checkNameSql = "select count(*) from userinfo where name='{0}'";
checkNameSql = string.Format(checkNameSql, textBox1.Text);
//创建SqlCommand对象
SqlCommand cmdCheckName = new SqlCommand(checkNameSql, conn);
//执行SQL语句
int isRepeatName = (int)cmdCheckName.ExecuteScalar();
if (isRepeatName != 0)
{
//用户名重复,则不执行注册操作
MessageBox.Show("用户名已存在!");
return;
}
string sql = "insert into userinfo(name,password) values('{0}','{1}')";
//填充SQL语句
sql = string.Format(sql, textBox1.Text, textBox2.Text);
//创建SqlCommand对象
SqlCommand cmd = new SqlCommand(sql, conn);
//执行SQL语句
int returnvalue = cmd.ExecuteNonQuery();
//判断SQL语句是否执行成功
if(returnvalue != -1)
{
MessageBox.Show("注册成功!");
}
}
catch(Exception ex)
{
MessageBox.Show("注册失败!"+ex.Message);
}
finally
{
if (conn != null)
{
//关闭数据库连接
conn.Close();
}
}
}

5.4 实例四 创建一个存储过程实现用户注册功能,并使用 SqlCommand 类调用存储过程

5.4.1 功能分析

用户注册功能的存储过程比较简单,只需要写一个带参数的存储过程将用户名和密码传递给存储过程,并使用 insert 语句将用户名和密码添加到用户信息表中

5.4.2 创建存储过程的语句

数据库的存储过程上单击右键添加存储过程,在dbo.Procedure.sql,填入存储过程语句,并更新

5.4.3 代码

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
//编写数据库连接串
string connStr = "Data Source=.;Initial Catalog=test;User ID=sa;Password=root";
//创建 SqlConnection的实例
SqlConnection conn = null;
try
{
conn = new SqlConnection(connStr);
//打开数据库连接
conn.Open();
//创建SqlCommand对象
SqlCommand cmd = new SqlCommand("AddUser", conn);
//设置SQLCommand对象的命令类型(CommandType)是存储过程
cmd.CommandType = CommandType.StoredProcedure;
//设置存储过程需要的参数
cmd.Parameters.AddWithValue("name", textBox1.Text);
cmd.Parameters.AddWithValue("password", textBox2.Text);
//执行存储过程
int returnvalue = cmd.ExecuteNonQuery();
Console.WriteLine(returnvalue);
//判断SQL语句是否执行成功
if(returnvalue != -1)
{
MessageBox.Show("注册成功!");
}
}
catch(Exception ex)
{
MessageBox.Show("注册失败!"+ex.Message);
}
finally
{
if (conn != null)
{
//关闭数据库连接
conn.Close();
}
}

5.4.4 说明

运行该窗体,效果与实例 1 一致。从上面的代码可以看出,调用存储过程并不复杂,只需要在 SqlCommand 对象中将 CommandType 属性的值改成 StoredProcedure,并添加存储过程中所需要的参数即可