当前位置：首页 > news >正文

c#using Oracle.ManagedDataAccess.Client 批量保存数据

news 2025/10/22 8:56:35

在C#中使用Oracle.ManagedDataAccess.Client来批量保存数据是一种高效的方法，尤其是在需要插入大量数据时。Oracle.ManagedDataAccess.Client是Oracle提供的官方.NET数据访问库，它支持ADO.NET接口。以下是一些常用的方法来实现批量插入数据：

方法1：使用`OracleBulkCopy`

OracleBulkCopy是Oracle提供的一个专门用于批量插入数据的类。使用此方法可以显著提高数据插入的性能。

步骤：

添加必要的命名空间引用。
创建OracleConnection对象并打开连接。
创建OracleBulkCopy对象并配置目标表和映射。
调用WriteToServer方法执行批量插入。

示例代码：

using System;
using System.Data;
using Oracle.ManagedDataAccess.Client;

class Program
{
static void Main()
{
string connString = "User Id=yourUsername;Password=yourPassword;Data Source=yourDataSource";
using (OracleConnection conn = new OracleConnection(connString))
{
conn.Open();
using (OracleBulkCopy bulkCopy = new OracleBulkCopy(conn))
{
bulkCopy.DestinationTableName = "your_table_name"; // 设置目标表名
DataTable table = new DataTable();
table.Columns.Add("column1", typeof(string)); // 添加列和类型
table.Columns.Add("column2", typeof(int)); // 根据你的表结构添加列和类型
// 添加数据行
table.Rows.Add("value1", 1);
table.Rows.Add("value2", 2);
// 更多数据行...
bulkCopy.WriteToServer(table); // 执行批量插入
}
}
}
}

方法2：使用`OracleCommand`和`OracleTransaction`进行批量插入

如果不想使用OracleBulkCopy，你也可以通过手动构建SQL语句和事务来批量插入数据。这种方法提供了更高的灵活性，但性能可能不如使用OracleBulkCopy。

示例代码：

using System;
using System.Data;
using Oracle.ManagedDataAccess.Client;

class Program
{
static void Main()
{
string connString = "User Id=yourUsername;Password=yourPassword;Data Source=yourDataSource";
using (OracleConnection conn = new OracleConnection(connString))
{
conn.Open();
OracleCommand cmd = new OracleCommand("INSERT INTO your_table_name (column1, column2) VALUES (:column1, :column2)", conn);
cmd.Parameters.Add("column1", OracleDbType.Varchar2, 50, "column1", ParameterDirection.Input);
cmd.Parameters.Add("column2", OracleDbType.Int32, "column2", ParameterDirection.Input);
cmd.BindByName = true; // 使用参数名绑定参数，而不是位置绑定
using (OracleTransaction trans = conn.BeginTransaction())
{
try
{
cmd.Transaction = trans; // 将命令与事务关联起来
// 批量插入数据，这里以循环插入为例，实际应用中可以根据需要调整逻辑以批量处理数据集。
for (int i = 0; i < 1000; i++) // 假设我们要插入1000条数据
{
cmd.Parameters["column1"].Value = $"value{i}"; // 设置参数值
cmd.Parameters["column2"].Value = i; // 设置参数值
cmd.ExecuteNonQuery(); // 执行插入命令，但不提交事务，等待所有数据插入后一起提交。
}
trans.Commit(); // 提交事务，完成批量插入操作。
}
catch (Exception ex)
{
trans.Rollback(); // 出错时回滚事务。
Console.WriteLine(ex.Message);
}
}
}
}
}