Class PersistentDatabase

Namespace

The.SQL

Assembly

Instagile.dll

public abstract class PersistentDatabase : IDatabase, IDisposable

Inheritance

object

PersistentDatabase

Implements

IDatabase

IDisposable

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Extension Methods

DatabaseExtensions.BufferAsync<TResult>(IDatabase, string, Func<IDataRecord, TResult>, params DbParameter[])

DatabaseExtensions.BufferAsync<TResult>(IDatabase, string, TimeSpan?, Func<IDataRecord, TResult>, params DbParameter[])

DatabaseExtensions.BufferAsync<TResult>(IDatabase, string, TimeSpan?, CancellationToken, Func<IDataRecord, TResult>, params DbParameter[])

DatabaseExtensions.BufferAsync<TResult>(IDatabase, string, CancellationToken, Func<IDataRecord, TResult>, params DbParameter[])

DatabaseExtensions.Buffer<TResult>(IDatabase, string, Func<IDataRecord, TResult>, params DbParameter[])

DatabaseExtensions.Buffer<TResult>(IDatabase, string, TimeSpan?, Func<IDataRecord, TResult>, params DbParameter[])

DatabaseExtensions.Execute(IDatabase, string, params DbParameter[])

DatabaseExtensions.ExecuteAsync(IDatabase, string, params DbParameter[])

DatabaseExtensions.ExecuteAsync(IDatabase, string, CancellationToken, params DbParameter[])

DatabaseExtensions.QueryAsync<TResult>(IDatabase, string, CommandBehavior, Func<DbDataReader, TResult>, params DbParameter[])

DatabaseExtensions.QueryAsync<TResult>(IDatabase, string, Func<DbDataReader, TResult>, params DbParameter[])

DatabaseExtensions.QueryAsync<TResult>(IDatabase, string, CancellationToken, CommandBehavior, Func<DbDataReader, TResult>, params DbParameter[])

DatabaseExtensions.QueryAsync<TResult>(IDatabase, string, CancellationToken, Func<DbDataReader, TResult>, params DbParameter[])

DatabaseExtensions.Query<TResult>(IDatabase, string, Func<DbDataReader, TResult>, params DbParameter[])

DatabaseExtensions.ReadAsync<TResult>(IDatabase, string, Func<IDataRecord, TResult>, params DbParameter[])

DatabaseExtensions.ReadAsync<TResult>(IDatabase, string, TimeSpan?, Func<IDataRecord, TResult>, params DbParameter[])

DatabaseExtensions.ReadAsync<TResult>(IDatabase, string, TimeSpan?, CancellationToken, Func<IDataRecord, TResult>, params DbParameter[])

DatabaseExtensions.ReadAsync<TResult>(IDatabase, string, CancellationToken, Func<IDataRecord, TResult>, params DbParameter[])

DatabaseExtensions.Read<TResult>(IDatabase, string, Func<IDataRecord, TResult>, params DbParameter[])

DatabaseExtensions.Read<TResult>(IDatabase, string, TimeSpan?, Func<IDataRecord, TResult>, params DbParameter[])

DatabaseExtensions.Stream<TResult>(IDatabase, string, Func<IDataRecord, TResult>, params DbParameter[])

Constructors

PersistentDatabase(string, TimeSpan?)

public PersistentDatabase(string connectionString, TimeSpan? timeout = null)

Parameters

connectionString string

timeout TimeSpan?

Properties

Name

public string Name { get; }

Property Value

string

Server

public string Server { get; }

Property Value

string

SupportsBatching

public abstract bool SupportsBatching { get; }

Property Value

bool

Methods

Batch(IEnumerable<BatchQuery>, TimeSpan?)

Execute multiple queries

public void Batch(IEnumerable<BatchQuery> queries, TimeSpan? timeout = null)

Parameters

queries IEnumerable<BatchQuery>

timeout TimeSpan?

BatchAsync(IEnumerable<BatchQuery>, TimeSpan?, CancellationToken)

Execute multiple queries asynchronously

public Task BatchAsync(IEnumerable<BatchQuery> queries, TimeSpan? timeout = null, CancellationToken ct = default)

Parameters

queries IEnumerable<BatchQuery>

timeout TimeSpan?

ct CancellationToken

Returns

Task

BulkExecute(string, TimeSpan?, IReadOnlyList<DbParameter[]>)

Execute a command repeatedly

public virtual int BulkExecute(string commandText, TimeSpan? timeout, IReadOnlyList<DbParameter[]> parameterSets)

