Class AbstractQueryExecutor

TBD

Inheritance

Object

AbstractQueryExecutor

Implements

IJournalQueryExecutor

Inherited Members

Object.Equals(Object)

Object.Equals(Object, Object)

Object.GetHashCode()

Object.GetType()

Object.MemberwiseClone()

Object.ReferenceEquals(Object, Object)

Object.ToString()

Namespace: Akka.Persistence.Sql.Common.Journal

Assembly: Akka.Persistence.Sql.Common.dll

Syntax

public abstract class AbstractQueryExecutor : IJournalQueryExecutor

Constructors

| Improve this Doc View Source

AbstractQueryExecutor(QueryConfiguration, Serialization, ITimestampProvider)

TBD

Declaration

protected AbstractQueryExecutor(QueryConfiguration configuration, Serialization serialization, ITimestampProvider timestampProvider)

Parameters

Type	Name	Description
QueryConfiguration	configuration	TBD
Serialization	serialization	TBD
ITimestampProvider	timestampProvider	TBD

Fields

| Improve this Doc View Source

IsDeletedIndex

TBD

Declaration

protected const int IsDeletedIndex = 3

Field Value

Type	Description
Int32

| Improve this Doc View Source

LongTypeName

TBD

Declaration

protected static readonly string LongTypeName

Field Value

Type	Description
String

| Improve this Doc View Source

ManifestIndex

TBD

Declaration

protected const int ManifestIndex = 4

Field Value

Type	Description
Int32

| Improve this Doc View Source

OrderingIndex

TBD

Declaration

protected const int OrderingIndex = 7

Field Value

Type	Description
Int32

| Improve this Doc View Source

PayloadIndex

TBD

Declaration

protected const int PayloadIndex = 5

Field Value

Type	Description
Int32

| Improve this Doc View Source

PersistenceIdIndex

TBD

Declaration

protected const int PersistenceIdIndex = 0

Field Value

Type	Description
Int32

| Improve this Doc View Source

SequenceNrIndex

TBD

Declaration

protected const int SequenceNrIndex = 1

Field Value

Type	Description
Int32

| Improve this Doc View Source

Serialization

TBD

Declaration

protected Serialization Serialization

Field Value

Type	Description
Serialization

| Improve this Doc View Source

SerializerIdIndex

TBD

Declaration

protected const int SerializerIdIndex = 6

Field Value

Type	Description
Int32

| Improve this Doc View Source

TimestampIndex

TBD

Declaration

protected const int TimestampIndex = 2

Field Value

Type	Description
Int32

| Improve this Doc View Source

TimestampProvider

TBD

Declaration

protected ITimestampProvider TimestampProvider

Field Value

Type	Description
ITimestampProvider

Properties

| Improve this Doc View Source

AllEventsSql

TBD

Declaration

protected virtual string AllEventsSql { get; }

Property Value

Type	Description
String

| Improve this Doc View Source

AllPersistenceIdsSql

TBD

Declaration

protected virtual string AllPersistenceIdsSql { get; }

Property Value

Type	Description
String

| Improve this Doc View Source

ByPersistenceIdSql

TBD

Declaration

protected virtual string ByPersistenceIdSql { get; }

Property Value

Type	Description
String

| Improve this Doc View Source

ByTagSql

TBD

Declaration

protected virtual string ByTagSql { get; }

Property Value

Type	Description
String

| Improve this Doc View Source

Configuration

TBD

Declaration

public QueryConfiguration Configuration { get; }

Property Value

Type	Description
QueryConfiguration

| Improve this Doc View Source

CreateEventsJournalSql

TBD

Declaration

protected abstract string CreateEventsJournalSql { get; }

Property Value

Type	Description
String

| Improve this Doc View Source

CreateMetaTableSql

TBD

Declaration

protected abstract string CreateMetaTableSql { get; }

Property Value

Type	Description
String

| Improve this Doc View Source

DeleteBatchSql

TBD

Declaration

protected virtual string DeleteBatchSql { get; }

Property Value

Type	Description
String

| Improve this Doc View Source

HighestOrderingSql

TBD

Declaration

protected virtual string HighestOrderingSql { get; }

