C#使用SQL DataReader访问数据的优点和实例

在 C# 中，我们常常需要访问数据库中的数据。使用 SQL DataReader 可以有效地对数据进行访问，使得程序的性能得到提高。本文将详细讲解如何使用 SQL DataReader 访问数据的方法，同时介绍使用 SQL DataReader 访问数据的优点。

SQL DataReader 的优点

使用 SQL DataReader 可以有效地对数据进行读取操作，相比使用 DataSet 等其他方式，具有以下的优点：

1. 快速读取数据： SQL DataReader 是一种快速的读取数据的方法，对于大量数据的读取操作，其性能优于 DataSet。
2. 省内存： 使用 DataSet 的话，需要将所有的数据加载到本地内存中，占用内存较大，可能会导致程序崩溃。而使用 DataReader，读取到的数据可以一行一行地读取，从而避免了内存的占用问题。

如何使用 SQL DataReader 访问数据

下面我们将以使用 SQL DataReader 访问数据库中的学生表为例，详细介绍如何使用 SQL DataReader 进行数据库访问操作。

准备工作

在代码中使用 SQL DataReader 需要引用 System.Data.SqlClient 命名空间。在使用 SQL DataReader 前需要先创建 SqlConnection 对象，这个对象表示要访问的数据库的连接。其代码如下：

using System.Data.SqlClient;

namespace DataReaderDemo
{
    class Program
    {
        static void Main(string[] args)
        {
            string connectionString = "Data Source=(LocalDB)\\MSSQLLocalDB;AttachDbFilename=C:\\Database\\StudentDB.mdf;Integrated Security=True;Connect Timeout=30";
            SqlConnection connection = new SqlConnection(connectionString);
        }
    }
}

执行 SQL 查询

在建立连接后，我们可以使用 SqlCommand 对象执行 SQL 查询，如下所示：

SqlCommand command = new SqlCommand("SELECT * FROM Student", connection);

这里我们执行了一个简单的 SQL 语句“SELECT * FROM Student”，其中 Student 是我们数据库中的一个表名。

执行 SQL 查询并读取结果

执行 SQL 查询后，我们可以使用 SqlDataReader 对象读取查询结果。DataReader 对象是一种只读、向前、加载时推进的数据流，可以有效地处理大量数据。下面是一个简单的例子，使用 DataReader 输出 Student 表中的所有记录：

connection.Open();
SqlDataReader reader = command.ExecuteReader();

while (reader.Read())
{
    Console.WriteLine(reader["Name"].ToString() + "\t" + reader["Age"].ToString());
}

connection.Close();

在这里我们首先需要打开数据库连接，然后使用 command.ExecuteReader() 方法执行查询，返回一个 SqlDataReader 对象。之后使用 while (reader.Read()) 循环逐行读取结果集中的数据，最后关闭连接即可。

SQL DataReader 的使用实例

下面我们再给出一个使用 SQL DataReader 访问数据库的完整示例。这个示例将读取一个学生表并且输出所有学生的姓名和年龄。

using System;
using System.Data.SqlClient;

namespace DataReaderDemo
{
    class Program
    {
        static void Main(string[] args)
        {
            string connectionString = "Data Source=(LocalDB)\\MSSQLLocalDB;AttachDbFilename=C:\\Database\\StudentDB.mdf;Integrated Security=True;Connect Timeout=30";
            SqlConnection connection = new SqlConnection(connectionString);

            SqlCommand command = new SqlCommand("SELECT * FROM Student", connection);

            try
            {
                connection.Open();
                SqlDataReader reader = command.ExecuteReader();

                while (reader.Read())
                {
                    Console.WriteLine(reader["Name"].ToString() + "\t" + reader["Age"].ToString());
                }
            }
            catch (Exception ex)
            {
                Console.WriteLine(ex.Message);
            }
            finally
            {
                connection.Close();
            }
        }
    }
}

上面的代码中，我们首先定义了一个 connection 对象，指定了要访问的数据库连接字符串。之后使用 SqlCommand 对象执行 SQL 查询，最后使用 SqlDataReader 读取查询结果。在这里我们捕获了可能发生的异常，并在程序结束时关闭了连接。该程序读取 Student 表中的所有数据并逐行输出姓名和年龄。

另一个实例

下面我们再给出一个例子，演示如何通过 SQL DataReader 对数据库进行增、删、查、改操作：

using System;
using System.Data.SqlClient;

namespace DataReaderDemo
{
    class Program
    {
        static void Main(string[] args)
        {
            string connectionString = "Data Source=(LocalDB)\\MSSQLLocalDB;AttachDbFilename=C:\\Database\\StudentDB.mdf;Integrated Security=True;Connect Timeout=30";
            SqlConnection connection = new SqlConnection(connectionString);

            try
            {
                // 创建 SQL 语句
                string insertSql = "INSERT INTO Student (Name, Age) VALUES ('Tom', 18)";
                string deleteSql = "DELETE FROM Student WHERE Id = 1";
                string updateSql = "UPDATE Student SET Age = 20 WHERE Name = 'Tom'";
                string selectSql = "SELECT * FROM Student";

                // 创建 SqlCommand 对象
                SqlCommand insertCommand = new SqlCommand(insertSql, connection);
                SqlCommand deleteCommand = new SqlCommand(deleteSql, connection);
                SqlCommand updateCommand = new SqlCommand(updateSql, connection);
                SqlCommand selectCommand = new SqlCommand(selectSql, connection);

                // 打开连接
                connection.Open();

                // 执行插入操作
                insertCommand.ExecuteNonQuery();

                // 执行删除操作
                deleteCommand.ExecuteNonQuery();

                // 执行更新操作
                updateCommand.ExecuteNonQuery();

                // 执行查询操作
                SqlDataReader reader = selectCommand.ExecuteReader();
                while (reader.Read())
                {
                    Console.WriteLine(reader["Name"].ToString() + "\t" + reader["Age"].ToString());
                }
            }
            catch (Exception ex)
            {
                Console.WriteLine(ex.Message);
            }
            finally
            {
                connection.Close();
            }
        }
    }
}

在上述代码中，我们使用 SqlCommand 对象分别执行了插入、删除、更新、查询等 SQL 操作。注意，插入、删除、更新操作使用 ExecuteNonQuery() 方法，查询操作使用 ExecuteReader() 方法。最后关闭连接。

总结

使用 SQL DataReader 对数据库进行访问操作，能够方便、快速、省内存地读取大量的数据。当然，在使用 DataReader 时需要注意使用完后需要记得关闭相关的连接对象以及资源的释放。