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

发表于 分类于 ， ， 阅读时长 ≈ 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，并添加存储过程中所需要的参数即可