数据导入

使用场景

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