将 ICollection 批量插入到 Oracle 表中

Question

我正在根据来自 Nswag 工作室的规范编写 API 客户端。我可以使用提供的 client.PlansAsync(apikey).GetAwaiter().GetResult() 检索该数据，但我正在努力将返回的 ICollection 转换为能够批量插入 Oracle 数据库表的数据。

我试图创建一个DataTable，但在转换为数据表的过程中，抛出了一个异常。我怀疑它与集合中的可为空类型有关。

我的猜测是我应该尝试使用 Entity Framework 进行插入，但对于这个特定的客户端来说，添加所有额外的 EF Core 内容似乎是多余的。

我觉得 Oracle 批量复制方法非常适合我的意图，但我一直遇到上面列出的问题。

任何帮助将不胜感激。

TIA

编辑：这是有问题的代码。

//first in the calling class
ICollection<Plans> plansFromApi = client_.PlansAsync(apiKey).GetAwaiter().GetResult();

ListToDatTable listToDt = new();
List<Plans> ps = plansFromApi.ToList();
DataTable dt = listToDt.ToDataTable<Plans>(ps);


//second the List to Datatable class

public class ListToDataTable
{
    public DataTable ToDataTable<T>(List<T> items)
    {
        DataTable dataTable = new(typeof(T).Name);
        PropertyInfo[] Props = typeof(T).GetProperties(BindingFlags.Public | BindingFlags.Instance);
        foreach(T item in items)
        {
            var values = new object[Props.Length];
            for(int i = 0; i < Props.Length; i++)
            {
                values[i] = Props[i].GetValue(item);
            }
            //line where the exception is thrown
            //System.ArgumentException: 'Input array is longer than the number of columns in this table.'
            dataTable.Rows.Add(values);
         }
     }
}

编辑 2： 这是来自 Nswag 工作室的内容。这只是我需要检索的 15 个数据集之一。这不是我目前正在测试的那个，因为它有 25 个属性，所以为简洁起见，我将包含一个较小的属性。最后它们都将是相同的，因为它们都将以完全相同的方式进行处理，是的，我也使用此数据集进行了测试，并收到了相同的异常。

[System.CodeDom.Compiler.GeneratedCode("NJsonSchema", "10.5.2.0 (Newtonsoft.Json v12.0.0.0)")]
    public partial class ContactGroupedManufacturer
    {
        [Newtonsoft.Json.JsonProperty("lastContacted", Required = Newtonsoft.Json.Required.Default, NullValueHandling = Newtonsoft.Json.NullValueHandling.Ignore)]
        public System.DateTimeOffset? LastContacted { get; set; }
    
        [Newtonsoft.Json.JsonProperty("vendorContactId", Required = Newtonsoft.Json.Required.DisallowNull, NullValueHandling = Newtonsoft.Json.NullValueHandling.Ignore)]
        public int VendorContactId { get; set; }
    
        [Newtonsoft.Json.JsonProperty("ManufacturerId", Required = Newtonsoft.Json.Required.DisallowNull, NullValueHandling = Newtonsoft.Json.NullValueHandling.Ignore)]
        public int ManufacturerId { get; set; }
    
        [Newtonsoft.Json.JsonProperty("website", Required = Newtonsoft.Json.Required.Default, NullValueHandling = Newtonsoft.Json.NullValueHandling.Ignore)]
        public string Website { get; set; }
    
    
    }

这里有几行数据：

lastContacted	vendorContactId	manufacturerId	website
6575	1848
6599	2693
6604	8878	06/08/2018
6692	6879
6930	4040		some url

---

2021 年 11 月 10 日更新：我发现了一个名为 MoreLinq 的 NuGet 包，其中包含一个扩展方法，用于处理到 DataTable 的转换。

ICollection<ActionPlans> actionPlans = client.ActionPlansAsync(apiKey).GetAwaiter().GetResult();
_logger.LogInformation(${actionPlans.Count} APs returned");

DataTable actionPlansDt = actionPlans.ToDataTable();

Answer 1

您可以将 IEnumerable 包装在 IDataReader 中以传递给 BulkCopy 方法。参见例如： ObjectDataReader

一旦您拥有 IDataReader，请将其传递给 OracleBulkCopy.WriteToServer(IDataReader) 请参阅 OracleBulkCopy。

Answer 2

您可能对 DataTable 中的列数有疑问。 试试这个代码：

public class ListToDataTable
{
    public DataTable ToDataTable<T>(List<T> items)
    {
        DataTable dataTable = new DataTable();
        PropertyInfo[] Props = typeof(T).GetProperties(BindingFlags.Public | BindingFlags.Instance);
        bool columnsAlreadyCreated=false;
        foreach(T item in items)
        {
            if (columnsAlreadyCreated==false)
            {
              for(int i = 0; i < Props.Length; i++)
              {
         dataTable.Columns.Add(Props[i].Name,Nullable.GetUnderlyingType(
         Props[i].PropertyType) ?? Props[i].PropertyType);
              }
              columnsAlreadyCreated=true;
            }
            var values = new object[Props.Length];
            for(int i = 0; i < Props.Length; i++)
            {
                values[i] = Props[i].GetValue(item);
            }
            //line where the exception is thrown
            //System.ArgumentException: 'Input array is longer than the number of columns in this table.'
            dataTable.Rows.Add(values);
         }
     }
}