Parameters

commandText string

timeout TimeSpan?

parameterSets IReadOnlyList<DbParameter[]>

Returns

int

Affected row count

BulkExecuteAsync(string, TimeSpan?, CancellationToken, IReadOnlyList<DbParameter[]>)

Execute a command repeatedly, asynchronously

public virtual Task<int> BulkExecuteAsync(string commandText, TimeSpan? timeout, CancellationToken cancellationToken, IReadOnlyList<DbParameter[]> parameterSets)

Parameters

commandText string

timeout TimeSpan?

cancellationToken CancellationToken

parameterSets IReadOnlyList<DbParameter[]>

Returns

Task<int>

Affected row count

CreateConnection(string)

protected abstract DbConnection CreateConnection(string connectionString)

Parameters

connectionString string

Returns

DbConnection

Dispose()

Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources.

public void Dispose()

Execute(string, TimeSpan?, params DbParameter[])

Execute a command

public virtual int Execute(string commandText, TimeSpan? timeout, params DbParameter[] parameters)

Parameters

commandText string

timeout TimeSpan?

parameters DbParameter[]

Returns

int

Affected row count

ExecuteAsync(string, TimeSpan?, CancellationToken, params DbParameter[])

Execute a command asynchronously

public virtual Task<int> ExecuteAsync(string commandText, TimeSpan? timeout, CancellationToken cancellationToken, params DbParameter[] parameters)

Parameters

commandText string

timeout TimeSpan?

cancellationToken CancellationToken

parameters DbParameter[]

Returns

Task<int>

Affected row count

GetTransaction()

Begin a sequence of commands and queries wrapped in a transaction

public virtual ITransaction GetTransaction()

Returns

ITransaction

QueryAsync<TResult>(string, TimeSpan?, CancellationToken, CommandBehavior, Func<DbDataReader, TResult>, params DbParameter[])

Execute a query asynchronously

public virtual Task<TResult> QueryAsync<TResult>(string queryText, TimeSpan? timeout, CancellationToken cancellationToken, CommandBehavior behaviour, Func<DbDataReader, TResult> map, params DbParameter[] parameters)

Parameters

queryText string

timeout TimeSpan?

cancellationToken CancellationToken

behaviour CommandBehavior

map Func<DbDataReader, TResult>

parameters DbParameter[]

Returns

Task<TResult>

Query results

Type Parameters

TResult

Query<TResult>(string, TimeSpan?, CommandBehavior, Func<DbDataReader, TResult>, params DbParameter[])

Execute a query

public virtual TResult Query<TResult>(string queryText, TimeSpan? timeout, CommandBehavior behaviour, Func<DbDataReader, TResult> map, params DbParameter[] parameters)

Parameters

queryText string

timeout TimeSpan?

behaviour CommandBehavior

map Func<DbDataReader, TResult>

parameters DbParameter[]

Returns

TResult

Query results

Type Parameters

TResult

Stream(string, TimeSpan?, Func<DbDataReader, Stream>, params DbParameter[])

Execute a query which returns a forward-only stream, asynchronously

public virtual Stream Stream(string queryText, TimeSpan? timeout, Func<DbDataReader, Stream> map, params DbParameter[] parameters)

Parameters

queryText string

timeout TimeSpan?

map Func<DbDataReader, Stream>

parameters DbParameter[]

Returns

Stream

StreamAsync(string, TimeSpan?, CancellationToken, Func<DbDataReader, Stream?>, params DbParameter[])

Execute a query which returns a forward-only stream, asynchronously

public virtual Task<Stream> StreamAsync(string queryText, TimeSpan? timeout, CancellationToken cancellationToken, Func<DbDataReader, Stream?> map, params DbParameter[] parameters)

Parameters

queryText string

timeout TimeSpan?

cancellationToken CancellationToken

map Func<DbDataReader, Stream>

parameters DbParameter[]

Returns

Task<Stream>

Stream<TResult>(string, TimeSpan?, Func<IDataRecord, TResult>, params DbParameter[])

Produce a forward-only enumerable which will execute a query

public virtual IEnumerable<TResult> Stream<TResult>(string queryText, TimeSpan? timeout, Func<IDataRecord, TResult> map, params DbParameter[] parameters)

Parameters

queryText string

timeout TimeSpan?

map Func<IDataRecord, TResult>

parameters DbParameter[]

Returns

IEnumerable<TResult>

Query results

Type Parameters

TResult