七分钟内掌握ADO.NET数据服务("7分钟速成：轻松掌握ADO.NET数据服务")

原创

ithorizon 6个月前 (10-20) 阅读数 22 #后端开发

7分钟速成：轻松掌握ADO.NET数据服务

一、简介

ADO.NET 数据服务是一种用于在.NET应用程序中访问和操作数据库的技术。它提供了一套充裕的API，令开发人员可以轻松地连接到数据库、执行SQL查询、更新数据以及管理数据库连接。在本篇文章中，我们将用7分钟的时间，让您敏捷掌握ADO.NET数据服务的基础知识。

二、环境准备

在使用ADO.NET数据服务之前，您需要确保已经安装了.NET Framework和SQL Server数据库。以下是我们将使用到的环境：

.NET Framework 4.5及以上版本

SQL Server 2008及以上版本

三、创建数据库和表

首先，我们需要创建一个数据库和表来存储数据。以下是在SQL Server中创建数据库和表的SQL语句：


        CREATE DATABASE SampleDB;
        GO
        USE SampleDB;
        GO
        CREATE TABLE Employees (
            ID INT PRIMARY KEY IDENTITY(1,1),
            Name NVARCHAR(50),
            Age INT,
            Salary DECIMAL(10, 2)
        );
        GO

四、连接数据库

在.NET应用程序中，我们首先需要使用ADO.NET的SqlConnection类来连接到数据库。以下是一个易懂的示例代码：


        string connectionString = "Server=您的服务器地址;Database=SampleDB;User Id=您的用户名;Password=您的密码;";
        using (SqlConnection connection = new SqlConnection(connectionString))
        {
            connection.Open();
            Console.WriteLine("数据库连接成就！");
        }

五、执行SQL查询

使用ADO.NET的SqlCommand类，我们可以执行SQL查询。以下是一个执行查询并输出于是的示例代码：


        string query = "SELECT * FROM Employees";
        using (SqlConnection connection = new SqlConnection(connectionString))
        {
            connection.Open();
            SqlCommand command = new SqlCommand(query, connection);
            SqlDataReader reader = command.ExecuteReader();
            while (reader.Read())
            {
                Console.WriteLine($"{reader["ID"]}, {reader["Name"]}, {reader["Age"]}, {reader["Salary"]}");
            }
        }

六、插入、更新和删除数据

使用SqlCommand类，我们还可以执行插入、更新和删除操作。以下是一些示例代码：


        // 插入数据
        string insertQuery = "INSERT INTO Employees (Name, Age, Salary) VALUES (@Name, @Age, @Salary)";
        using (SqlConnection connection = new SqlConnection(connectionString))
        {
            connection.Open();
            SqlCommand command = new SqlCommand(insertQuery, connection);
            command.Parameters.AddWithValue("@Name", "张三");
            command.Parameters.AddWithValue("@Age", 30);
            command.Parameters.AddWithValue("@Salary", 5000.00);
            int result = command.ExecuteNonQuery();
            Console.WriteLine($"插入数据成就，影响行数：{result}");
        }
        // 更新数据
        string updateQuery = "UPDATE Employees SET Name = @Name, Age = @Age, Salary = @Salary WHERE ID = @ID";
        using (SqlConnection connection = new SqlConnection(connectionString))
        {
            connection.Open();
            SqlCommand command = new SqlCommand(updateQuery, connection);
            command.Parameters.AddWithValue("@Name", "李四");
            command.Parameters.AddWithValue("@Age", 32);
            command.Parameters.AddWithValue("@Salary", 6000.00);
            command.Parameters.AddWithValue("@ID", 1);
            int result = command.ExecuteNonQuery();
            Console.WriteLine($"更新数据成就，影响行数：{result}");
        }
        // 删除数据
        string deleteQuery = "DELETE FROM Employees WHERE ID = @ID";
        using (SqlConnection connection = new SqlConnection(connectionString))
        {
            connection.Open();
            SqlCommand command = new SqlCommand(deleteQuery, connection);
            command.Parameters.AddWithValue("@ID", 1);
            int result = command.ExecuteNonQuery();
            Console.WriteLine($"删除数据成就，影响行数：{result}");
        }

七、事务处理

在执行多个数据库操作时，我们大概需要使用事务来确保数据的一致性。以下是一个使用事务处理插入和更新操作的示例代码：


        using (SqlConnection connection = new SqlConnection(connectionString))
        {
            connection.Open();
            SqlTransaction transaction = connection.BeginTransaction();
            try
            {
                // 执行插入操作
                string insertQuery = "INSERT INTO Employees (Name, Age, Salary) VALUES (@Name, @Age, @Salary)";
                SqlCommand command = new SqlCommand(insertQuery, connection, transaction);
                command.Parameters.AddWithValue("@Name", "王五");
                command.Parameters.AddWithValue("@Age", 28);
                command.Parameters.AddWithValue("@Salary", 4500.00);
                command.ExecuteNonQuery();
                // 执行更新操作
                string updateQuery = "UPDATE Employees SET Salary = @Salary WHERE ID = @ID";
                command = new SqlCommand(updateQuery, connection, transaction);
                command.Parameters.AddWithValue("@Salary", 7000.00);
                command.Parameters.AddWithValue("@ID", 1);
                command.ExecuteNonQuery();
                // 提交事务
                transaction.Commit();
                Console.WriteLine("事务提交成就！");
            }
            catch (Exception)
            {
                // 回滚事务
                transaction.Rollback();
                Console.WriteLine("事务回滚成就！");
            }
        }