使用ADO.NET对象模型数据库("利用ADO.NET对象模型高效操作数据库")

原创

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

利用ADO.NET对象模型高效操作数据库

一、引言

在.NET环境下，ADO.NET是一种用于访问数据库的技术。它提供了一组丰盈的对象模型，促使开发人员能够轻松地实现对数据库的各种操作，如查询、更新、插入和删除等。本文将详细介绍怎样使用ADO.NET对象模型高效操作数据库。

二、ADO.NET对象模型概述

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

Connection：用于与数据库构建连接。

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

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

DataSet：用于在内存中存储数据。

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

三、连接数据库

在操作数据库之前，首先需要构建与数据库的连接。以下是一个使用SqlConnection对象连接SQL Server数据库的示例：


        string connectionString = "server=.;database=TestDB;uid=sa;pwd=123456";
        SqlConnection connection = new SqlConnection(connectionString);
        try
        {
            connection.Open();
            Console.WriteLine("数据库连接胜利！");
        }
        catch (Exception ex)
        {
            Console.WriteLine("数据库连接落败：" + ex.Message);
        }
        finally
        {
            connection.Close();
        }

四、执行SQL命令

使用SqlCommand对象可以执行SQL命令或存储过程。以下是一个执行查询操作的示例：


        string connectionString = "server=.;database=TestDB;uid=sa;pwd=123456";
        using (SqlConnection connection = new SqlConnection(connectionString))
        {
            connection.Open();
            string sql = "SELECT * FROM Users";
            SqlCommand command = new SqlCommand(sql, connection);
            SqlDataReader reader = command.ExecuteReader();
            while (reader.Read())
            {
                Console.WriteLine("用户名：" + reader["Username"]);
            }
        }

五、使用DataSet操作数据

DataSet是一个内存中的数据库，它可以包含多个DataTable对象，用于存储数据。以下是一个使用DataSet查询数据的示例：


        string connectionString = "server=.;database=TestDB;uid=sa;pwd=123456";
        using (SqlConnection connection = new SqlConnection(connectionString))
        {
            connection.Open();
            string sql = "SELECT * FROM Users";
            SqlCommand command = new SqlCommand(sql, connection);
            SqlDataAdapter adapter = new SqlDataAdapter(command);
            DataSet dataSet = new DataSet();
            adapter.Fill(dataSet, "Users");
            DataTable table = dataSet.Tables["Users"];
            foreach (DataRow row in table.Rows)
            {
                Console.WriteLine("用户名：" + row["Username"]);
            }
        }

六、更新数据库

使用DataAdapter的Update方法可以将DataSet中的更改更新到数据库。以下是一个更新数据的示例：


        string connectionString = "server=.;database=TestDB;uid=sa;pwd=123456";
        using (SqlConnection connection = new SqlConnection(connectionString))
        {
            connection.Open();
            string sql = "SELECT * FROM Users";
            SqlCommand command = new SqlCommand(sql, connection);
            SqlDataAdapter adapter = new SqlDataAdapter(command);
            DataSet dataSet = new DataSet();
            adapter.Fill(dataSet, "Users");
            DataTable table = dataSet.Tables["Users"];
            // 更新数据
            DataRow row = table.Rows[0];
            row["Username"] = "新用户名";
            // 将更改更新到数据库
            adapter.Update(dataSet, "Users");
        }

七、事务处理

在操作数据库时，事务处理是非常重要的。ADO.NET提供了Transaction对象，用于实现事务操作。以下是一个使用事务处理更新数据的示例：


        string connectionString = "server=.;database=TestDB;uid=sa;pwd=123456";
        using (SqlConnection connection = new SqlConnection(connectionString))
        {
            connection.Open();
            SqlTransaction transaction = connection.BeginTransaction();
            try
            {
                string sql1 = "UPDATE Users SET Username='新用户名' WHERE ID=1";
                string sql2 = "UPDATE Roles SET RoleName='新角色名' WHERE ID=1";
                SqlCommand command1 = new SqlCommand(sql1, connection, transaction);
                SqlCommand command2 = new SqlCommand(sql2, connection, transaction);
                command1.ExecuteNonQuery();
                command2.ExecuteNonQuery();
                transaction.Commit();
                Console.WriteLine("事务提交胜利！");
            }
            catch (Exception ex)
            {
                transaction.Rollback();
                Console.WriteLine("事务回滚：" + ex.Message);
            }
        }