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

c#操控数据库

admin
行业动态
2025-02-03
7

摘要：C#操控数据库主要通过ADO.NET、Entity Framework等技术，实现对数据库的连接、查询、插入、更新和删除等操作，为开发者提供了高效便捷的数据管理方式。

在当今数字化时代，数据成为了企业和个人决策的重要依据，C#作为一种强大的编程语言，其在数据库操控方面的能力尤为突出，无论是开发大型企业级应用还是小型桌面程序，掌握C#与数据库的交互都是至关重要的，下面将介绍C#如何高效地操控数据库，包括连接数据库、执行SQL命令、读取和写入数据等操作。

一、连接数据库

在C#中，连接数据库通常使用SqlConnection类（针对SQL Server数据库），以下是一个简单的示例：

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))
        {
            try
            {
                connection.Open();
                Console.WriteLine("Connection to Database successful!");
            }
            catch (Exception ex)
            {
                Console.WriteLine("Error: " + ex.Message);
            }
        }
    }
}

在这个示例中，我们首先定义了一个连接字符串connectionString，其中包含了服务器地址、数据库名称、用户名和密码等信息，我们创建了一个SqlConnection对象，并使用Open方法打开连接，如果连接成功，控制台将输出“Connection to Database successful!”；如果连接失败，将捕获异常并输出错误信息。

二、执行SQL命令

一旦建立了与数据库的连接，我们就可以执行各种SQL命令来操作数据库了，我们可以使用SqlCommand类来执行查询、插入、更新和删除等操作。

查询数据

以下是一个查询数据的示例：

using System;
using System.Data.SqlClient;
class Program
{
    static void Main()
    {
        string connectionString = "Server=myServerAddress;Database=myDataBase;User Id=myUsername;Password=myPassword;";
        string query = "SELECT * FROM Employees";
        using (SqlConnection connection = new SqlConnection(connectionString))
        {
            using (SqlCommand command = new SqlCommand(query, connection))
            {
                connection.Open();
                SqlDataReader reader = command.ExecuteReader();
                while (reader.Read())
                {
                    Console.WriteLine(String.Format("{0}, {1}", reader[0], reader[1]));
                }
                reader.Close();
            }
        }
    }
}

在这个示例中，我们首先定义了一个查询字符串query，用于从Employees表中选择所有记录，我们创建了一个SqlCommand对象，并将查询字符串传递给它，我们打开连接并执行命令，通过SqlDataReader对象读取查询结果，并在控制台上输出每条记录的字段值，我们关闭了SqlDataReader和连接。

c#操控数据库

插入数据

以下是一个插入数据的示例：

using System;
using System.Data.SqlClient;
class Program
{
    static void Main()
    {
        string connectionString = "Server=myServerAddress;Database=myDataBase;User Id=myUsername;Password=myPassword;";
        string insertQuery = "INSERT INTO Employees (Name, Age, Department) VALUES (@Name, @Age, @Department)";
        using (SqlConnection connection = new SqlConnection(connectionString))
        {
            using (SqlCommand command = new SqlCommand(insertQuery, connection))
            {
                command.Parameters.AddWithValue("@Name", "John Doe");
                command.Parameters.AddWithValue("@Age", 30);
                command.Parameters.AddWithValue("@Department", "IT");
                connection.Open();
                int rowsAffected = command.ExecuteNonQuery();
                Console.WriteLine(rowsAffected + " row(s) inserted.");
            }
        }
    }
}

在这个示例中，我们首先定义了一个插入查询字符串insertQuery，用于向Employees表中插入一条新记录，我们创建了一个SqlCommand对象，并将插入查询字符串传递给它，我们为命令添加了三个参数（@Name、@Age和@Department），并分别设置了它们的值，我们打开连接并执行命令，通过ExecuteNonQuery方法返回受影响的行数，并在控制台上输出插入的行数。

更新数据

以下是一个更新数据的示例：

using System;
using System.Data.SqlClient;
class Program
{
    static void Main()
    {
        string connectionString = "Server=myServerAddress;Database=myDataBase;User Id=myUsername;Password=myPassword;";
        string updateQuery = "UPDATE Employees SET Age = @Age WHERE Name = @Name";
        using (SqlConnection connection = new SqlConnection(connectionString))
        {
            using (SqlCommand command = new SqlCommand(updateQuery, connection))
            {
                command.Parameters.AddWithValue("@Age", 35);
                command.Parameters.AddWithValue("@Name", "John Doe");
                connection.Open();
                int rowsAffected = command.ExecuteNonQuery();
                Console.WriteLine(rowsAffected + " row(s) updated.");
            }
        }
    }
}

在这个示例中，我们首先定义了一个更新查询字符串updateQuery，用于更新Employees表中满足条件（Name等于John Doe）的记录的Age字段，我们创建了一个SqlCommand对象，并将更新查询字符串传递给它，我们为命令添加了两个参数（@Age和@Name），并分别设置了它们的值，我们打开连接并执行命令，通过ExecuteNonQuery方法返回受影响的行数，并在控制台上输出更新的行数。

c#操控数据库

删除数据

以下是一个删除数据的示例：

