Oracle：EFCore使用OracleBulkCopy实现批量导入数据

        public int BulkInsert<T>(List<T> entities, string tableName = null)
        {
            if (String.IsNullOrEmpty(tableName))
            {
                var tableAttribute = (TableAttribute)typeof(T).GetCustomAttributes(typeof(TableAttribute), false).First();
                tableName = $"\"{tableAttribute.Name}\"";
            }

            using (OracleBulkCopy bulkCopy = new OracleBulkCopy(ConnectionString))
            {
                bulkCopy.BulkCopyTimeout = 0;
                bulkCopy.BatchSize = entities.Count;
                bulkCopy.DestinationTableName = tableName;
                bulkCopy.BulkCopyOptions = OracleBulkCopyOptions.UseInternalTransaction | OracleBulkCopyOptions.Default;

                var table = DataTableHelper.ToDataTable<T>(entities);
                table.TableName = tableName;

                //重要：记录设置为新增状态
                foreach (DataRow r in table.Rows) r.SetAdded();

                bulkCopy.WriteToServer(table);

                return table.Rows.Count;
            }
        }

            IDatabase db = DatabaseFactory.GetDatabase(GetDatabaseType(), GetConfig("Normal").ConnectionString);
            var watch = Stopwatch.StartNew();

            var list = new List<_Demo_Customer>();
            for (int i = 1; i <= 1000; i++)
            {
                list.Add(NewCustomer());
            }

            //调用IDatabase.BulkInsert方法
            int x = db.BulkInsert<_Demo_Customer>(list);

            watch.Stop();

            int count = db.GetQueryable<_Demo_Customer>().Count();
            var msg = $"成功:{x},总记录数:{count},用时:{watch.ElapsedMilliseconds}(ms)";

            ShowResult("测试BulkInsert方法 -> 结果:" + msg);