在 C# 中，连接到数据库通常有多种方式，其中使用 OLE DB 来连接数据库是一种常见的方式，尤其是当你需要访问较老的数据库或非 SQL Server 数据库时。OleDbConnection 类是 System.Data.OleDb 命名空间的一部分，用于与 OLE DB 数据源建立连接。

下面是 C# 中使用 OleDbConnection 连接和操作数据库的步骤。

1. 添加引用

首先，确保你的项目中引用了 System.Data 和 System.Data.OleDb，因为它们包含了你所需要的 OleDbConnection 类。

2. 连接字符串

OleDbConnection 需要一个连接字符串来指示如何连接到数据库。连接字符串的格式依赖于你连接的数据库类型（例如 Access、Excel 或其他数据库）。

示例连接字符串：

  • Access 数据库："Provider=Microsoft.ACE.OLEDB.12.0;Data Source=your-database-path.accdb;"
  • SQL Server 数据库："Provider=SQLOLEDB;Data Source=server-name;Initial Catalog=database-name;User ID=user-id;Password=password;"
  • Excel 文件："Provider=Microsoft.ACE.OLEDB.12.0;Data Source=your-file-path.xlsx;Extended Properties=\"Excel 12.0;HDR=YES;\""

3. C# 代码示例

以下是一个基本的 C# 示例，展示如何使用 OleDbConnection 连接到数据库，执行查询，并读取数据。

代码示例：连接到 Access 数据库并读取数据

using System;
using System.Data;
using System.Data.OleDb;

namespace OleDbExample
{
    class Program
    {
        static void Main(string[] args)
        {
            // 数据库连接字符串
            string connectionString = @"Provider=Microsoft.ACE.OLEDB.12.0;Data Source=C:\path\to\your\database.accdb;";

            // 使用 OleDbConnection 创建连接
            using (OleDbConnection connection = new OleDbConnection(connectionString))
            {
                try
                {
                    // 打开连接
                    connection.Open();
                    Console.WriteLine("连接成功！");

                    // 创建查询
                    string query = "SELECT * FROM your_table_name";
                    OleDbCommand command = new OleDbCommand(query, connection);

                    // 执行查询并获取数据
                    OleDbDataReader reader = command.ExecuteReader();
                    
                    // 读取数据
                    while (reader.Read())
                    {
                        // 假设数据表的第一列是 id，第二列是 name
                        Console.WriteLine($"ID: {reader[0]}, Name: {reader[1]}");
                    }
                    
                    // 关闭数据读取器
                    reader.Close();
                }
                catch (Exception ex)
                {
                    Console.WriteLine("连接失败: " + ex.Message);
                }
            }
        }
    }
}

解释：

  • 连接字符串：用于连接到数据库的关键部分。这里使用了 Microsoft.ACE.OLEDB.12.0 提供程序，它通常用于连接 Microsoft Access 数据库。你需要根据实际情况调整文件路径。
  • OleDbConnection：建立到数据库的连接。
  • OleDbCommand：执行 SQL 查询或其他数据库命令。
  • OleDbDataReader：用于读取查询结果，类似于 SqlDataReader，用来处理从数据库中返回的数据。

4. 插入数据

你可以使用 OleDbCommand 执行 INSERT 操作以向数据库中插入数据。

代码示例：插入数据到数据库

using System;
using System.Data.OleDb;

namespace OleDbInsertExample
{
    class Program
    {
        static void Main(string[] args)
        {
            // 数据库连接字符串
            string connectionString = @"Provider=Microsoft.ACE.OLEDB.12.0;Data Source=C:\path\to\your\database.accdb;";

            // 使用 OleDbConnection 创建连接
            using (OleDbConnection connection = new OleDbConnection(connectionString))
            {
                try
                {
                    // 打开连接
                    connection.Open();
                    Console.WriteLine("连接成功！");

                    // 插入数据的 SQL 语句
                    string query = "INSERT INTO your_table_name (column1, column2) VALUES (?, ?)";
                    OleDbCommand command = new OleDbCommand(query, connection);

                    // 添加参数，防止 SQL 注入
                    command.Parameters.AddWithValue("?", "Sample Value 1");
                    command.Parameters.AddWithValue("?", "Sample Value 2");

                    // 执行插入操作
                    int rowsAffected = command.ExecuteNonQuery();
                    Console.WriteLine($"{rowsAffected} 行数据已插入！");
                }
                catch (Exception ex)
                {
                    Console.WriteLine("操作失败: " + ex.Message);
                }
            }
        }
    }
}

