EF Core - ошибка с дублированным ключом при добавлении данных с уникальным индексом - PullRequest
1 голос
/ 21 марта 2019

Я пытаюсь добавить данные в базу данных с помощью EF Core, но не могу устранить ошибку дублированного ключа: Cannot insert duplicate key row in object 'dbo.Stocks' with unique index 'IX_Stocks_Name'. The duplicate key value is (stock1).

У меня есть сущность Stock, которая имеет отношение один ко многим с Transaction - один Stock может быть связан со многими Transaction с.

Проблема не возникает, только если в базе данных нет Stock с данным идентификатором - в этом случае я могу добавить много Transaction s с тем же StockID, и это работает:

using(var context = dbContextFactory.CreateDbContext(new string[0]))
     {
        List<Transaction> list = new List<Transaction>();
        //If there's no Stock with ID "stock1" in the database the code works.
        //Executing the code for the second time results in error, however, if I changed stock1 to stock2 it would work 
        var stock1 = new Stock("stock1");
        list.AddRange(new Transaction[]
        {
        //I can add two exactly the same `Transaction`s and it's ok when executed on a fresh database
        new Transaction(stock1, DateTime.Now, 1M, 5),
        new Transaction(stock1, DateTime.Now, 1M, 5),
        });
        context.Transactions.AddRange(list);
        context.SaveChanges();
     }

Ниже я добавил определения классов с их IEntityTypeConfiguration с.

Заранее благодарим за любые подсказки.

Transaction класс:

public class Transaction
    {
        public Stock RelatedStock { get; set; }
        public DateTime TransactionTime { get; set; }
        public Decimal Price { get; set; }
        public int Volume { get; set; }
        public Transaction() { }
    }

TransactionConfiguration класс:

public class TransactionConfiguration : IEntityTypeConfiguration<Transaction>
    {
        public void Configure(EntityTypeBuilder<Transaction> builder)
        {
            builder
                .ToTable("Transactions");

            builder
                .Property<int>("TransactionID")
                .HasColumnType("int")
                .ValueGeneratedOnAdd()
                .HasAnnotation("Key", 0);

            builder
                .Property(transaction => transaction.Price)
                .HasColumnName("Price")
                .IsRequired();

            builder
                .Property(transaction => transaction.TransactionTime)
                .HasColumnName("Time")
                .IsRequired();

            builder
                .Property(transaction => transaction.Volume)
                .HasColumnName("Volume")
                .IsRequired();

            builder
                .HasIndex("RelatedStockStockID", nameof(Transaction.TransactionTime))
                .IsUnique();
        }
    }

Stock класс:

public class Stock
  {
     public string Name { get; set; }
     public ICollection<Transaction> Transactions { get; set; }
     public Stock() { }
  }

StockConfiguration класс:

public class StockConfiguration : IEntityTypeConfiguration<Stock>
    {
        public void Configure(EntityTypeBuilder<Stock> builder)
        {
            builder
                .ToTable("Stocks");

            builder
                .Property<int>("StockID")
                .HasColumnType("int")
                .ValueGeneratedOnAdd()
                .HasAnnotation("Key", 0);

            builder
                .Property(stock => stock.Name)
                .HasColumnName("Name")
                .HasMaxLength(25)
                .IsRequired();

            builder
                .HasMany(stock => stock.Transactions)
                .WithOne(transaction => transaction.RelatedStock)
                .IsRequired();

            builder
                .HasIndex(stock => stock.Name)
                .IsUnique();
        }
    }

Ответы [ 3 ]

1 голос
/ 21 марта 2019

В таблице dbo.Stocks есть уникальный индекс IX_Stocks_Name. Вы нарушаете этот индекс.

Ваша проблема в этой строке:

var stock1 = new Stock("stock1");

Вы создаете "stock1" снова и снова. Вместо этого вы должны сначала извлечь (или сохранить) сущность Stock для «stock1» и использовать ее, если она уже существует. Если его не существует, его можно создать безопасно.

Короче говоря, код выполняет INSERT в dbo.Stocks с существующим Name.

0 голосов
/ 21 марта 2019

Благодаря предложениям @ Zer0 и @Steve Py я нашел следующее решение:

void Insert(IEnumerable<Transaction> data)
        {
            using(var context = dbContextFactory.CreateDbContext(new string[0]))
            {
                List<Stock> stocks = data.Select(s => s.RelatedStock).Distinct(new StockComparer()).ToList();
                context.AddRange(stocks);
                context.SaveChanges();
                stocks = context.Stocks.ToList();

                List<Transaction> newList = new List<Transaction>(data.Count());

                foreach (var t in data)
                {
                        Stock relatedStock = stocks.Where(s => s.Name == t.RelatedStock.Name).First();
                        t.RelatedStock = relatedStock;
                        newList.Add(t);
                }

                context.Transactions.AddRange(newList);
                context.SaveChanges();
            }
        }
0 голосов
/ 21 марта 2019

Вам необходимо проверить, есть ли акции, уже известные для желаемого идентификатора. ради вашего примера:

var stock1 = context.Stocks.SingleOrDefault(x => x.StockId == "stock1") ?? new Stock("stock1");

Это свяжет существующую акцию, если она уже есть в базе данных, или свяжет новую, если ее нет.

...