1

Tenho um projeto onde o usuário seleciona um arquivo txt ou csv, e o sistema lê linha a linha passando os campos para uma entidade. Da primeira vez, executava SaveChanges() do contexto do banco a cada linha do arquivo. Mas isso estava demorando muito e depois de 20mil linhas dava erro de timeout.

Após algumas pesquisas resolvi preencher a entidade e adicionar ao contexto e depois do arquivo todo ser lido, salvar o contexto todo de uma vez. mas agora estou recebendo o erro "A transação associada à conexão atual foi concluída, mas não foi descartada. A transação deve ser descartada antes do uso da conexão para executar as instruções SQL."

Tentei usar o package BulkInsert, mas também não consegui.

Alguém sabe uma solução? Segue meu código.

using (TransactionScope scope = new TransactionScope())
{
    ContextoBanco context = null;
    try
    {
        using (context = new ContextoBanco())
        {
            context.Configuration.AutoDetectChangesEnabled = false;

            int count = 0;
            if (extension.ToLower() == ".csv")
            {

                //string filename = Path.GetFileName(UploadedFile.PostedFile.InputStream);
                StreamReader csvreader = new StreamReader(file.InputStream, Encoding.Default);
                var header = csvreader.ReadLine();
                string[] cols = header.Split(';');

                while (!csvreader.EndOfStream)
                {
                    var line = csvreader.ReadLine();
                    var values = line.Split(';');

                     Cadastrar(cols, values, file.FileName, context);
                    }
                }
            }
            else if (extension.ToLower() == ".txt")
            {
                //string filename = Path.GetFileName(UploadedFile.PostedFile.InputStream);
                StreamReader sr = new StreamReader(file.InputStream);
                sr.ReadLine();

                while (!sr.EndOfStream)
                {
                    var line = sr.ReadLine();
                    var values = line.Split(';');

                    Cadastrar(values, file.FileName, context, count);
                }
            }

            context.SaveChanges();

        }
    }
    catch(Exception ex)
    {
        ex.InnerException.ToString();
    }

    scope.Complete();
}

private void Cadastrar(string[] cols, string[] values, string filename, ContextoBanco context, int count)
{

    Entidade evento = new Entidade();
    evento.nome = values[0];
    evento.data = values[1];
    evento.tipo = values[2];
    evento.valor = values[3];

    RepositorioBase<Entidade> rep = new RepositorioBase<Entidade>();
    rep.AddToContext(context, evento);
}

public ContextoBanco AddToContext(ContextoBanco context, TEntidade entity)
{
    context.Set<TEntidade>().Add(entity);

    return context;
}

0

Você deve fazer log-in para responder a esta pergunta.

Pesquise outras perguntas com a tag .