Entity Framework v8, on SaveChangeAsyc() intserts record twice

Hello, Thank you for your response, I have the ID on Auto increment. and the values is not being passed its a default: 0 , I have tried, async and Sync methods but the issue persists. DBrecords:energy_data=# select * from "Devices";

Id | Pod | Direction

----+-----------------------------------+-----------

1 | AT009000000000000000056789800E | 1

2 | AT009000000000000000056789800E | 1

same Pod: AT009000000000000000056789800E added twice again

(2 rows)

Hi, @Reema George Dass.

Could you provide minimal reproducible code?

Method Call:

public async Task InsertionToDatabase()
{ 
if (device == null)
{
    device = _mapper.Map<Device>(deviceDto);
    await _datarepo.AddAsync(device); 
    device = await _datarepo.GetDeviceByPoDAsync(deviceDto.Pod);
}
else
{
    // Device already exists, skip adding and log
    _logger.LogInformation($"Device with PoD {deviceDto.Pod} already exists, skipping insert.");
}
}

Mapper:

public class MappingProfile : Profile
    {
        public MappingProfile()
        {
            CreateMap<DeviceDTO, Device>()
                .ForPath(dest => dest.Id, opt => opt.Ignore()); // tried with n without this line
            CreateMap<DeviceDataDTO, DeviceData>() // second table( not in question for the error atm)
            .ForMember(dest => dest.TimestampUtc, opt => opt.MapFrom(src =>
                DateTime.SpecifyKind(src.TimestampUtc, DateTimeKind.Utc))
            );
        }
    }
}

Models:

[Table("Devices")]
public class Device
{
    [DatabaseGenerated(DatabaseGeneratedOption.Identity), Key, Required]
    public long Id { get; set; } // auto incremented on insertion
    [MaxLength(33)]
    public required string Pod { get; set; }
    [Required]
    public EnergyDirection Direction { get; set; }
}

DB_insertion:

  public async Task AddAsync<T>(T entity) where T : class
   {
       await _dbContext.Set<T>().AddAsync(entity); 
       await _dbContext.SaveChangesAsync();
   }

On debug: I see two records populated at SaveChanges()

Please refer the previous comment.

Things I have tried:

1. To use specific model type addition and not Set<T>().
2. Sync method with SaveChanges()
3. few more that dint make differences from stack overflow.

I was following this: https://github.com/PomeloFoundation/Pomelo.EntityFrameworkCore.MySql/issues/1621

This thread talks about the same issue in older frame works which is not consistent.

The job that is triggering the first method:

// Add Logging
builder.Logging.ClearProviders();
builder.Logging.AddConsole();
// Quartz services
builder.Services.AddQuartz(q =>
{
    // Define the job
    var jobKey = new JobKey("DatabaseInsertionScheduler");
    q.AddJob<DatabaseInsertionScheduler>(opts => opts.WithIdentity(jobKey));
    // Define a trigger using a Cron expression (every minute)
    //    q.AddTrigger(opts => opts
    //        .ForJob(jobKey)
    //        .WithIdentity("DatabaseInsertionScheduler")
    //        .WithCronSchedule("0 * * * * ?")); // Runs every minute
    q.AddTrigger(opts => opts
            .ForJob(jobKey)
            .WithIdentity("DatabaseInsertionScheduler")
            .StartNow()  // Trigger immediately when the app starts
            .WithSimpleSchedule(x => x.WithRepeatCount(0)) // No repeat, run once
        );
});
// Register the Quartz hosted service
builder.Services.AddQuartzHostedService(options => options.WaitForJobsToComplete = true);

The trigger:

// Trigger the job manually after the app starts For testingusing (var scope = app.Services.CreateScope()){    var scheduler = await scope.ServiceProvider.GetRequiredService<ISchedulerFactory>().GetScheduler();    var jobKey = new JobKey("DatabaseInsertionScheduler");    if (await scheduler.CheckExists(jobKey))    {        Console.WriteLine("Manually triggering DatabaseInsertionScheduler job...");        await scheduler.TriggerJob(jobKey);        Console.WriteLine("Job triggered successfully!");    }    else    {        Console.WriteLine("Job not found!");    }}