如何使用C#与SQL Server数据库进行交互

使用C#与SQL Server数据库进行交互是开发应用程序中的一个常见任务。在这篇文章中，我们将详细介绍如何连接到SQL Server数据库、执行SQL查询、插入数据以及处理事务等操作。

一、环境准备

在开始之前，确保你已安装以下环境：

1. Visual Studio（推荐使用最新版）
2. SQL Server（可以使用SQL Server Express）
3. .NET Framework或.NET Core（取决于你的项目）

二、安装必要的库

在C#项目中，我们需要使用System.Data.SqlClient命名空间中的类来与SQL Server进行交互。通常情况下，该库是随.NET Framework或.NET Core默认提供的，但在.NET Core项目中，你需要安装Microsoft.Data.SqlClient包。

可以通过NuGet包管理器进行安装，打开Package Manager Console，输入以下命令：

Install-Package Microsoft.Data.SqlClient

三、建立数据库连接

首先，我们需要建立与SQL Server数据库的连接。以下是一个典型的连接字符串示例：

string connectionString = "Server=your_server;Database=your_database;User Id=your_username;Password=your_password;";

接下来，让我们使用SqlConnection类来建立连接，并进行一些基本的数据库操作。

四、执行SQL查询

下面的代码示例展示了如何使用C#与SQL Server进行连接，并执行一个查询操作：

using System;
using System.Data.SqlClient;

class Program
{
    static void Main(string[] args)
    {
        string connectionString = "Server=your_server;Database=your_database;User Id=your_username;Password=your_password;";

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

            string sqlQuery = "SELECT * FROM YourTable";
            SqlCommand command = new SqlCommand(sqlQuery, connection);

            using (SqlDataReader reader = command.ExecuteReader())
            {
                while (reader.Read())
                {
                    Console.WriteLine($"{reader["ColumnName1"]}, {reader["ColumnName2"]}");
                }
            }
        }
    }
}

在上面的代码中，我们使用SqlConnection类连接到数据库，使用SqlCommand类执行SQL查询，并使用SqlDataReader读取结果。

五、插入数据

插入数据到数据库中也非常简单。下面的代码示例展示了如何插入数据：

using System;
using System.Data.SqlClient;

class Program
{
    static void Main(string[] args)
    {
        string connectionString = "Server=your_server;Database=your_database;User Id=your_username;Password=your_password;";

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

            string sqlInsert = "INSERT INTO YourTable (ColumnName1, ColumnName2) VALUES (@value1, @value2)";
            SqlCommand command = new SqlCommand(sqlInsert, connection);

            command.Parameters.AddWithValue("@value1", "SampleValue1");
            command.Parameters.AddWithValue("@value2", "SampleValue2");

            int rowsAffected = command.ExecuteNonQuery();
            Console.WriteLine($"{rowsAffected} row(s) inserted.");
        }
    }
}

在插入数据时，我们使用参数化查询来防止SQL注入攻击，并有效地插入数据。

六、处理事务

有时，我们需要在一个事务中执行多个数据库操作，以确保数据的一致性。以下是一个处理事务的示例：

using System;
using System.Data.SqlClient;

class Program
{
    static void Main(string[] args)
    {
        string connectionString = "Server=your_server;Database=your_database;User Id=your_username;Password=your_password;";

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

            SqlTransaction transaction = connection.BeginTransaction();
            SqlCommand command = connection.CreateCommand();
            command.Transaction = transaction;

            try
            {
                command.CommandText = "INSERT INTO YourTable (ColumnName1) VALUES ('Value1')";
                command.ExecuteNonQuery();

                command.CommandText = "INSERT INTO YourTable (ColumnName2) VALUES ('Value2')";
                command.ExecuteNonQuery();

                transaction.Commit();
                Console.WriteLine("Both records were written to database.");
            }
            catch (Exception ex)
            {
                transaction.Rollback();
                Console.WriteLine("An error occurred: " + ex.Message);
            }
        }
    }
}

在这个示例中，我们在SQL Server中创建了一个事务，如果其中一个操作失败，所有操作都会被回滚，确保数据库状态的一致性。

结论

通过本文的示例，我们简单介绍了如何通过C#与SQL Server数据库进行交互，包括连接数据库、查询、插入数据以及处理事务。掌握这些基本的操作，对于构建数据库驱动的应用程序是非常必要的。希望本篇文章能帮助你更好地理解C#与SQL Server的交互。