当前位置：首页 > 行业动态 > 正文

c# 数据库access

admin
行业动态
2025-02-22
3

在C#中操作Access数据库，可借助OleDbConnection等类，通过连接字符串连接后进行增删改查等操作。

在C#中操作Access数据库是一个常见的需求，特别是在桌面应用程序开发中，下面将详细介绍如何在C#中连接和操作Access数据库。

一、准备工作

1、安装必要的软件

Microsoft Access：确保你的系统上安装了Microsoft Access，你可以从微软官方网站下载并安装。

Microsoft .NET Framework：确保你的系统上安装了.NET Framework，因为C#是基于.NET框架的编程语言。

2、创建Access数据库

c# 数据库access

打开Microsoft Access，创建一个新的数据库文件（MyDatabase.accdb）。

在数据库中创建一个表（Users），并添加一些列（ID,Name,Email）。

二、连接到Access数据库

在C#中，你可以使用System.Data.OleDb命名空间中的类来连接和操作Access数据库，下面是一个简单的示例，演示如何连接到Access数据库并执行一个查询。

示例代码

using System;
using System.Data;
using System.Data.OleDb;
namespace AccessDatabaseExample
{
    class Program
    {
        static void Main(string[] args)
        {
            // 定义连接字符串
            string connectionString = @"Provider=Microsoft.ACE.OLEDB.12.0;Data Source=C:pathtoyourdatabaseMyDatabase.accdb;";
            // 创建OleDbConnection对象
            using (OleDbConnection connection = new OleDbConnection(connectionString))
            {
                try
                {
                    // 打开连接
                    connection.Open();
                    Console.WriteLine("连接成功！");
                    // 定义查询字符串
                    string query = "SELECT * FROM Users";
                    // 创建OleDbCommand对象
                    OleDbCommand command = new OleDbCommand(query, connection);
                    // 执行查询并读取结果
                    using (OleDbDataReader reader = command.ExecuteReader())
                    {
                        while (reader.Read())
                        {
                            int id = reader.GetInt32(0);
                            string name = reader.GetString(1);
                            string email = reader.GetString(2);
                            Console.WriteLine($"ID: {id}, Name: {name}, Email: {email}");
                        }
                    }
                }
                catch (Exception ex)
                {
                    Console.WriteLine("发生错误：" + ex.Message);
                }
            }
        }
    }
}

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

除了查询数据，你还可以使用C#来插入、更新和删除Access数据库中的数据，以下是一些示例代码。

c# 数据库access

插入数据

string insertQuery = "INSERT INTO Users (Name, Email) VALUES (@Name, @Email)";
using (OleDbCommand command = new OleDbCommand(insertQuery, connection))
{
    command.Parameters.AddWithValue("@Name", "John Doe");
    command.Parameters.AddWithValue("@Email", "john.doe@example.com");
    command.ExecuteNonQuery();
}

更新数据

string updateQuery = "UPDATE Users SET Email = @Email WHERE ID = @ID";
using (OleDbCommand command = new OleDbCommand(updateQuery, connection))
{
    command.Parameters.AddWithValue("@Email", "new.email@example.com");
    command.Parameters.AddWithValue("@ID", 1);
    command.ExecuteNonQuery();
}

删除数据

string deleteQuery = "DELETE FROM Users WHERE ID = @ID";
using (OleDbCommand command = new OleDbCommand(deleteQuery, connection))
{
    command.Parameters.AddWithValue("@ID", 1);
    command.ExecuteNonQuery();
}

四、处理事务

在执行多个数据库操作时，你可能需要使用事务来确保数据的一致性，以下是一个示例，演示如何使用事务来插入和更新数据。

示例代码

using (OleDbConnection connection = new OleDbConnection(connectionString))
{
    connection.Open();
    OleDbTransaction transaction = connection.BeginTransaction();
    try
    {
        // 插入数据
        string insertQuery = "INSERT INTO Users (Name, Email) VALUES (@Name, @Email)";
        using (OleDbCommand insertCommand = new OleDbCommand(insertQuery, connection, transaction))
        {
            insertCommand.Parameters.AddWithValue("@Name", "Jane Doe");
            insertCommand.Parameters.AddWithValue("@Email", "jane.doe@example.com");
            insertCommand.ExecuteNonQuery();
        }
        // 更新数据
        string updateQuery = "UPDATE Users SET Email = @Email WHERE ID = @ID";
        using (OleDbCommand updateCommand = new OleDbCommand(updateQuery, connection, transaction))
        {
            updateCommand.Parameters.AddWithValue("@Email", "new.email@example.com");
            updateCommand.Parameters.AddWithValue("@ID", 1);
            updateCommand.ExecuteNonQuery();
        }
        // 提交事务
        transaction.Commit();
    }
    catch (Exception ex)
    {
        // 回滚事务
        transaction.Rollback();
        Console.WriteLine("发生错误：" + ex.Message);
    }
}