SqlProjectionStoreType

PackageFCQRS
Stores one durable, contiguous sequence position per projection and persistence ID. Connection factories must return new, unopened connections. The journal factory must read the authoritative journal database, not a replica. Read-model writes must use the connection and transaction supplied to the projection handler, so they commit with progress. Journal history must remain available until every required projection has processed it. Table and column names are quoted as individual identifiers; schemas are separate arguments. The progress table and its companion lock table are owned by FCQRS and must not be edited. Journal source settings are compared conservatively. Password changes are excluded from the persisted source binding so a new store can resume existing progress after credential rotation.

Specification

Kind
Type
Members
4
Examples
0
``.ctor``Signature
SqlProjectionStore(dialect, journalConnectionFactory, projectionConnectionFactory)
``.ctor``Signature
SqlProjectionStore(dialect, connectionFactory)
``.ctor``Signature
SqlProjectionStore(dialect, journalConnectionFactory, projectionConnectionFactory, ?journalTable, ?journalSchema, ?progressTable, ?progressSchema, ?journalPersistenceIdColumn, ?journalSequenceNumberColumn)
DialectSignature
this.Dialect

Summary

NameSignatureSynopsis
``.ctor``SqlProjectionStore(dialect, journalConnectionFactory, projectionConnectionFactory)Uses separate journal and read-model databases with the default table mappings.
``.ctor``SqlProjectionStore(dialect, connectionFactory)Uses one database for both the journal and the transactional read model.
``.ctor``SqlProjectionStore(dialect, journalConnectionFactory, projectionConnectionFactory, ?journalTable, ?journalSchema, ?progressTable, ?progressSchema, ?journalPersistenceIdColumn, ?journalSequenceNumberColumn)No description available.
Dialectthis.DialectThe SQL dialect used by this store.

``.ctor``

SqlProjectionStore(dialect, journalConnectionFactory, projectionConnectionFactory)
Member
Uses separate journal and read-model databases with the default table mappings.

Parameters

NameTypeDescription
dialectProjectionSqlDialect
journalConnectionFactoryFunc<DbConnection>
projectionConnectionFactoryFunc<DbConnection>

Returns

SqlProjectionStore

``.ctor``

SqlProjectionStore(dialect, connectionFactory)
Member
Uses one database for both the journal and the transactional read model.

Parameters

NameTypeDescription
dialectProjectionSqlDialect
connectionFactoryFunc<DbConnection>

Returns

SqlProjectionStore

``.ctor``

SqlProjectionStore(dialect, journalConnectionFactory, projectionConnectionFactory, ?journalTable, ?journalSchema, ?progressTable, ?progressSchema, ?journalPersistenceIdColumn, ?journalSequenceNumberColumn)
Member

Parameters

NameTypeDescription
dialectProjectionSqlDialect
journalConnectionFactoryFunc<DbConnection>
projectionConnectionFactoryFunc<DbConnection>
journalTablestring
journalSchemastring
progressTablestring
progressSchemastring
journalPersistenceIdColumnstring
journalSequenceNumberColumnstring

Returns

SqlProjectionStore

Dialect

this.Dialect
Member
The SQL dialect used by this store.

Returns

ProjectionSqlDialect