当前位置：首页 > 行业动态 > 正文

如何在C中向数据库添加新数据？

admin
行业动态
2025-01-23
2702

在C#中，可以使用ADO.NET来连接和操作数据库。首先需要建立数据库连接，然后使用SqlCommand对象执行SQL语句来插入数据。，，“ csharp，using System.Data.SqlClient;，，string connectionString = "your_connection_string";，string query = "INSERT INTO TableName (Column1, Column2) VALUES (@value1, @value2)";，，using (SqlConnection connection = new SqlConnection(connectionString))，{， SqlCommand command = new SqlCommand(query, connection);， command.Parameters.AddWithValue("@value1", value1);， command.Parameters.AddWithValue("@value2", value2);，， connection.Open();， command.ExecuteNonQuery();，}，“

在C#中，向数据库补充数据通常涉及以下几个步骤：连接数据库、执行SQL命令、处理结果和关闭连接，以下是详细的步骤和示例代码。

如何在C中向数据库添加新数据？第1张

设置数据库连接

你需要设置一个数据库连接，这通常通过使用SqlConnection类来实现。

using System;
using System.Data.SqlClient;
class Program
{
    static void Main()
    {
        // 定义连接字符串
        string connectionString = "Server=myServerAddress;Database=myDataBase;User Id=myUsername;Password=myPassword;";
        using (SqlConnection connection = new SqlConnection(connectionString))
        {
            // 打开连接
            connection.Open();
            // 在这里执行你的数据库操作
            // 关闭连接
            connection.Close();
        }
    }
}

创建SQL命令

创建一个SqlCommand对象来执行SQL命令，你可以使用INSERT语句来添加新数据。

using System;
using System.Data.SqlClient;
class Program
{
    static void Main()
    {
        string connectionString = "Server=myServerAddress;Database=myDataBase;User Id=myUsername;Password=myPassword;";
        using (SqlConnection connection = new SqlConnection(connectionString))
        {
            connection.Open();
            // 定义SQL命令
            string sql = "INSERT INTO TableName (Column1, Column2) VALUES (@Value1, @Value2)";
            using (SqlCommand command = new SqlCommand(sql, connection))
            {
                // 添加参数并赋值
                command.Parameters.AddWithValue("@Value1", "SomeValue1");
                command.Parameters.AddWithValue("@Value2", "SomeValue2");
                // 执行命令
                command.ExecuteNonQuery();
            }
            connection.Close();
        }
    }
}

使用参数化查询

为了防止SQL注入攻击，建议使用参数化查询，上面的代码已经展示了如何使用参数化查询。

处理事务（可选）

如果你需要确保多个操作要么全部成功，要么全部失败，可以使用事务。

using System;
using System.Data.SqlClient;
class Program
{
    static void Main()
    {
        string connectionString = "Server=myServerAddress;Database=myDataBase;User Id=myUsername;Password=myPassword;";
        using (SqlConnection connection = new SqlConnection(connectionString))
        {
            connection.Open();
            // 开始事务
            using (SqlTransaction transaction = connection.BeginTransaction())
            {
                try
                {
                    // 定义第一个SQL命令
                    string sql1 = "INSERT INTO TableName (Column1, Column2) VALUES (@Value1, @Value2)";
                    using (SqlCommand command1 = new SqlCommand(sql1, connection, transaction))
                    {
                        command1.Parameters.AddWithValue("@Value1", "SomeValue1");
                        command1.Parameters.AddWithValue("@Value2", "SomeValue2");
                        command1.ExecuteNonQuery();
                    }
                    // 定义第二个SQL命令
                    string sql2 = "UPDATE AnotherTable SET Column3 = @Value3 WHERE Column4 = @Value4";
                    using (SqlCommand command2 = new SqlCommand(sql2, connection, transaction))
                    {
                        command2.Parameters.AddWithValue("@Value3", "NewValue3");
                        command2.Parameters.AddWithValue("@Value4", "ConditionValue4");
                        command2.ExecuteNonQuery();
                    }
                    // 提交事务
                    transaction.Commit();
                }
                catch (Exception ex)
                {
                    // 如果发生错误，回滚事务
                    transaction.Rollback();
                    Console.WriteLine("Transaction rolled back due to an error: " + ex.Message);
                }
            }
            connection.Close();
        }
    }
}

处理结果集（如果适用）

如果你执行的是SELECT语句，可以使用SqlDataReader来读取结果集。

using System;
using System.Data.SqlClient;
class Program
{
    static void Main()
    {
        string connectionString = "Server=myServerAddress;Database=myDataBase;User Id=myUsername;Password=myPassword;";
        using (SqlConnection connection = new SqlConnection(connectionString))
        {
            connection.Open();
            // 定义SQL命令
            string sql = "SELECT Column1, Column2 FROM TableName WHERE Column3 = @Value3";
            using (SqlCommand command = new SqlCommand(sql, connection))
            {
                command.Parameters.AddWithValue("@Value3", "ConditionValue3");
                using (SqlDataReader reader = command.ExecuteReader())
                {
                    while (reader.Read())
                    {
                        Console.WriteLine(String.Format("Column1: {0}, Column2: {1}", reader["Column1"], reader["Column2"]));
                    }
                }
            }
            connection.Close();
        }
    }
}