C# 中如何使用 SqlConnection, SqlCommand, SqlDataReader？

推荐答案

// www.javascriptcn.com code example
using System;
using System.Data.SqlClient;

class Program
{
    static void Main()
    {
        string connectionString = "Server=your_server;Database=your_db;User Id=your_user;Password=your_password;";
        string query = "SELECT * FROM your_table";

        using (SqlConnection connection = new SqlConnection(connectionString))
        {
            connection.Open();

            using (SqlCommand command = new SqlCommand(query, connection))
            {
                using (SqlDataReader reader = command.ExecuteReader())
                {
                    while (reader.Read())
                    {
                        Console.WriteLine(reader["column_name"].ToString());
                    }
                }
            }
        }
    }
}

本题详细解读

1. SqlConnection

SqlConnection 用于与 SQL Server 数据库建立连接。你需要提供一个连接字符串，其中包含服务器地址、数据库名称、用户名和密码等信息。

string connectionString = "Server=your_server;Database=your_db;User Id=your_user;Password=your_password;";
using (SqlConnection connection = new SqlConnection(connectionString))
{
    connection.Open();
    // 其他操作
}

2. SqlCommand

SqlCommand 用于执行 SQL 语句或存储过程。你可以通过 SqlCommand 对象执行查询、插入、更新或删除操作。

string query = "SELECT * FROM your_table";
using (SqlCommand command = new SqlCommand(query, connection))
{
    // 执行命令
}

3. SqlDataReader

SqlDataReader 用于从数据库中读取数据。它提供了一种快速、只进的方式读取查询结果。

using (SqlDataReader reader = command.ExecuteReader())
{
    while (reader.Read())
    {
        Console.WriteLine(reader["column_name"].ToString());
    }
}

4. 使用 using 语句

using 语句确保 SqlConnection、SqlCommand 和 SqlDataReader 在使用完毕后被正确释放，避免资源泄漏。

// www.javascriptcn.com code example
using (SqlConnection connection = new SqlConnection(connectionString))
{
    connection.Open();
    using (SqlCommand command = new SqlCommand(query, connection))
    {
        using (SqlDataReader reader = command.ExecuteReader())
        {
            while (reader.Read())
            {
                Console.WriteLine(reader["column_name"].ToString());
            }
        }
    }
}

5. 异常处理

在实际应用中，建议添加异常处理机制以捕获可能的数据库连接或查询错误。

// www.javascriptcn.com code example
try
{
    using (SqlConnection connection = new SqlConnection(connectionString))
    {
        connection.Open();
        using (SqlCommand command = new SqlCommand(query, connection))
        {
            using (SqlDataReader reader = command.ExecuteReader())
            {
                while (reader.Read())
                {
                    Console.WriteLine(reader["column_name"].ToString());
                }
            }
        }
    }
}
catch (Exception ex)
{
    Console.WriteLine("An error occurred: " + ex.Message);
}