Class ReadDbContext<TContext>

Namespace

Stratara.EventSourcing.EntityFrameworkCore.ReadStore

Assembly

Stratara.EventSourcing.EntityFrameworkCore.dll

Base read-store DbContext that consumer DbContexts derive from. Hosts the projection / read-model tables that the projection workers write into and queries read from.

public class ReadDbContext<TContext> : DbContext, IInfrastructure<IServiceProvider>, IDbContextDependencies, IDbSetCache, IDbContextPoolable, IResettableService, IDisposable, IAsyncDisposable, IReadDbContext, IDbContext where TContext : DbContext

Type Parameters

TContext

The concrete derived DbContext type (used for DbContextOptions<TContext> binding).

Inheritance

object

DbContext

ReadDbContext<TContext>

Implements

IInfrastructure<IServiceProvider>

IDbContextDependencies

IDbSetCache

IDbContextPoolable

IResettableService

IDisposable

IAsyncDisposable

IReadDbContext

IDbContext

Inherited Members

DbContext.Set<TEntity>()

DbContext.Set<TEntity>(string)

DbContext.OnConfiguring(DbContextOptionsBuilder)

DbContext.ConfigureConventions(ModelConfigurationBuilder)

DbContext.SaveChanges()

DbContext.SaveChanges(bool)

DbContext.SaveChangesAsync(CancellationToken)

DbContext.SaveChangesAsync(bool, CancellationToken)

DbContext.Dispose()

DbContext.DisposeAsync()

DbContext.Entry<TEntity>(TEntity)

DbContext.Entry(object)

DbContext.Add<TEntity>(TEntity)

DbContext.AddAsync<TEntity>(TEntity, CancellationToken)

DbContext.Attach<TEntity>(TEntity)

DbContext.Update<TEntity>(TEntity)

DbContext.Remove<TEntity>(TEntity)

DbContext.Add(object)

DbContext.AddAsync(object, CancellationToken)

DbContext.Attach(object)

DbContext.Update(object)

DbContext.Remove(object)

DbContext.AddRange(params object[])

DbContext.AddRangeAsync(params object[])

DbContext.AttachRange(params object[])

DbContext.UpdateRange(params object[])

DbContext.RemoveRange(params object[])

DbContext.AddRange(IEnumerable<object>)

DbContext.AddRangeAsync(IEnumerable<object>, CancellationToken)

DbContext.AttachRange(IEnumerable<object>)

DbContext.UpdateRange(IEnumerable<object>)

DbContext.RemoveRange(IEnumerable<object>)

DbContext.Find(Type, params object[])

DbContext.FindAsync(Type, params object[])

DbContext.FindAsync(Type, object[], CancellationToken)

DbContext.Find<TEntity>(params object[])

DbContext.FindAsync<TEntity>(params object[])

DbContext.FindAsync<TEntity>(object[], CancellationToken)

DbContext.FromExpression<TResult>(Expression<Func<IQueryable<TResult>>>)

DbContext.Database

DbContext.ChangeTracker

DbContext.Model

DbContext.ContextId

DbContext.SavingChanges

DbContext.SavedChanges

DbContext.SaveChangesFailed

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Extension Methods

FieldChangedEventExtensions.ApplyPropertyChanged<TAggregate>(TAggregate, FieldChangedEvent<TAggregate>)

EventStream.ApplyEvents(object, IReadOnlyList<IEvent>)

Remarks

Filters ApplyConfigurationsFromAssembly by the Stratara.EventSourcing.EntityFrameworkCore.ReadStore namespace so the write-store and identity-store IEntityTypeConfiguration<> implementations co-hosted in the same assembly do not leak into the read model. Missing the namespace predicate yields PendingModelChangesWarning at runtime — a regression that escapes unit tests and only surfaces against a real Postgres in the consumer's E2E pipeline.

Constructors

ReadDbContext(DbContextOptions<TContext>)

Base read-store DbContext that consumer DbContexts derive from. Hosts the projection / read-model tables that the projection workers write into and queries read from.

public ReadDbContext(DbContextOptions<TContext> options)

Parameters

options DbContextOptions<TContext>

Options bound by the host's AddNpgsqlReadDbContextFactory registration.

Remarks

Filters ApplyConfigurationsFromAssembly by the Stratara.EventSourcing.EntityFrameworkCore.ReadStore namespace so the write-store and identity-store IEntityTypeConfiguration<> implementations co-hosted in the same assembly do not leak into the read model. Missing the namespace predicate yields PendingModelChangesWarning at runtime — a regression that escapes unit tests and only surfaces against a real Postgres in the consumer's E2E pipeline.

Methods

OnModelCreating(ModelBuilder)

Override this method to further configure the model that was discovered by convention from the entity types exposed in DbSet<TEntity> properties on your derived context. The resulting model may be cached and re-used for subsequent instances of your derived context.

protected override void OnModelCreating(ModelBuilder modelBuilder)

Parameters

modelBuilder ModelBuilder

The builder being used to construct the model for this context. Databases (and other extensions) typically define extension methods on this object that allow you to configure aspects of the model that are specific to a given database.

Remarks

If a model is explicitly set on the options for this context (via UseModel(IModel)) then this method will not be run. However, it will still run when creating a compiled model.

See Modeling entity types and relationships for more information and examples.