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

c# 使用数据库的增删查改

admin
行业动态
2025-02-21
1

在C#中，使用数据库进行增删查改操作通常涉及以下步骤：1. 引入相关命名空间；2. 创建数据库连接字符串；3. 使用 SqlConnection类建立与数据库的连接；4. 使用 SqlCommand类执行SQL语句实现增删查改操作。

在C#中，使用数据库进行增删查改操作通常涉及到与ADO.NET或Entity Framework等数据访问技术的交互，以下是详细的步骤和示例代码：

一、准备工作

1、引入命名空间：确保在C#文件中引入必要的命名空间，如System.Data.SqlClient用于SQL Server数据库连接，或其他适用于特定数据库的命名空间。

2、建立数据库连接：使用SqlConnection类（对于SQL Server）或其他相应的连接类来建立与数据库的连接，需要提供数据库服务器地址、数据库名称、用户名和密码等信息。

二、增（Insert）

插入数据到数据库表中，通常使用SqlCommand对象执行INSERT 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();
            string query = "INSERT INTO TableName (Column1, Column2) VALUES (@Value1, @Value2)";
            using (SqlCommand command = new SqlCommand(query, connection))
            {
                command.Parameters.AddWithValue("@Value1", "SomeValue1");
                command.Parameters.AddWithValue("@Value2", "SomeValue2");
                int rowsAffected = command.ExecuteNonQuery();
                Console.WriteLine(rowsAffected + " row(s) inserted.");
            }
        }
    }
}

三、删（Delete）

删除数据从数据库表中，使用SqlCommand对象执行DELETE 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();
            string query = "DELETE FROM TableName WHERE Column1 = @Value1";
            using (SqlCommand command = new SqlCommand(query, connection))
            {
                command.Parameters.AddWithValue("@Value1", "ValueToDelete");
                int rowsAffected = command.ExecuteNonQuery();
                Console.WriteLine(rowsAffected + " row(s) deleted.");
            }
        }
    }
}

四、查（Select）

查询数据从数据库表中，使用SqlCommand对象执行SELECT SQL语句，并通过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();
            string query = "SELECT Column1, Column2 FROM TableName WHERE Column1 = @Value1";
            using (SqlCommand command = new SqlCommand(query, connection))
            {
                command.Parameters.AddWithValue("@Value1", "SearchValue");
                using (SqlDataReader reader = command.ExecuteReader())
                {
                    while (reader.Read())
                    {
                        Console.WriteLine("Column1: " + reader["Column1"].ToString());
                        Console.WriteLine("Column2: " + reader["Column2"].ToString());
                    }
                }
            }
        }
    }
}

五、改（Update）

更新数据库表中的数据，使用SqlCommand对象执行UPDATE 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();
            string query = "UPDATE TableName SET Column2 = @NewValue WHERE Column1 = @Value1";
            using (SqlCommand command = new SqlCommand(query, connection))
            {
                command.Parameters.AddWithValue("@Value1", "OldValue");
                command.Parameters.AddWithValue("@NewValue", "NewValue");
                int rowsAffected = command.ExecuteNonQuery();
                Console.WriteLine(rowsAffected + " row(s) updated.");
            }
        }
    }
}