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

使用 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 的错误信息相对直接，至少不会让你半夜排查 bug 到崩溃。

批量提交大小设为 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 自动兜底——它并没有那么智能。