Property Value

Type	Description
String

| Improve this Doc View Source

HighestSequenceNrSql

TBD

Declaration

protected virtual string HighestSequenceNrSql { get; }

Property Value

Type	Description
String

| Improve this Doc View Source

HighestTagOrderingSql

Query to return the highest ordering number for a tag

Declaration

protected virtual string HighestTagOrderingSql { get; }

Property Value

Type	Description
String

| Improve this Doc View Source

InsertEventSql

TBD

Declaration

protected virtual string InsertEventSql { get; }

Property Value

Type	Description
String

| Improve this Doc View Source

ReadIsolationLevel

Isolation level of transactions used during read query execution.

Declaration

public IsolationLevel ReadIsolationLevel { get; }

Property Value

Type	Description
IsolationLevel

| Improve this Doc View Source

UpdateSequenceNrSql

TBD

Declaration

protected virtual string UpdateSequenceNrSql { get; }

Property Value

Type	Description
String

| Improve this Doc View Source

WriteIsolationLevel

Isolation level of transactions used during write query execution.

Declaration

public IsolationLevel WriteIsolationLevel { get; }

Property Value

Type	Description
IsolationLevel

Methods

| Improve this Doc View Source

AddParameter(DbCommand, String, DbType, Object)

TBD

Declaration

protected void AddParameter(DbCommand command, string parameterName, DbType parameterType, object value)

Parameters

Type	Name	Description
DbCommand	command	TBD
String	parameterName	TBD
DbType	parameterType	TBD
Object	value	TBD

| Improve this Doc View Source

CreateCommand(DbConnection)

TBD

Declaration

protected abstract DbCommand CreateCommand(DbConnection connection)

Parameters

Type	Name	Description
DbConnection	connection	TBD

Returns

Type	Description
DbCommand	TBD

| Improve this Doc View Source

CreateTablesAsync(DbConnection, CancellationToken)

TBD

Declaration

public virtual async Task CreateTablesAsync(DbConnection connection, CancellationToken cancellationToken)

Parameters

Type	Name	Description
DbConnection	connection	TBD
CancellationToken	cancellationToken	TBD

Returns

Type	Description
Task	TBD

| Improve this Doc View Source

DeleteBatchAsync(DbConnection, CancellationToken, String, Int64)

TBD

Declaration

public virtual async Task DeleteBatchAsync(DbConnection connection, CancellationToken cancellationToken, string persistenceId, long toSequenceNr)

Parameters

Type	Name	Description
DbConnection	connection	TBD
CancellationToken	cancellationToken	TBD
String	persistenceId	TBD
Int64	toSequenceNr	TBD

Returns

Type	Description
Task	TBD

| Improve this Doc View Source

GetCommand(DbConnection, String)

TBD

Declaration

protected DbCommand GetCommand(DbConnection connection, string sql)

Parameters

Type	Name	Description
DbConnection	connection	TBD
String	sql	TBD

Returns

Type	Description
DbCommand	TBD

| Improve this Doc View Source

InsertBatchAsync(DbConnection, CancellationToken, WriteJournalBatch)

TBD

Declaration

public virtual async Task InsertBatchAsync(DbConnection connection, CancellationToken cancellationToken, WriteJournalBatch write)

Parameters

Type	Name	Description
DbConnection	connection	TBD
CancellationToken	cancellationToken	TBD
WriteJournalBatch	write	TBD

Returns

Type	Description
Task	TBD

| Improve this Doc View Source

PreAddParameterToCommand(DbCommand, DbParameter)

Override this to customize DbParameter creation used for building database queries

Declaration

protected virtual void PreAddParameterToCommand(DbCommand command, DbParameter param)

Parameters

Type	Name	Description
DbCommand	command	DbCommand used to define a parameter in.
DbParameter	param	Parameter to customize

| Improve this Doc View Source

ReadEvent(DbDataReader)

TBD

Declaration

protected virtual IPersistentRepresentation ReadEvent(DbDataReader reader)

Parameters

Type	Name	Description
DbDataReader	reader	TBD

Returns

Type	Description
IPersistentRepresentation	TBD

| Improve this Doc View Source