解释：

  • 使用 ExecuteNonQuery() 方法执行不返回结果集的 SQL 语句（如 INSERT、UPDATE 或 DELETE）。
  • 为了防止 SQL 注入，我们使用 参数化查询（?）来插入数据。

5. 更新数据

你也可以使用 UPDATE 语句来更新数据库中的数据，以下是更新数据的代码示例。

代码示例：更新数据

using System;
using System.Data.OleDb;

namespace OleDbUpdateExample
{
    class Program
    {
        static void Main(string[] args)
        {
            // 数据库连接字符串
            string connectionString = @"Provider=Microsoft.ACE.OLEDB.12.0;Data Source=C:\path\to\your\database.accdb;";

            // 使用 OleDbConnection 创建连接
            using (OleDbConnection connection = new OleDbConnection(connectionString))
            {
                try
                {
                    // 打开连接
                    connection.Open();
                    Console.WriteLine("连接成功！");

                    // 更新数据的 SQL 语句
                    string query = "UPDATE your_table_name SET column1 = ? WHERE column2 = ?";
                    OleDbCommand command = new OleDbCommand(query, connection);

                    // 添加参数
                    command.Parameters.AddWithValue("?", "Updated Value");
                    command.Parameters.AddWithValue("?", "Sample Value 2");

                    // 执行更新操作
                    int rowsAffected = command.ExecuteNonQuery();
                    Console.WriteLine($"{rowsAffected} 行数据已更新！");
                }
                catch (Exception ex)
                {
                    Console.WriteLine("操作失败: " + ex.Message);
                }
            }
        }
    }
}

解释：

  • 使用 UPDATE 语句来更新表中的数据。
  • 通过 ExecuteNonQuery() 执行 SQL 更新操作。

6. 删除数据

如果你需要删除数据，可以使用 DELETE 语句，代码示例如下。

代码示例：删除数据

using System;
using System.Data.OleDb;

namespace OleDbDeleteExample
{
    class Program
    {
        static void Main(string[] args)
        {
            // 数据库连接字符串
            string connectionString = @"Provider=Microsoft.ACE.OLEDB.12.0;Data Source=C:\path\to\your\database.accdb;";

            // 使用 OleDbConnection 创建连接
            using (OleDbConnection connection = new OleDbConnection(connectionString))
            {
                try
                {
                    // 打开连接
                    connection.Open();
                    Console.WriteLine("连接成功！");

                    // 删除数据的 SQL 语句
                    string query = "DELETE FROM your_table_name WHERE column1 = ?";
                    OleDbCommand command = new OleDbCommand(query, connection);

                    // 添加参数
                    command.Parameters.AddWithValue("?", "Sample Value 1");

                    // 执行删除操作
                    int rowsAffected = command.ExecuteNonQuery();
                    Console.WriteLine($"{rowsAffected} 行数据已删除！");
                }
                catch (Exception ex)
                {
                    Console.WriteLine("操作失败: " + ex.Message);
                }
            }
        }
    }
}

总结

  • OleDbConnection 用于与 OLE DB 数据源建立连接，可以连接到多种类型的数据库（如 Microsoft Access、Excel 等）。
  • 通过使用 OleDbCommand 来执行 SQL 查询、插入、更新或删除操作。
  • 使用 参数化查询 防止 SQL 注入攻击，保证应用的安全性。

希望这些代码示例能帮助你更好地理解如何使用 OleDbConnection 进行数据库操作。如果你有任何问题或需要进一步的帮助，请告诉我！