Search Results for

    Show / Hide Table of Contents

    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.Sqlite.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)
    In This Article
    • githubImprove this Doc
    • View Source
    Back to top
    Contribute
    • Project Chat
    • Discussion Forum
    • Source Code
    Support
    • Akka.NET Support Plans
    • Akka.NET Observability Tools
    • Akka.NET Training & Consulting
    Maintained By
    • Petabridge - The Akka.NET Company
    • Learn Akka.NET