SelectAllEventsAsync(DbConnection, CancellationToken, Int64, Int64, Int64, Action<ReplayedEvent>)

Declaration

public virtual Task<long> SelectAllEventsAsync(DbConnection connection, CancellationToken cancellationToken, long fromOffset, long toOffset, long max, Action<ReplayedEvent> callback)

Parameters

Type	Name	Description
DbConnection	connection
CancellationToken	cancellationToken
Int64	fromOffset
Int64	toOffset
Int64	max
Action<ReplayedEvent>	callback

Returns

Type	Description
Task<Int64>

| Improve this Doc View Source

SelectAllPersistenceIdsAsync(DbConnection, CancellationToken, Int64)

TBD

Declaration

public virtual Task<ImmutableArray<string>> SelectAllPersistenceIdsAsync(DbConnection connection, CancellationToken cancellationToken, long offset)

Parameters

Type	Name	Description
DbConnection	connection	TBD
CancellationToken	cancellationToken	TBD
Int64	offset	TBD

Returns

Type	Description
Task<System.Collections.Immutable.ImmutableArray<String>>	TBD

| Improve this Doc View Source

SelectByPersistenceIdAsync(DbConnection, CancellationToken, String, Int64, Int64, Int64, Action<IPersistentRepresentation>)

TBD

Declaration

public virtual async Task SelectByPersistenceIdAsync(DbConnection connection, CancellationToken cancellationToken, string persistenceId, long fromSequenceNr, long toSequenceNr, long max, Action<IPersistentRepresentation> callback)

Parameters

Type	Name	Description
DbConnection	connection	TBD
CancellationToken	cancellationToken	TBD
String	persistenceId	TBD
Int64	fromSequenceNr	TBD
Int64	toSequenceNr	TBD
Int64	max	TBD
Action<IPersistentRepresentation>	callback	TBD

Returns

Type	Description
Task	TBD

| Improve this Doc View Source

SelectByTagAsync(DbConnection, CancellationToken, String, Int64, Int64, Int64, Action<ReplayedTaggedMessage>)

TBD

Declaration

public virtual async Task<long> SelectByTagAsync(DbConnection connection, CancellationToken cancellationToken, string tag, long fromOffset, long toOffset, long max, Action<ReplayedTaggedMessage> callback)

Parameters

Type	Name	Description
DbConnection	connection	TBD
CancellationToken	cancellationToken	TBD
String	tag	TBD
Int64	fromOffset	TBD
Int64	toOffset	TBD
Int64	max	TBD
Action<ReplayedTaggedMessage>	callback	TBD

Returns

Type	Description
Task<Int64>	TBD

| Improve this Doc View Source

SelectHighestSequenceNrAsync(DbConnection, CancellationToken)

Declaration

public virtual Task<long> SelectHighestSequenceNrAsync(DbConnection connection, CancellationToken cancellationToken)

Parameters

Type	Name	Description
DbConnection	connection
CancellationToken	cancellationToken

Returns

Type	Description
Task<Int64>

| Improve this Doc View Source

SelectHighestSequenceNrAsync(DbConnection, CancellationToken, String)

TBD

Declaration

public virtual Task<long> SelectHighestSequenceNrAsync(DbConnection connection, CancellationToken cancellationToken, string persistenceId)

Parameters

Type	Name	Description
DbConnection	connection	TBD
CancellationToken	cancellationToken	TBD
String	persistenceId	TBD

Returns

Type	Description
Task<Int64>	TBD

| Improve this Doc View Source

WriteEvent(DbCommand, IPersistentRepresentation, IImmutableSet<String>)

TBD

Declaration

protected virtual void WriteEvent(DbCommand command, IPersistentRepresentation e, IImmutableSet<string> tags)

Parameters

Type	Name	Description
DbCommand	command	TBD
IPersistentRepresentation	e	TBD
System.Collections.Immutable.IImmutableSet<String>	tags	TBD

Implements

IJournalQueryExecutor

Extension Methods

ObjectExtensions.IsDefaultForType<T>(T)

ObjectExtensions.AsOption<T>(T)

Extensions.AsInstanceOf<T>(Object)