对于ADO.NET对象模型进行学习研究("深入探索ADO.NET对象模型：学习与实践指南")

原创

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

深入探索ADO.NET对象模型：学习与实践指南

一、引言

ADO.NET是.NET Framework中用于数据访问和操作的核心技术。它提供了一组用于连接数据库、执行命令、检索数据以及更新数据库的对象模型。本文将深入探讨ADO.NET对象模型，帮助读者更好地领会其工作原理，并提供实际应用中的实践指南。

二、ADO.NET对象模型概述

ADO.NET对象模型重点包括以下几个核心组件：

Connection：用于生成与数据库的连接。

Command：用于执行SQL命令或存储过程。

DataReader：用于从数据库读取数据。

DataSet：用于在内存中存储数据，并与数据库进行交互。

DataAdapter：用于填充DataSet和更新数据库。

三、Connection对象

Connection对象用于生成与数据库的连接。下面是一个明了的示例，展示了怎样使用Connection对象连接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("连接圆满！");
            }
            catch (Exception e)
            {
                Console.WriteLine("连接失利：" + e.Message);
            }
        }
    }
}

四、Command对象

Command对象用于执行SQL命令或存储过程。下面是一个示例，展示了怎样使用Command对象执行一个明了的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 = "SELECT * FROM Employees";
            using (SqlCommand command = new SqlCommand(query, connection))
            {
                using (SqlDataReader reader = command.ExecuteReader())
                {
                    while (reader.Read())
                    {
                        Console.WriteLine(reader["Name"] + " - " + reader["Title"]);
                    }
                }
            }
        }
    }
}

五、DataReader对象

DataReader对象用于从数据库读取数据。它提供了一种高效的行为来读取大量数据，下面是一个示例：


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 * FROM Employees";
            using (SqlCommand command = new SqlCommand(query, connection))
            {
                using (SqlDataReader reader = command.ExecuteReader())
                {
                    while (reader.Read())
                    {
                        Console.WriteLine(reader["Name"] + " - " + reader["Title"]);
                    }
                }
            }
        }
    }
}

六、DataSet对象

DataSet对象用于在内存中存储数据，并与数据库进行交互。下面是一个示例，展示了怎样使用DataSet对象填充数据并操作它：


using System;
using System.Data;
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 * FROM Employees";
            using (SqlCommand command = new SqlCommand(query, connection))
            {
                using (SqlDataAdapter adapter = new SqlDataAdapter(command))
                {
                    DataSet dataSet = new DataSet();
                    adapter.Fill(dataSet, "Employees");
                    DataTable employees = dataSet.Tables["Employees"];
                    foreach (DataRow row in employees.Rows)
                    {
                        Console.WriteLine(row["Name"] + " - " + row["Title"]);
                    }
                }
            }
        }
    }
}

七、DataAdapter对象

DataAdapter对象用于填充DataSet和更新数据库。下面是一个示例，展示了怎样使用DataAdapter对象更新数据库：


using System;
using System.Data;
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 * FROM Employees";
            using (SqlCommand command = new SqlCommand(query, connection))
            {
                using (SqlDataAdapter adapter = new SqlDataAdapter(command))
                {
                    DataSet dataSet = new DataSet();
                    adapter.Fill(dataSet, "Employees");
                    DataTable employees = dataSet.Tables["Employees"];
                    // 假设我们修改了某个员工的信息
                    employees.Rows[0]["Title"] = "Senior Developer";
                    // 更新数据库
                    SqlCommandBuilder builder = new SqlCommandBuilder(adapter);
                    adapter.Update(employees);
                }
            }
        }
    }
}