数据导入
使用场景
- 从非SQL数据库(例如:influxdb)查询到一个数据结果集
- 从第三方来源获取一些文本数据,例如:xml, json, csv
- 从其它各种数据源清洗到一些结构数据表
- 需要将以上数据结果导入 MySQL
实现过程
- 将各种来源先转换成 DataTable
- 再调用 ClownFish 提供的【数据导入】功能写入 MySQL
数据导入API示例
using DbContext dbContext = DbContext.Create("mysql");
DataImportArgs args = new DataImportArgs {
DestDbContext = dbContext, // 目标表的数据连接对象
DestTableName = "TestImport", // 目标表名称
Data = datatable, // 将要导入的数据
AllowAutoIncrement = true, // 是否允许自增列的主键
WithTranscation = false // 是否启用事务
};
await DataImport.ExecuteAsync(args);