C#与Oracle数据库|极客笔记

C#与Oracle数据库

1. 概述

C# 是一种强类型、面向对象的编程语言，而 Oracle 是一种全球领先的关系数据库管理系统。C# 与 Oracle 数据库的结合，可以提供强大的数据处理和管理能力，适用于各种应用场景。

本文将介绍如何使用 C# 与 Oracle 数据库进行连接、数据查询、数据插入和更新、事务处理等操作。同时，还将介绍如何使用 Oracle 数据库的一些高级功能，如存储过程、触发器、索引、视图等。

2. 连接 Oracle 数据库

在 C# 中连接 Oracle 数据库，需要使用 Oracle 提供的官方数据访问组件 Oracle.DataAccess 或者通过 NuGet 安装的 Oracle.ManagedDataAccess.Client。这两者的使用方式类似，我们以 Oracle.ManagedDataAccess.Client 为例进行说明。

首先，在项目中添加对 Oracle.ManagedDataAccess.Client 的引用。

using Oracle.ManagedDataAccess.Client;

然后，通过创建 OracleConnection 对象来连接 Oracle 数据库。

string connectionString = "Data Source=your_oracle_server;User Id=your_username;Password=your_password;";
OracleConnection connection = new OracleConnection(connectionString);

try
{
    connection.Open();
    Console.WriteLine("连接成功！");
}
catch (Exception ex)
{
    Console.WriteLine("连接失败：" + ex.Message);
}
finally
{
    connection.Close();
}

在上述代码中，your_oracle_server 是 Oracle 数据库的服务器地址，your_username 是登录用户名，your_password 是登录密码。

3. 执行 SQL 查询

连接成功后，我们可以使用 OracleCommand 对象来执行 SQL 查询语句，并获取查询结果。

string sql = "SELECT * FROM employees";
OracleCommand command = new OracleCommand(sql, connection);
OracleDataReader reader = command.ExecuteReader();

while (reader.Read())
{
    string name = reader.GetString(0);
    int age = reader.GetInt32(1);
    Console.WriteLine($"姓名：{name}，年龄：{age}");
}

reader.Close();

在上述代码中，我们执行了一个简单的查询语句，获取了 employees 表中的所有记录，并输出了每条记录的姓名和年龄。

4. 插入和更新数据

要向 Oracle 数据库插入或更新数据，可以使用 OracleCommand 对象的 ExecuteNonQuery 方法。

string sql = "INSERT INTO employees (name, age) VALUES ('John', 30)";
OracleCommand command = new OracleCommand(sql, connection);
int rowsAffected = command.ExecuteNonQuery();

Console.WriteLine($"插入 {rowsAffected} 条数据。");

在上述代码中，我们执行了一个插入语句，向 employees 表中插入了一条记录。ExecuteNonQuery 方法返回插入或更新的记录数。

5. 事务处理

在需要对多个 SQL 语句进行原子操作的场景下，可以使用事务处理来确保数据的一致性。

OracleTransaction transaction = connection.BeginTransaction();

try
{
    string sql1 = "INSERT INTO employees (name, age) VALUES ('Jane', 25)";
    string sql2 = "UPDATE employees SET age = 26 WHERE name = 'John'";

    OracleCommand command1 = new OracleCommand(sql1, connection, transaction);
    OracleCommand command2 = new OracleCommand(sql2, connection, transaction);

    command1.ExecuteNonQuery();
    command2.ExecuteNonQuery();

    transaction.Commit();
    Console.WriteLine("事务提交成功！");
}
catch (Exception ex)
{
    transaction.Rollback();
    Console.WriteLine("事务回滚：" + ex.Message);
}
finally
{
    connection.Close();
}

在上述代码中，我们通过 connection.BeginTransaction() 方法创建了一个事务对象，并将其与两个 SQL 命令绑定。在执行两个 SQL 命令之后，通过 transaction.Commit() 提交事务，或者在出现异常时通过 transaction.Rollback() 回滚事务。

6. Oracle 数据库高级功能

除了基本的连接和数据操作，Oracle 数据库还提供了许多高级功能，包括存储过程、触发器、索引、视图等。

6.1 存储过程

存储过程是一组预编译的 SQL 语句，可以在 Oracle 数据库中进行存储和重复使用。C# 中可以使用 OracleCommand 对象执行存储过程。

string sql = "BEGIN my_stored_proc(:param1, :param2, :param3); END;";
OracleCommand command = new OracleCommand(sql, connection);

command.Parameters.Add("param1", OracleDbType.Varchar2, "John", ParameterDirection.Input);
command.Parameters.Add("param2", OracleDbType.Int32, 30, ParameterDirection.Input);
command.Parameters.Add("param3", OracleDbType.RefCursor, ParameterDirection.Output);

command.ExecuteNonQuery();

// 处理输出参数
OracleDataReader reader = ((OracleRefCursor)command.Parameters["param3"].Value).GetDataReader();

while (reader.Read())
{
    string name = reader.GetString(0);
    int age = reader.GetInt32(1);
    Console.WriteLine($"姓名：{name}，年龄：{age}");
}

在上述代码中，我们通过 command.Parameters.Add() 方法添加了三个参数，其中 param3 是一个输出参数，对应了存储过程的返回结果。

6.2 触发器

触发器是在数据库中某些事件发生时自动执行的一段代码。在封装在触发器中的代码可以在插入、更新或删除数据库表时执行。

6.3 索引

索引是对数据库表中一列或多列的值进行排序的结构，提高对表中数据的查询速度。在 Oracle 数据库中，可以使用 CREATE INDEX 命令创建索引。

6.4 视图

视图是一个虚拟的表，它是由一个或多个关系表的行和列组成的。视图并不在数据库中以真实的数据形式存在，但它包含了与真实表相同的数据。

7. 总结

C# 与 Oracle 数据库的结合可以为应用程序提供强大的数据处理和管理能力。通过连接 Oracle 数据库、执行 SQL 查询、插入和更新数据、事务处理等操作，我们可以完成各种应用场景下的数据操作。同时，通过使用 Oracle 数据库的高级功能，如存储过程、触发器、索引、视图等，可以进一步提高数据处理效率和性能。