如何在C中高效地修改数据库表的数据？

在C#中修改数据库表中的数据是一个常见的操作，通常涉及使用ADO.NET来连接数据库并执行SQL语句，以下是如何在C#中修改数据库表的一个详细示例：

引入命名空间和创建数据库连接

需要引入必要的命名空间，然后创建一个数据库连接对象。

using System;
using System.Data;
using System.Data.SqlClient;
class Program
{
    static void Main()
    {
        // 创建连接字符串
        string connectionString = "Data Source=服务器地址;Initial Catalog=数据库名;User ID=用户名;Password=密码";
        // 创建数据库连接对象
        using (SqlConnection connection = new SqlConnection(connectionString))
        {
            try
            {
                // 打开数据库连接
                connection.Open();
                // 执行修改操作
                ModifyTable(connection);
            }
            catch (Exception ex)
            {
                Console.WriteLine("An error occurred: " + ex.Message);
            }
        }
    }
    static void ModifyTable(SqlConnection connection)
    {
        // 定义SQL语句
        string sql = "UPDATE 表名 SET 列名='新值' WHERE 条件";
        // 创建命令对象
        using (SqlCommand command = new SqlCommand(sql, connection))
        {
            // 执行命令
            int rowsAffected = command.ExecuteNonQuery();
            Console.WriteLine($"Rows affected: {rowsAffected}");
        }
    }
}

使用参数化查询防止SQL注入

为了防止SQL注入攻击，建议使用参数化查询，以下是一个示例：

static void ModifyTableWithParameters(SqlConnection connection)
{
    // 定义SQL语句，带参数占位符
    string sql = "UPDATE 表名 SET 列名=@新值 WHERE 条件=@条件";
    // 创建命令对象
    using (SqlCommand command = new SqlCommand(sql, connection))
    {
        // 添加参数
        command.Parameters.AddWithValue("@新值", "新值");
        command.Parameters.AddWithValue("@条件", 条件值);
        // 执行命令
        int rowsAffected = command.ExecuteNonQuery();
        Console.WriteLine($"Rows affected: {rowsAffected}");
    }
}

事务处理

如果需要确保多个操作要么全部成功要么全部失败，可以使用事务处理，以下是一个示例：

static void ModifyTableWithTransaction(SqlConnection connection)
{
    // 开始事务
    using (SqlTransaction transaction = connection.BeginTransaction())
    {
        try
        {
            // 定义SQL语句，带参数占位符
            string sql1 = "UPDATE 表名1 SET 列名1=@新值1 WHERE 条件1";
            string sql2 = "UPDATE 表名2 SET 列名2=@新值2 WHERE 条件2";
            // 创建命令对象1
            using (SqlCommand command1 = new SqlCommand(sql1, connection, transaction))
            {
                // 添加参数1
                command1.Parameters.AddWithValue("@新值1", "新值1");
                command1.Parameters.AddWithValue("@条件1", 条件值1);
                // 执行命令1
                command1.ExecuteNonQuery();
            }
            // 创建命令对象2
            using (SqlCommand command2 = new SqlCommand(sql2, connection, transaction))
            {
                // 添加参数2
                command2.Parameters.AddWithValue("@新值2", "新值2");
                command2.Parameters.AddWithValue("@条件2", 条件值2);
                // 执行命令2
                command2.ExecuteNonQuery();
            }
            // 提交事务
            transaction.Commit();
            Console.WriteLine("Transaction committed successfully.");
        }
        catch (Exception ex)
        {
            // 如果发生错误，回滚事务
            transaction.Rollback();
            Console.WriteLine("An error occurred: " + ex.Message);
        }
    }
}

4. 使用DataAdapter更新数据表

DataAdapter提供了一种更灵活的方式来更新数据表，它可以根据DataTable中的变化自动生成相应的SQL语句，以下是一个示例：

static void UpdateDataTable(SqlConnection connection)
{
    // 定义SQL语句，选择要更新的行
    string selectSql = "SELECT * FROM 表名";
    DataTable dataTable = new DataTable();
    // 创建命令对象，填充DataTable
    using (SqlCommand selectCommand = new SqlCommand(selectSql, connection))
    {
        using (SqlDataAdapter dataAdapter = new SqlDataAdapter(selectCommand))
        {
            dataAdapter.Fill(dataTable);
        }
    }
    // 修改DataTable中的数据
    DataRow[] rows = dataTable.Select("条件列='旧值'");
    foreach (DataRow row in rows)
    {
        row["列名"] = "新值"; // 修改数据
    }
    // 创建命令构建器和命令对象，用于更新数据库
    SqlCommandBuilder commandBuilder = new SqlCommandBuilder(new SqlDataAdapter());
    using (SqlCommand updateCommand = new SqlCommand(commandBuilder.GetUpdateCommand(), connection))
    {
        using (SqlDataAdapter updateAdapter = new SqlDataAdapter())
        {
            updateAdapter.UpdateCommand = updateCommand;
            int rowsAffected = updateAdapter.Update(dataTable); // 更新数据库
            Console.WriteLine($"Rows affected: {rowsAffected}");
        }
    }
}

相关问答FAQs

Q1: 如何防止SQL注入攻击？

A1: 使用参数化查询是防止SQL注入的有效方法，通过将用户输入作为参数传递给SQL命令，而不是直接拼接到SQL字符串中，可以避免反面代码的注入。

Q2: 何时使用事务处理？

A2: 当需要确保一系列数据库操作要么全部成功要么全部失败时，应该使用事务处理，在转账操作中，需要同时更新两个账户的余额，这时就需要使用事务来保证数据的一致性。