NET中使用OracleBulkCopy快速入库百万级数据

在 .NET 中使用 OracleBulkCopy 进行大批量数据导入时，许多开发者会遇到各种隐藏问题。首先，构造函数必须传入一个已打开的 OracleConnection 对象，它不接受连接字符串，也不会自动打开连接。如果直接传入字符串或未打开的连接，会抛出 InvalidOperationException，提示 "Connection property has not been initialized or is null"。正确做法是先调用 conn.Open()，再传递给构造函数，仅一行代码之差。

using var conn = new OracleConnection(connectionString);
conn.Open(); // 这一步不能省
using var bulk = new OracleBulkCopy(conn); //  这才是正确姿势

此外，连接在整个 WriteToServer 执行期间必须保持打开状态，不能中途关闭或被其他操作复用。如果使用连接池，连接字符串中不要设置 Pooling=false，否则性能会大幅下降。同时，OracleBulkCopy 实例不是线程安全的，必须单线程使用，不能跨线程复用。

列映射必须显式指定

许多人误以为 OracleBulkCopy 会自动按列名匹配，但默认行为是按列序号一一对应（source[0] → target[0]）。当数据来自 DataTable 且列名与目标表字段名不一致，或顺序不对时，会导致静默写错字段或抛出 ORA-01722: invalid number 异常。应使用 ColumnMappings.Add() 手动绑定：

bulk.DestinationTableName = "T_LOG";
bulk.ColumnMappings.Add("LogId", "LOG_ID");
bulk.ColumnMappings.Add("Msg", "MSG_CONTENT");
bulk.ColumnMappings.Add("CreateTime", "CREATE_TIME");

• 左边是源列名（取自 DataTable.Columns[i].ColumnName），右边是目标表字段名，注意大小写敏感——如果建表时使用了双引号，大小写必须一致。
• 如果源数据来自 IDataReader，列名取 GetSchemaTable() 中的 ColumnName，而非 SQL 别名。
• 漏映射、重复映射或映射不存在的列，会在 WriteToServer() 时立即抛出异常，不会静默跳过——Oracle 的异常信息相对直接，便于排查。

批量提交大小设为 5000–10000

BatchSize 默认值为 0，表示一次性提交所有行。百万级数据量容易导致 ORA-04030: out of process memory（Oracle 进程内存耗尽）或 .NET 的 OutOfMemoryException。建议手动设置合理的批次大小：

bulk.BatchSize = 8000;
bulk.WriteToServer(dataTable);

• 实测区间：5000~10000 较为稳定。低于 1000 时，事务提交过于频繁，开销占比增大；高于 20000 容易挤爆 PGA 或使 .NET GC 压力陡增。
• BatchSize 不影响单次调用的总行数上限，只控制内部分批提交的粒度。例如，一次传入 100 万行，会按 8000 行一批分批提交，但整批数据仍在同一个事务中。
• 如果目标表有大量索引或触发器，建议在导入前禁用索引（ALTER INDEX ... UNUSABLE），导完后再重建，可显著提升写入速度。

字段类型必须严格兼容

OracleBulkCopy 不进行运行时类型转换，这与许多开发者的直觉相反。常见问题包括：

• 源 DateTime 写入 DATE 字段没问题，但写入 TIMESTAMP(6) 可能丢失纳秒精度，写入 CHAR(10) 会报 ORA-00932（数据类型不一致）。
• 源 int 写入 NUMBER(5) 正常，但写入 NUMBER(3) 一旦超限（如 1000 无法写入三位数），会抛出 ORA-01438，且错误信息不指明具体行号——这是最棘手的地方。
• NULL 值写入 NOT NULL 字段会直接失败，不会用默认值填补。

因此，上线前务必用小批量数据做预演，包含边界值、NULL、超长字符串，对所有字段类型进行测试。生产环境建议配合 WriteToServerAsync() 和 try/catch，捕获 OracleException 后记录失败批次的起始行号，便于排查。

实际上，让 OracleBulkCopy 跑通并不难，但要使百万行数据的每一列、每一行都恰好落在 Oracle 类型系统的“安全区”内，需要提前对源数据进行清洗，而不是依赖 BulkCopy 自动兜底——它并不具备这种智能。