使用实体框架和PostgreSQL的SaveChanges中的错误

问题描述

使用以下代码，我尝试使用实体框架将新对象插入PostgreSQL数据库：

坎普班

public class campo
{
    public int id { get; set; }
    public int id_extrator { get; set; }
    public string nome { get; set; }
    public bool campo_selecionado { get; set; }

}

调用事件：

private void btnSalvarDetalhesExtrator_Click(object sender,EventArgs e)
{
    try
    {
        _campoDal = new CampoDal();
        List<campo> listaCampos = new List<campo>();
        campo dadosCampo;
        for (int a = 0; a < gvCamposExtrator.RowCount; a++)
        {
            dadosCampo = new campo();
            dadosCampo.id_extrator = _idExtrator;
            dadosCampo.nome = (string)gvCamposExtrator.Rows[a].Cells["Nome"].Value;
            dadosCampo.campo_selecionado = (bool)gvCamposExtrator.Rows[a].Cells["Campo_Selecionado"].Value;
            _campoDal.AdicionarCampo(dadosCampo);
        }
    }
}

添加到数据库

public campo AdicionarCampo(campo dadosCampo)
{
    try
    {
        _dbContext.Campos.Add(new campo
            {
                nome = dadosCampo.nome,id_extrator = dadosCampo.id_extrator,campo_selecionado = dadosCampo.campo_selecionado
            }
        );
        _dbContext.SaveChanges();
        return dadosCampo;
    }
    catch (Exception ex)
    {
        throw;
    }
}

但是，当我尝试执行此操作时，会显示以下错误，类似于SQLTransaction的ZombieCheck。

Error ZombieCheck Npgsql

堆栈跟踪器：

   em Npgsql.NpgsqlTransaction.CheckReady()
   em Npgsql.NpgsqlTransaction.get_DbConnection()
   em System.Data.Common.DbTransaction.get_Connection()
   em System.Data.Entity.Infrastructure.Interception.DbTransactionDispatcher.Dispose(DbTransaction transaction,DbInterceptionContext interceptionContext)
   em System.Data.Entity.Core.EntityClient.EntityTransaction.Dispose(Boolean disposing)
   em System.Data.Common.DbTransaction.Dispose()
   em System.Data.Entity.Core.Objects.ObjectContext.ExecuteInTransaction[T](Func`1 func,IDbExecutionStrategy executionStrategy,Boolean startLocalTransaction,Boolean releaseConnectionOnSuccess)
   em System.Data.Entity.Core.Objects.ObjectContext.SaveChangesToStore(SaveOptions options,Boolean startLocalTransaction)
   em System.Data.Entity.Core.Objects.ObjectContext.<>c__DisplayClass148_0.<SaveChangesInternal>b__0()
   em System.Data.Entity.Infrastructure.DefaultExecutionStrategy.Execute[TResult](Func`1 operation)
   em System.Data.Entity.Core.Objects.ObjectContext.SaveChangesInternal(SaveOptions options,Boolean executeInExistingTransaction)
   em System.Data.Entity.Core.Objects.ObjectContext.SaveChanges(SaveOptions options)
   em System.Data.Entity.Internal.InternalContext.SaveChanges()
   em System.Data.Entity.Internal.LazyInternalContext.SaveChanges()
   em System.Data.Entity.DbContext.SaveChanges()
   em ConectorAditi.DAL.Concrete.CampoDal.AdicionarCampo(campo dadosCampo) na C:\Users\Joao Pedro\source\repos\ConectorAditi\ConectorAditi\DAL\Concrete\CampoDal.cs:linha 29

尝试解决此问题或提供临时解决方案，而不是在catch块中返回引发值，我最初并未在该块中写入任何内容，也没有将其返回给我试图添加的对象，就好像它已经起作用了一样

public campo AdicionarCampo(campo dadosCampo)
{
    try
    {
        _dbContext.Campos.Add(new campo
            {
                nome = dadosCampo.nome,campo_selecionado = dadosCampo.campo_selecionado
            }
        );
        return dadosCampo;
    }
    catch (Exception ex)
    {
        return dadosCampo;
    }
}

在此实现中，数据保存在数据库中，但是在每次循环交互中， SaveChanges保存新对象和已插入的对象，而不是仅插入新实例化对象的数据。

我不知道问题是否在那里，但是下面的代码引用了数据库的上下文类

public class ApplicationDataBase : DbContext
{
    private readonly string schema;
    public DbSet<assunto> Assuntos { get; set; }
    public DbSet<atualizacao_campos_realizada> AtualizacoesCamposRealizadas { get; set; }
    public DbSet<campo> Campos { get; set; }
    public DbSet<carga_realizada> CargaRealizadas { get; set; }
    public DbSet<data_base> DataBases { get; set; }
    public DbSet<extrator> Extratores { get; set; }
    public DbSet<tipo_carga> TiposCargas { get; set; }

    public ApplicationDataBase(string schema) : base("dbConectionString")
    {
        this.schema = schema;
    }
    protected override void OnModelCreating(DbModelBuilder builder)
    {
        builder.Conventions.Remove<PluralizingTableNameConvention>();
        Database.SetInitializer<ApplicationDataBase>(null);
        builder.HasDefaultSchema(this.schema);
        base.OnModelCreating(builder);
    }
}

有人会知道在此实现中我可能出错的地方，以及在使用SaveChanges时如何解决NpgsqlTransaction的“ ZombieCheck”问题或什至是数据重复的问题？我尝试了一些解决方案和实现，但没有一个解决这些问题。

编辑：

作为一个临时解决方案，我在catch块中添加了以下行，该行删除了从上下文跟踪中添加的实体，并通过@Sowmyadhar Gourishetty的注释找到了该解决方案：

        catch (Exception ex)
        {
            _dbContext.Entry(dadosCampo).State = EntityState.Detached;

            return dadosCampo;
         }

但是，我仍然没有找到一种方法来避免在第一张图像中发布“ ZombieCheck”错误，从而防止其进入catch块。如果有人可以提供帮助，我会很感激。

解决方法

我认为您的问题可能是EF不知道您的主键是什么。

尝试将以下属性添加到类id中的属性campo上：

[Key]
public int id { get; set; }

此属性可以在命名空间System.ComponentModel.DataAnnotations中找到。

此外，您无需创建新实体。您可以将要传递的方法添加到方法中。现在无需退货。另外，如果您要重新抛出异常，则捕获异常是没有意义的。唯一有用的时间是，如果您需要添加有关方法内部发生的事情的其他信息。

然后将您的方法简化为：

public void AdicionarCampo(campo dadosCampo)
{
    _dbContext.Campos.Add(dadosCampo);
    _dbContext.SaveChanges();
}

所有这些，您的代码当前将始终添加新记录。如果您希望做的是更新现有对象，而仅添加新对象，那么您将需要先从上下文中检索对象（如果存在），更新它们，然后在上下文中调用SaveChanges方法。

我要提醒的一件事是，您正在保留一个内部上下文实例（_dbContext）。这意味着在使用上下文时，需要确保上下文处于正确的状态。该上下文应作为工作单元使用，因此，只有在您要允许一系列最终将被一起“提交”的操作时，才应以这种方式使它保持活动状态。实际上，如果这不能解决您的问题，则可能是在这些调用之前您可能会对DAL（以及上下文）进行其他操作，这可能会导致问题。

c#c#database entity-framework npgsql

使用实体框架和PostgreSQL的SaveChanges中的错误

问题描述

解决方法

相关问答