Отказ от ответственности: я все еще новичок в разработке микросервисных архитектур.
После того, как пользователь получит токен доступа от внешнего поставщика удостоверений, я хочу, чтобы ему был разрешен доступ к конечной точке /questions для создания вопроса. Только пользователи с действительным JWT должны иметь возможность создавать вопросы.
Конечная точка извлечет значение sub из токена и будет использовать его в качестве UserSnapshotId в таблице Вопрос.
Однако аутентифицированный пользователь может еще не существовать в таблице UserSnapshot из-за задержек в обработке событий между службой идентификации и вопросом. service.
Я мог бы проверить, существует ли пользователь в таблице UserSnapshot, прежде чем создавать Вопрос, но я думаю, что такой подход неэффективен.
Короче говоря, я хочу, чтобы конечная точка могла создать Вопрос, даже если UserSnapshotId еще не существует в таблице UserSnapshot.
Для других конечных точек (таких как GET) я хочу вернуть все вопросы вместе со связанными с ними данными UserSnapshot, поэтому сущность Вопрос, вероятно, должна иметь свойство навигации, допускающее значение NULL, типа UserSnapshot, позволяющее мне использовать Include() в запросах.
Мой вопрос: возможно ли иметь UserSnapshot свойство навигации без применения ограничения внешнего ключа?
using Microsoft.EntityFrameworkCore;
var builder = WebApplication.CreateBuilder(args);
builder.Services.AddDbContext(o => o.UseSqlite("Data Source=App.db"));
var app = builder.Build();
app.MapPost("/questions", async (AppDbContext db) =>
{
var sub = 1000;// pretend we got this from JWT
// ==============================================================================================
// I want to avoid retrieving UserSnapshot every time user posts a question because it is less efficient.
if (await db.UserSnapshots.FindAsync(sub) is null)
{
db.UserSnapshots.Add(new UserSnapshot { Id = sub });
await db.SaveChangesAsync();
}
// So I want to let any authenticated user post question without retrieving UserSnapshot first,
// and let background job create UserSnapshot if it does not exist.
// Unfortunately foreign key constraint does not allow us to create question with a UserSnapshot that does not exist.
// SO WHAT IS THE BEST PRACTICE TO HANDLE THIS SCENARIO?
// ==============================================================================================
db.Questions.Add(new Question { UserSnapshotId = sub });
await db.SaveChangesAsync();
return TypedResults.Ok("Created successfully!");
});
app.MapGet("/", async (AppDbContext db) => TypedResults.Ok(await db.Questions.Include(q => q.UserSnapshot).AsNoTracking().ToArrayAsync()));
await app.SeedAsync();
await app.RunAsync();
public static class DbContextExtensions
{
public static async Task SeedAsync(this WebApplication app)
{
await using var scope = app.Services.CreateAsyncScope();
var db = scope.ServiceProvider.GetRequiredService();
await db.Database.EnsureDeletedAsync();
await db.Database.EnsureCreatedAsync();
var admin = new UserSnapshot { };
db.UserSnapshots.Add(admin);
await db.SaveChangesAsync();
db.Questions.Add(new Question { UserSnapshotId = admin.Id });
await db.SaveChangesAsync();
}
}
sealed class UserSnapshot
{
public int Id { get; set; }
}
sealed class Question
{
public int Id { get; set; }
public int UserSnapshotId { get; set; }
public UserSnapshot? UserSnapshot { get; set; }
}
sealed class AppDbContext(DbContextOptions o) : DbContext(o)
{
public DbSet UserSnapshots => Set();
public DbSet Questions => Set();
protected override void OnModelCreating(ModelBuilder modelBuilder)
{
// Unfortunately it causes Include() to fail.
modelBuilder.Entity().Ignore(q => q.UserSnapshot);
}
}
Изменить
Кажется, это невозможно, поэтому я удаляю UserSnapshot из вопроса и использую GroupJoin и SelectMany вместо Include() следующим образом:
app.MapGet("/", async (AppDbContext db) =>
{
var result = await db.Questions
.AsNoTracking()
.GroupJoin(
db.UserSnapshots.AsNoTracking(),
q => q.UserSnapshotId,
u => u.Id,
(q, userGroup) => new { q, userGroup }
)
.SelectMany(
x => x.userGroup.DefaultIfEmpty(),
(x, user) => new
{
x.q.Id,
// additional properties can go here
// UserDisplayName = user == null ? "Backfilled User" : user.DisplayName
}
)
.ToListAsync();
return TypedResults.Ok(result);
});
Подробнее здесь: https://stackoverflow.com/questions/797 ... in-ef-core
