Class WriteDbContext<TContext>

Namespace

Stratara.EventSourcing.EntityFrameworkCore.WriteStore

Assembly

Stratara.EventSourcing.EntityFrameworkCore.dll

Base write-store DbContext that consumer DbContexts derive from. Hosts the event-sourcing tables — event_stream_entry, snapshot, command_log_entry, and outbox_entry — that the command, hashing, and outbox workers persist into.

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

Type Parameters

TContext

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

Inheritance

object

DbContext

WriteDbContext<TContext>

Implements

IInfrastructure<IServiceProvider>

IDbContextDependencies

IDbSetCache

IDbContextPoolable

IResettableService

IDisposable

IAsyncDisposable

IWriteDbContext

IDbContext

Derived

StrataraTestWriteDbContext

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.WriteStore namespace so the read-store and identity-store IEntityTypeConfiguration<> implementations co-hosted in the same assembly do not leak into the write 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

WriteDbContext(DbContextOptions<TContext>)

Base write-store DbContext that consumer DbContexts derive from. Hosts the event-sourcing tables — event_stream_entry, snapshot, command_log_entry, and outbox_entry — that the command, hashing, and outbox workers persist into.

public WriteDbContext(DbContextOptions<TContext> options)

Parameters

options DbContextOptions<TContext>

Options bound by the host's AddNpgsqlWriteDbContextFactory registration.

Remarks

Filters ApplyConfigurationsFromAssembly by the Stratara.EventSourcing.EntityFrameworkCore.WriteStore namespace so the read-store and identity-store IEntityTypeConfiguration<> implementations co-hosted in the same assembly do not leak into the write 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.