using System:System.Data.SqlClient;
class Program
{
    static void Main()
    {
        string connectionString = "Server=myServerAddress;Database=myDataBase;User Id=myUsername;Password=myPassword;";
        string deleteQuery = "DELETE FROM Employees WHERE Name = @Name";
        using (SqlConnection connection = new SqlConnection(connectionString))
        {
            using (SqlCommand command = new SqlCommand(deleteQuery, connection))
            {
                command.Parameters.AddWithValue("@Name", "John Doe");
                connection.Open();
                int rowsAffected = command.ExecuteNonQuery();
                Console.WriteLine(rowsAffected + " row(s) deleted.");
            }
        }
    }
}

在这个示例中，我们首先定义了一个删除查询字符串deleteQuery，用于删除Employees表中满足条件（Name等于John Doe）的记录，我们创建了一个SqlCommand对象，并将删除查询字符串传递给它，我们为命令添加了一个参数（@Name），并设置了它的值，我们打开连接并执行命令，通过ExecuteNonQuery方法返回受影响的行数，并在控制台上输出删除的行数。

三、读取和写入数据

除了上述的基本操作外，C#还提供了其他一些方式来读取和写入数据库中的数据，我们可以使用DataTable和DataSet类来存储和处理数据，以下是一个简单的示例：

using System;
using System.Data.SqlClient;
using System.Data;
class Program
{
    static void Main()
    {
        string connectionString = "Server=myServerAddress;Database=myDataBase;User Id=myUsername;Password=myPassword;";
        string query = "SELECT * FROM Employees";
        using (SqlConnection connection = new SqlConnection(connectionString))
        {
            using (SqlCommand command = new SqlCommand(query, connection))
            {
                connection.Open();
                SqlDataAdapter adapter = new SqlDataAdapter(command);
                DataSet dataSet = new DataSet();
                adapter.Fill(dataSet, "Employees");
                foreach (DataRow row in dataSet.Tables["Employees"].Rows)
                {
                    Console.WriteLine(String.Format("{0}, {1}, {2}", row["Name"], row["Age"], row["Department"]));
                }
            }
        }
    }
}

在这个示例中，我们首先定义了一个查询字符串query，用于从Employees表中选择所有记录，我们创建了一个SqlCommand对象和一个SqlDataAdapter对象，并将查询字符串传递给它们，我们创建了一个空的DataSet对象，并使用adapter.Fill方法将查询结果填充到DataSet中，我们遍历DataSet中的记录，并在控制台上输出每条记录的字段值。

c#操控数据库

四、事务处理

在数据库操作中，事务处理是非常重要的一部分，它允许我们将多个操作组合成一个原子性操作单元，要么全部成功执行，要么全部回滚，C#中的事务处理可以通过TransactionScope类来实现，以下是一个简单的示例：

using System;
using System.Data.SqlClient;
using System.Transactions;
class Program
{
    static void Main()
    {
        string connectionString = "Server=myServerAddress;Database=myDataBase;User Id=myUsername;Password=myPassword;";
        string insertQuery = "INSERT INTO Employees (Name, Age, Department) VALUES (@Name, @Age, @Department)";
        string updateQuery = "UPDATE Employees SET Age = @Age WHERE Name = @Name";
        using (TransactionScope transaction = new TransactionScope())
        {
            using (SqlConnection connection = new SqlConnection(connectionString))
            {
                using (SqlCommand insertCommand = new SqlCommand(insertQuery, connection))
                {
                    insertCommand.Parameters.AddWithValue("@Name", "John Doe");
                    insertCommand.Parameters.AddWithValue("@Age", 30);
                    insertCommand.Parameters.AddWithValue("@Department", "IT");
                    connection.Open();
                    insertCommand.ExecuteNonQuery();
                }
                using (SqlCommand updateCommand = new SqlCommand(updateQuery, connection))
                {
                    updateCommand.Parameters.AddWithValue("@Age", 35);
                    updateCommand.Parameters.AddWithValue("@Name", "John Doe");
                    updateCommand.ExecuteNonQuery();
                }
                transaction.Complete(); // 提交事务
            }
        }
    }
}

在这个示例中，我们首先定义了两个查询字符串（一个用于插入数据，一个用于更新数据），我们创建了一个TransactionScope对象来开始一个新的事务，我们在事务范围内执行插入和更新操作，如果所有操作都成功执行，我们调用transaction.Complete()方法提交事务；如果任何一个操作失败，事务将自动回滚，这样，我们就可以确保数据的一致性和完整性。

通过上述内容的介绍，我们可以看到C#在数据库操控方面具有非常强大的功能和灵活性，无论是简单的查询操作还是复杂的事务处理，C#都能提供相应的解决方案，在实际开发中，我们还需要考虑更多的因素，如性能优化、安全性、并发控制等，掌握C#的数据库操控技术对于开发高效的数据库应用程序是非常有帮助的，未来随着技术的不断发展和创新，C#在数据库操控方面也将会有更多的新特性和新功能出现，作为开发者，我们需要不断学习和探索新的技术来提升自己的开发能力和水平。

C 数据库操作关键词