从上传的 Web API CSV 和实体框架将行保存到数据库

Question

我有一个上传到 Web API 路由的 CSV 文件。我已经能够通过字节数组将 CSV 放入内存，这就是我被卡住的地方。我想获取 CSV 的每一行，添加三个从上传表单与文件一起发布的附加字段，并将每个带有附加字段的 CSV 行插入到 SQL 服务器表中。如何获取字节数组、转换行并插入数据？

这是我使用 ng-file-upload 的 AngularJS。

$scope.upload = function (file) {
Upload.upload({
    url: 'api/UploadProfile',
    data: {
        file: file,
        'ProfileName': $scope.ProfileName,
        'SubmittedBy': $scope.SubmittedBy,
        'InsertDate': $scope.InsertDate
    }
})}

这是我的 Web API 控制器

public class ProfileUploadController : ApiController
{
    private BIMarketOrderEntities db = new BIMarketOrderEntities();

    [HttpPost, Route("api/UploadProfile")]
    public async Task<IHttpActionResult> Upload()
    {
        if (!Request.Content.IsMimeMultipartContent())
            throw new HttpResponseException(HttpStatusCode.UnsupportedMediaType);

        var provider = new MultipartMemoryStreamProvider();
        await Request.Content.ReadAsMultipartAsync(provider);
        foreach (var file in provider.Contents)
        {
            var filename = file.Headers.ContentDisposition.FileName.Trim('\"');
            var buffer = await file.ReadAsByteArrayAsync();

            // How do I get 'buffer' to my database while adding the additional fields?
        }

        return Ok();
    }
}

Answer 1

这就是我最终为这个特定实例所做的事情。如果有更有效的方法，我绝对愿意接受。

[HttpPost, Route("api/UploadProfile")]
public async Task<IHttpActionResult> Upload()
{
    //Get attachment and form data
    if (!Request.Content.IsMimeMultipartContent())
        throw new HttpResponseException(HttpStatusCode.UnsupportedMediaType);

    var provider = new MultipartMemoryStreamProvider();
    await Request.Content.ReadAsMultipartAsync(provider);

    //File and 3 form parameters will be saved to this array
    string[] results = new string[4];

    //Read all data into array
    int i = 0;
    foreach (var parameter in provider.Contents)
    {
        var bytes = await parameter.ReadAsByteArrayAsync();
        results[i++] = Encoding.Default.GetString(bytes);
    }

    //Split lines of CSV into array
    string[] stringArray = results[0].Split(new[] { "\r\n", "\r", "\n" }, StringSplitOptions.None);

    //Check if header row matches expected CSV layout
    if (stringArray[0] != "CSVField1,CSVField2,CSVField3,CSVField4,CSVField5,CSVField6")
    {
        //Failure
        var message = "File does not contain necessary header fields.";
        return Content(HttpStatusCode.BadRequest, message);
    }

    //Remove header row
    stringArray = stringArray.Skip(1).ToArray();

    //Create db object store all Insert data
    var profileObjs = db.Set<T_ProfileStaging>();
    foreach (var s in stringArray)
    {

        //Save each column in array
        string[] columns = s.Split(',');

        //Add form data to individial records
        T_ProfileStaging profileObj = new T_ProfileStaging();
        profileObj.Field1 = columns[0];
        profileObj.Field2 = results[1];
        profileObj.Field3 = columns[1];
        profileObj.Field4 = columns[2];
        profileObj.Field5 = columns[3];
        profileObj.Field6 = columns[4];
        profileObj.Field7 = results[2];
        profileObj.Field8 = columns[5];
        profileObj.Field9 = results[3];

        profileObjs.Add(profileObj);
    }

    //Save all objects to database
    db.SaveChanges();

    //Success
    return Ok();
}