oraclebulkcopy是oracle官方驱动(≥19.10)提供的高速批量插入方案,基于direct path api绕过sql解析与日志生成;要求目标表已存在、禁用触发器与约束、显式列映射、合理设置batchsize(10000–50000),并严格处理null和date精度问题。

用 OracleBulkCopy 实现高速批量插入
Oracle 官方驱动(Oracle.ManagedDataAccess)从 19.10 版本起正式支持 OracleBulkCopy,这是目前 C# 中写入 Oracle 最快的方式,原理类似 SQL Server 的 SqlBulkCopy,绕过常规 INSERT 语句解析与日志生成,直接走 Oracle 的 Direct Path API。
注意:它要求目标表必须已存在,不支持自动建表;且不能触发 INSERT 触发器,也不能执行 BEFORE/AFTER ROW 触发逻辑。
- 必须使用
OracleConnection(非OracleDataSource或连接字符串别名) - 源数据建议用
DataTable或IDataReader,避免用IEnumerable<t></t>直接传入——后者会触发反射+逐行转换,严重拖慢速度 -
OracleBulkCopy.BatchSize建议设为 10000–50000,太小增加网络往返,太大易 OOM 或事务回滚代价高 - 目标列名必须与源数据列名或
ColumnMappings完全匹配,大小写敏感(Oracle 默认大写,DataTable列名若为小写需显式映射)
处理 NULL 和 DATE 类型的常见翻车点
Oracle 对 DATE 和 NULL 的批量写入非常敏感:如果 DataTable 中某列为 DateTime?(可空),但实际值是 null,而目标表该字段定义为 NOT NULL,OracleBulkCopy.WriteToServer 会直接抛出 Oracle.ManagedDataAccess.Client.OracleException: ORA-01400: cannot insert NULL into (...),而不是跳过或报具体哪一行。
更隐蔽的是 DateTime 精度问题:Oracle DATE 类型只存年月日时分秒(无毫秒),但 .NET 的 DateTime 默认带毫秒。如果源数据含毫秒值(如 DateTime.Now),OracleBulkCopy 会尝试写入,但 Oracle 可能截断或报 ORA-01830: date format picture ends before converting entire input string(尤其在 NLS_DATE_FORMAT 不匹配时)。
- 写入前统一清理:对可空列,确保
DataTable.Columns[colName].AllowDBNull = true - 对
DATE列,提前用dt.AddTicks(-dt.Ticks % TimeSpan.TicksPerSecond)截掉毫秒,或改用OracleDbType.TimeStamp并配OracleBulkCopy.ColumnMappings - 不要依赖连接字符串里的
DateTime=1参数——它只影响普通命令,对 bulk copy 无效
替代方案:当 OracleBulkCopy 不可用时用 FORALL + 参数化批量
如果用的是旧版驱动(FORALL 方式。本质是拼一个带集合参数的大 SQL,由 Oracle 服务端一次性执行。
关键不是“怎么写 SQL”,而是怎么把 C# 数据高效转成 Oracle 能认的集合类型。最稳路径是用 OracleParameter 传入 Array,配合 OracleDbType.Int32 / OracleDbType.Varchar2 等数组类型。
- 单次最多传约 1000 行(受 Oracle
arraysize和内存限制),再多就拆批 - SQL 模板必须用命名参数(如
:ids),不能用位置占位符(?)——Oracle 数组绑定只认命名 - 示例语句:
FORALL i IN 1 .. :ids.COUNT INSERT INTO t (id, name) VALUES (:ids(i), :names(i)) - 对应 C#:
new OracleParameter("ids", OracleDbType.Int32, idsArray, ParameterDirection.Input) { ArrayBindSize = new int[idsArray.Length] }——ArrayBindSize必须设,否则 varchar 类型可能截断
连接和事务控制的实际取舍
批量写入不是“连上就开干”。Oracle 的事务行为和锁机制会让错误配置导致长时间阻塞或归档日志暴增。
默认情况下 OracleBulkCopy 不开启事务,每批是独立提交;而手写 FORALL 必须显式套在 OracleTransaction 里。但大事务(比如 100 万行包一个事务)极易失败回滚耗时极长,且可能触发 UNDO 表空间不足(ORA-30036)。
- 推荐分批 commit:每 5000–10000 行
transaction.Commit()一次,同时调用connection.BeginTransaction(IsolationLevel.ReadCommitted) - 禁用自动提交:
connection.AutoCommit = false,否则OracleBulkCopy会无视你手动开的事务 - 如果表上有索引,考虑先
ALTER INDEX ... UNUSABLE,写完再REBUILD——比边写边维护索引快 3–5 倍
真正卡住人的往往不是语法,而是 Oracle 实例侧的资源配额(比如 LOG_BUFFER 大小、UNDO_RETENTION 设置)和网络延迟抖动。压测时务必用真实数据量+生产级 DB 配置跑,本地 Oracle XE 很难复现并发锁表现。











