数据导入

使用场景

  • 从非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);