Class AbstractQueryExecutor

TBD

Inheritance

Object

AbstractQueryExecutor

SqliteSnapshotQueryExecutor

Implements

ISnapshotQueryExecutor

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.Snapshot

Assembly: Akka.Persistence.Sql.Common.dll

Syntax

public abstract class AbstractQueryExecutor : ISnapshotQueryExecutor

Constructors

| Improve this Doc View Source

AbstractQueryExecutor(QueryConfiguration, Serialization)

TBD

Declaration

protected AbstractQueryExecutor(QueryConfiguration configuration, Serialization serialization)

Parameters

Type	Name	Description
QueryConfiguration	configuration	TBD
Serialization	serialization	TBD

Fields

| Improve this Doc View Source

Serialization

TBD

Declaration

protected Serialization Serialization

Field Value

Type	Description
Serialization

Properties

| Improve this Doc View Source

Configuration

TBD

Declaration

public QueryConfiguration Configuration { get; }

Property Value

Type	Description
QueryConfiguration

| Improve this Doc View Source

CreateSnapshotTableSql

TBD

Declaration

protected abstract string CreateSnapshotTableSql { get; }

Property Value

Type	Description
String

| Improve this Doc View Source

DeleteSnapshotRangeSql

TBD

Declaration

protected virtual string DeleteSnapshotRangeSql { get; }

Property Value

Type	Description
String

| Improve this Doc View Source

DeleteSnapshotSql

TBD

Declaration

protected virtual string DeleteSnapshotSql { get; }

Property Value

Type	Description
String

| Improve this Doc View Source

InsertSnapshotSql

TBD

Declaration

protected virtual string InsertSnapshotSql { 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

SelectSnapshotSql

TBD

Declaration

protected virtual string SelectSnapshotSql { 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

CreateTableAsync(DbConnection, CancellationToken)

TBD

Declaration

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

Parameters

Type	Name	Description
DbConnection	connection	TBD
CancellationToken	cancellationToken	TBD

Returns

Type	Description
Task	TBD

| Improve this Doc View Source

DeleteAsync(DbConnection, CancellationToken, String, Int64, Nullable<DateTime>)

TBD

Declaration

public virtual async Task DeleteAsync(DbConnection connection, CancellationToken cancellationToken, string persistenceId, long sequenceNr, DateTime? timestamp)

Parameters

Type	Name	Description
DbConnection	connection	TBD
CancellationToken	cancellationToken	TBD
String	persistenceId	TBD
Int64	sequenceNr	TBD
Nullable<DateTime>	timestamp	TBD

Returns

Type	Description
Task	TBD

| Improve this Doc View Source

DeleteBatchAsync(DbConnection, CancellationToken, String, Int64, DateTime)

TBD

Declaration

public virtual async Task DeleteBatchAsync(DbConnection connection, CancellationToken cancellationToken, string persistenceId, long maxSequenceNr, DateTime maxTimestamp)

Parameters

Type	Name	Description
DbConnection	connection	TBD
CancellationToken	cancellationToken	TBD
String	persistenceId	TBD
Int64	maxSequenceNr	TBD
DateTime	maxTimestamp	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

GetSnapshot(DbDataReader)

TBD

Declaration

protected object GetSnapshot(DbDataReader reader)

Parameters

Type	Name	Description
DbDataReader	reader	TBD

Returns

Type	Description
Object	TBD

| Improve this Doc View Source

InsertAsync(DbConnection, CancellationToken, Object, SnapshotMetadata)

TBD

Declaration

public virtual async Task InsertAsync(DbConnection connection, CancellationToken cancellationToken, object snapshot, SnapshotMetadata metadata)

Parameters

Type	Name	Description
DbConnection	connection	TBD
CancellationToken	cancellationToken	TBD
Object	snapshot	TBD
SnapshotMetadata	metadata	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

ReadSnapshot(DbDataReader)

TBD

Declaration

protected virtual SelectedSnapshot ReadSnapshot(DbDataReader reader)

Parameters

Type	Name	Description
DbDataReader	reader	TBD

Returns

Type	Description
SelectedSnapshot	TBD

| Improve this Doc View Source

SelectSnapshotAsync(DbConnection, CancellationToken, String, Int64, DateTime)

TBD

Declaration

public virtual Task<SelectedSnapshot> SelectSnapshotAsync(DbConnection connection, CancellationToken cancellationToken, string persistenceId, long maxSequenceNr, DateTime maxTimestamp)

Parameters

Type	Name	Description
DbConnection	connection	TBD
CancellationToken	cancellationToken	TBD
String	persistenceId	TBD
Int64	maxSequenceNr	TBD
DateTime	maxTimestamp	TBD

Returns

Type	Description
Task<SelectedSnapshot>	TBD

| Improve this Doc View Source

SetManifestParameters(Object, DbCommand)

TBD

Declaration

protected virtual void SetManifestParameters(object snapshot, DbCommand command)

Parameters

Type	Name	Description
Object	snapshot	TBD
DbCommand	command	TBD

| Improve this Doc View Source

SetPayloadParameter(Object, DbCommand)

TBD

Declaration

protected virtual void SetPayloadParameter(object snapshot, DbCommand command)

Parameters

Type	Name	Description
Object	snapshot	TBD
DbCommand	command	TBD

| Improve this Doc View Source

SetPersistenceIdParameter(String, DbCommand)

TBD

Declaration

protected virtual void SetPersistenceIdParameter(string persistenceId, DbCommand command)

Parameters

Type	Name	Description
String	persistenceId	TBD
DbCommand	command	TBD

| Improve this Doc View Source

SetSequenceNrParameter(Int64, DbCommand)

TBD

Declaration

protected virtual void SetSequenceNrParameter(long sequenceNr, DbCommand command)

Parameters

Type	Name	Description
Int64	sequenceNr	TBD
DbCommand	command	TBD

| Improve this Doc View Source

SetTimestampParameter(DateTime, DbCommand)

TBD

Declaration

protected virtual void SetTimestampParameter(DateTime timestamp, DbCommand command)

Parameters

Type	Name	Description
DateTime	timestamp	TBD
DbCommand	command	TBD

Implements

ISnapshotQueryExecutor

Extension Methods

ObjectExtensions.IsDefaultForType<T>(T)

ObjectExtensions.AsOption<T>(T)

Extensions.AsInstanceOf<T>(Object)