利用ADO.NET命令进行使用介绍("ADO.NET命令使用详解与实践指导")

原创

ithorizon 4周前 (10-20) 阅读数 18 #后端开发

ADO.NET命令使用详解与实践指导

一、概述

ADO.NET（ActiveX Data Objects .NET）是.NET框架中用于数据访问的技术，它提供了一组用于连接、操作数据库的类库。在ADO.NET中，命令对象（SqlCommand）是核心组件之一，用于执行SQL语句或存储过程。本文将详细介绍怎样使用ADO.NET命令进行数据库操作，包括增删改查等实践应用。

二、ADO.NET命令简介

在ADO.NET中，SqlCommand类即SQL命令，用于执行SQL语句或存储过程。SqlCommand类继承自DbCommand类，具有以下首要属性和方法：

CommandText：获取或设置要对数据库执行的SQL语句或存储过程的名称。

CommandType：获取或设置命令的类型，如Text、StoredProcedure等。

Connection：获取或设置SqlCommand使用的数据库连接。

Parameters：获取SqlCommand的参数集合。

ExecuteNonQuery()：执行SQL命令，不返回于是集。

ExecuteReader()：执行SQL命令，返回一个用于读取于是集的SqlDataReader对象。

ExecuteScalar()：执行SQL命令，返回于是集中第一行的第一列的值。

三、连接数据库

在进行数据库操作之前，首先需要创建数据库连接。在ADO.NET中，使用SqlConnection类即数据库连接。以下是一个创建数据库连接的示例代码：


string connectionString = "Server=.;Database=MyDatabase;User Id=sa;Password=123456;";
SqlConnection connection = new SqlConnection(connectionString);

四、执行SQL命令

下面将通过几个示例来介绍怎样使用SqlCommand类执行SQL命令。

4.1 执行增删改操作

使用SqlCommand的ExecuteNonQuery()方法可以执行增删改操作。以下是一个向数据库中插入数据的示例代码：


string connectionString = "Server=.;Database=MyDatabase;User Id=sa;Password=123456;";
string sql = "INSERT INTO Users (Name, Age) VALUES (@Name, @Age)";
using (SqlConnection connection = new SqlConnection(connectionString))
{
    SqlCommand command = new SqlCommand(sql, connection);
    command.Parameters.AddWithValue("@Name", "张三");
    command.Parameters.AddWithValue("@Age", 25);
    connection.Open();
    int result = command.ExecuteNonQuery();
    Console.WriteLine("插入成就，影响行数：" + result);
}

4.2 执行查询操作

使用SqlCommand的ExecuteReader()方法可以执行查询操作，并返回一个SqlDataReader对象。以下是一个查询数据库中所有用户信息的示例代码：


string connectionString = "Server=.;Database=MyDatabase;User Id=sa;Password=123456;";
string sql = "SELECT * FROM Users";
using (SqlConnection connection = new SqlConnection(connectionString))
{
    SqlCommand command = new SqlCommand(sql, connection);
    connection.Open();
    using (SqlDataReader reader = command.ExecuteReader())
    {
        while (reader.Read())
        {
            Console.WriteLine("Name: " + reader["Name"] + ", Age: " + reader["Age"]);
        }
    }
}

4.3 执行查询并返回单个值

使用SqlCommand的ExecuteScalar()方法可以执行查询操作，并返回于是集中第一行的第一列的值。以下是一个查询数据库中用户总数示例代码：


string connectionString = "Server=.;Database=MyDatabase;User Id=sa;Password=123456;";
string sql = "SELECT COUNT(*) FROM Users";
using (SqlConnection connection = new SqlConnection(connectionString))
{
    SqlCommand command = new SqlCommand(sql, connection);
    connection.Open();
    int count = (int)command.ExecuteScalar();
    Console.WriteLine("用户总数：" + count);
}

五、参数化查询

参数化查询是防止SQL注入的有效方法。在ADO.NET中，可以使用SqlCommand的Parameters属性来添加参数。以下是一个使用参数化查询的示例代码：


string connectionString = "Server=.;Database=MyDatabase;User Id=sa;Password=123456;";
string sql = "SELECT * FROM Users WHERE Name = @Name";
using (SqlConnection connection = new SqlConnection(connectionString))
{
    SqlCommand command = new SqlCommand(sql, connection);
    command.Parameters.AddWithValue("@Name", "张三");
    connection.Open();
    using (SqlDataReader reader = command.ExecuteReader())
    {
        while (reader.Read())
        {
            Console.WriteLine("Name: " + reader["Name"] + ", Age: " + reader["Age"]);
        }
    }
}

六、事务处理

在数据库操作中，事务处理可以确保多个操作作为一个整体执行，要么全部成就，要么全部挫败。在ADO.NET中，可以使用SqlConnection类的BeginTransaction()方法起初一个事务。以下是一个使用事务处理的示例代码：


string connectionString = "Server=.;Database=MyDatabase;User Id=sa;Password=123456;";
string sql1 = "INSERT INTO Users (Name, Age) VALUES (@Name, @Age)";
string sql2 = "UPDATE Users SET Age = @Age WHERE Name = @Name";
using (SqlConnection connection = new SqlConnection(connectionString))
{
    connection.Open();
    SqlTransaction transaction = connection.BeginTransaction();
    try
    {
        SqlCommand command1 = new SqlCommand(sql1, connection, transaction);
        command1.Parameters.AddWithValue("@Name", "李四");
        command1.Parameters.AddWithValue("@Age", 30);
        command1.ExecuteNonQuery();
        SqlCommand command2 = new SqlCommand(sql2, connection, transaction);
        command2.Parameters.AddWithValue("@Name", "李四");
        command2.Parameters.AddWithValue("@Age", 35);
        command2.ExecuteNonQuery();
        transaction.Commit();
        Console.WriteLine("事务提交成就");
    }
    catch (Exception)
    {
        transaction.Rollback();
        Console.WriteLine("事务回滚");
    }
}