我正在努力导入.CSV文件,用户可以在列和名称上进行配置。
在我这边,我将动态处理/导入数据到数据库,但我需要将列与其标题名称匹配。
另外,这是作为服务运行所以我需要异步方法。
它看起来像CsvDataReader(https://joshclose.github.io/CsvHelper/examples/data-table)可能有点我正在寻找但我没有看到异步方法。
例如,我可能有一个如下所示的CSV:
id,first,last
101,john,doe
..
我需要在代码方面做的是:( prototyped /“ideal”)
foreach( var item in csvRead)
{
column = csvRead.columnName;
value = csvRead.value;
DBWrite(column, value);
}
这可能与CsvHelper有关吗? (最重要的是,异步是否存在必要的类?)
您可以使用动态对象。
public async Task WriteRecords()
{
using (MemoryStream stream = new MemoryStream())
using (StreamWriter writer = new StreamWriter(stream))
using (StreamReader reader = new StreamReader(stream))
using (CsvReader csv = new CsvReader(reader))
{
writer.WriteLine("id,first,last");
writer.WriteLine("101,john,doe");
writer.Flush();
stream.Position = 0;
await csv.ReadAsync();
csv.ReadHeader();
while (await csv.ReadAsync())
{
var record = csv.GetRecord<dynamic>();
foreach (var item in (IDictionary<string, object>)record)
{
DBWrite(item.Key, item.Value);
}
}
}
}
public void DBWrite(string column, object value)
{
Console.WriteLine($"Storing {column}: {value}");
}