创建使用ADO.NET数据库及其维护("使用ADO.NET构建与维护数据库全指南")

原创

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

使用ADO.NET构建与维护数据库全指南

一、引言

在.NET环境下，ADO.NET是一种广泛使用的数据库访问技术。它提供了一组用于连接、操作数据库的类库，允许开发者能够方便地实现对数据库的构建与维护。本文将详细介绍怎样使用ADO.NET构建与维护数据库，包括连接数据库、执行SQL命令、事务处理等内容。

二、环境准备

在使用ADO.NET之前，需要确保安装了.NET Framework和相应的数据库驱动程序。以下是一个基本的开发环境配置：

操作系统：Windows 7/8/10

开发工具：Visual Studio 2019/2022

数据库：SQL Server 2016/2019

三、连接数据库

首先，我们需要创建一个数据库连接。在ADO.NET中，使用SqlConnection类来即数据库连接。下面是一个易懂的示例代码：


using System;
using System.Data.SqlClient;
class Program
{
    static void Main()
    {
        string connectionString = "server=localhost;database=TestDB;uid=sa;pwd=123456";
        using (SqlConnection conn = new SqlConnection(connectionString))
        {
            try
            {
                conn.Open();
                Console.WriteLine("数据库连接圆满！");
            }
            catch (Exception ex)
            {
                Console.WriteLine("数据库连接挫败：" + ex.Message);
            }
        }
    }
}

四、执行SQL命令

在连接数据库后，我们可以使用SqlCommand类来执行SQL命令。以下是一个执行查询操作的示例代码：


using System;
using System.Data.SqlClient;
class Program
{
    static void Main()
    {
        string connectionString = "server=localhost;database=TestDB;uid=sa;pwd=123456";
        using (SqlConnection conn = new SqlConnection(connectionString))
        {
            conn.Open();
            string sql = "SELECT * FROM Users";
            using (SqlCommand cmd = new SqlCommand(sql, conn))
            {
                using (SqlDataReader reader = cmd.ExecuteReader())
                {
                    while (reader.Read())
                    {
                        Console.WriteLine("用户名：{0}，密码：{1}", reader["Username"], reader["Password"]);
                    }
                }
            }
        }
    }
}

五、插入、更新和删除操作

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


using System;
using System.Data.SqlClient;
class Program
{
    static void Main()
    {
        string connectionString = "server=localhost;database=TestDB;uid=sa;pwd=123456";
        using (SqlConnection conn = new SqlConnection(connectionString))
        {
            conn.Open();
            string sql = "INSERT INTO Users (Username, Password) VALUES ('test', '123456')";
            using (SqlCommand cmd = new SqlCommand(sql, conn))
            {
                int result = cmd.ExecuteNonQuery();
                if (result > 0)
                {
                    Console.WriteLine("插入圆满！");
                }
                else
                {
                    Console.WriteLine("插入挫败！");
                }
            }
        }
    }
}

六、事务处理

在进行数据库操作时，事务处理非常重要。在ADO.NET中，我们可以使用SqlTransaction类来管理事务。以下是一个事务处理的示例代码：


using System;
using System.Data.SqlClient;
class Program
{
    static void Main()
    {
        string connectionString = "server=localhost;database=TestDB;uid=sa;pwd=123456";
        using (SqlConnection conn = new SqlConnection(connectionString))
        {
            conn.Open();
            using (SqlTransaction transaction = conn.BeginTransaction())
            {
                try
                {
                    string sql1 = "UPDATE Users SET Password='654321' WHERE Username='test'";
                    using (SqlCommand cmd1 = new SqlCommand(sql1, conn, transaction))
                    {
                        cmd1.ExecuteNonQuery();
                    }
                    string sql2 = "DELETE FROM Users WHERE Username='test'";
                    using (SqlCommand cmd2 = new SqlCommand(sql2, conn, transaction))
                    {
                        cmd2.ExecuteNonQuery();
                    }
                    transaction.Commit();
                    Console.WriteLine("事务提交圆满！");
                }
                catch (Exception ex)
                {
                    transaction.Rollback();
                    Console.WriteLine("事务回滚：" + ex.Message);
                }
            }
        }
    }
}

七、数据库维护

数据库维护包括创建表、修改表结构、创建索引等操作。以下是一个创建表的示例代码：


using System;
using System.Data.SqlClient;
class Program
{
    static void Main()
    {
        string connectionString = "server=localhost;database=TestDB;uid=sa;pwd=123456";
        using (SqlConnection conn = new SqlConnection(connectionString))
        {
            conn.Open();
            string sql = "CREATE TABLE Products (" +
                         "ProductID INT PRIMARY KEY," +
                         "ProductName NVARCHAR(50)," +
                         "Price DECIMAL(10, 2))";
            using (SqlCommand cmd = new SqlCommand(sql, conn))
            {
                cmd.ExecuteNonQuery();
                Console.WriteLine("表创建圆满！");
            }
        }
    }
}