Class DatabaseExtensions

Namespace

The.SQL

Assembly

Instagile.dll

public static class DatabaseExtensions

Inheritance

object

DatabaseExtensions

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Methods

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

Execute a query asynchronously and produce a list of results, one for each row, with default timeout and no cancellation token

public static Task<IReadOnlyList<TResult>> BufferAsync<TResult>(this IDatabase db, string queryText, Func<IDataRecord, TResult> map, params DbParameter[] parameters)

Parameters

db IDatabase

queryText string

map Func<IDataRecord, TResult>

parameters DbParameter[]

Returns

Task<IReadOnlyList<TResult>>

Type Parameters

TResult

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

Execute a query asynchronously and produce a list of results, one for each row, with no cancellation token

public static Task<IReadOnlyList<TResult>> BufferAsync<TResult>(this IDatabase db, string queryText, TimeSpan? timeout, Func<IDataRecord, TResult> map, params DbParameter[] parameters)

Parameters

db IDatabase

queryText string

timeout TimeSpan?

map Func<IDataRecord, TResult>

parameters DbParameter[]

Returns

Task<IReadOnlyList<TResult>>

Type Parameters

TResult

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

Execute a query asynchronously and produce a list of results, one for each row

public static Task<IReadOnlyList<TResult>> BufferAsync<TResult>(this IDatabase db, string queryText, TimeSpan? timeout, CancellationToken cancellationToken, Func<IDataRecord, TResult> map, params DbParameter[] parameters)

Parameters

db IDatabase

queryText string

timeout TimeSpan?

cancellationToken CancellationToken

map Func<IDataRecord, TResult>

parameters DbParameter[]

Returns

Task<IReadOnlyList<TResult>>

Type Parameters

TResult

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

Execute a query asynchronously and produce a list of results, one for each row, with default timeout

public static Task<IReadOnlyList<TResult>> BufferAsync<TResult>(this IDatabase db, string queryText, CancellationToken cancellationToken, Func<IDataRecord, TResult> map, params DbParameter[] parameters)

Parameters

db IDatabase

queryText string

cancellationToken CancellationToken

map Func<IDataRecord, TResult>

parameters DbParameter[]

Returns

Task<IReadOnlyList<TResult>>

Type Parameters

TResult

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

Execute a query and produce a list of results, one for each row, with default timeout

public static IReadOnlyList<TResult> Buffer<TResult>(this IDatabase db, string queryText, Func<IDataRecord, TResult> map, params DbParameter[] parameters)

Parameters

db IDatabase

queryText string

map Func<IDataRecord, TResult>

parameters DbParameter[]

Returns

IReadOnlyList<TResult>

Type Parameters

TResult

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

Execute a query and produce a list of results, one for each row

public static IReadOnlyList<TResult> Buffer<TResult>(this IDatabase db, string queryText, TimeSpan? timeout, Func<IDataRecord, TResult> map, params DbParameter[] parameters)

Parameters

db IDatabase

queryText string

timeout TimeSpan?

map Func<IDataRecord, TResult>

parameters DbParameter[]

Returns

IReadOnlyList<TResult>

Type Parameters

TResult

Execute(IDatabase, string, params DbParameter[])

Execute a command with default timeout

public static int Execute(this IDatabase db, string commandText, params DbParameter[] parameters)

Parameters

db IDatabase

commandText string

parameters DbParameter[]

Returns

int

ExecuteAsync(IDatabase, string, params DbParameter[])

Execute a command asynchronously with default timeout and no cancellation token

public static Task<int> ExecuteAsync(this IDatabase db, string commandText, params DbParameter[] parameters)

Parameters

db IDatabase

commandText string

parameters DbParameter[]

Returns

Task<int>

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

Execute a command asynchronously with default timeout

public static Task<int> ExecuteAsync(this IDatabase db, string commandText, CancellationToken cancellationToken, params DbParameter[] parameters)

Parameters

db IDatabase

commandText string

cancellationToken CancellationToken

parameters DbParameter[]

Returns

Task<int>

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

Execute a query asynchronously with default timeout and no cancellation token

public static Task<TResult> QueryAsync<TResult>(this IDatabase db, string queryText, CommandBehavior behaviour, Func<DbDataReader, TResult> map, params DbParameter[] parameters)

Parameters

db IDatabase

queryText string

behaviour CommandBehavior

map Func<DbDataReader, TResult>

parameters DbParameter[]

Returns

Task<TResult>

Type Parameters

TResult

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

Execute a query asynchronously with default behaviour and timeout and no cancellation token

public static Task<TResult> QueryAsync<TResult>(this IDatabase db, string queryText, Func<DbDataReader, TResult> map, params DbParameter[] parameters)

Parameters

db IDatabase

queryText string

map Func<DbDataReader, TResult>

parameters DbParameter[]

Returns

Task<TResult>

Type Parameters

TResult

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

Execute a query asynchronously with default timeout

public static Task<TResult> QueryAsync<TResult>(this IDatabase db, string queryText, CancellationToken cancellationToken, CommandBehavior behaviour, Func<DbDataReader, TResult> map, params DbParameter[] parameters)

Parameters

db IDatabase

queryText string

cancellationToken CancellationToken

behaviour CommandBehavior

map Func<DbDataReader, TResult>

parameters DbParameter[]

Returns

Task<TResult>

Type Parameters

TResult

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

Execute a query asynchronously with default behaviour and timeout

public static Task<TResult> QueryAsync<TResult>(this IDatabase db, string queryText, CancellationToken cancellationToken, Func<DbDataReader, TResult> map, params DbParameter[] parameters)

Parameters

db IDatabase

queryText string

cancellationToken CancellationToken

map Func<DbDataReader, TResult>

parameters DbParameter[]

Returns

Task<TResult>

Type Parameters

TResult

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

Execute a query with default behaviour and timeout

public static TResult Query<TResult>(this IDatabase db, string queryText, Func<DbDataReader, TResult> map, params DbParameter[] parameters)

Parameters

db IDatabase

queryText string

map Func<DbDataReader, TResult>

parameters DbParameter[]

Returns

TResult

Type Parameters

TResult

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

Execute a query asynchronously and produce a single result with default timeout and no cancellation token

public static Task<TResult?> ReadAsync<TResult>(this IDatabase db, string queryText, Func<IDataRecord, TResult> map, params DbParameter[] parameters)

Parameters

db IDatabase

queryText string

map Func<IDataRecord, TResult>

parameters DbParameter[]

Returns

Task<TResult>

Type Parameters

TResult

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

Execute a query asynchronously and produce a single result with no cancellation token

public static Task<TResult?> ReadAsync<TResult>(this IDatabase db, string queryText, TimeSpan? timeout, Func<IDataRecord, TResult> map, params DbParameter[] parameters)

Parameters

db IDatabase

queryText string

timeout TimeSpan?

map Func<IDataRecord, TResult>

parameters DbParameter[]

Returns

Task<TResult>

Type Parameters

TResult

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

Execute a query asynchronously and produce a single result

public static Task<TResult?> ReadAsync<TResult>(this IDatabase db, string queryText, TimeSpan? timeout, CancellationToken cancellationToken, Func<IDataRecord, TResult> map, params DbParameter[] parameters)

Parameters

db IDatabase

queryText string

timeout TimeSpan?

cancellationToken CancellationToken

map Func<IDataRecord, TResult>

parameters DbParameter[]

Returns

Task<TResult>

Type Parameters

TResult

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

Execute a query asynchronously and produce a single result with default timeout

public static Task<TResult?> ReadAsync<TResult>(this IDatabase db, string queryText, CancellationToken cancellationToken, Func<IDataRecord, TResult> map, params DbParameter[] parameters)

Parameters

db IDatabase

queryText string

cancellationToken CancellationToken

map Func<IDataRecord, TResult>

parameters DbParameter[]

Returns

Task<TResult>

Type Parameters

TResult

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

Execute a query and produce a single result with default timeout

public static TResult? Read<TResult>(this IDatabase db, string queryText, Func<IDataRecord, TResult> map, params DbParameter[] parameters)

Parameters

db IDatabase

queryText string

map Func<IDataRecord, TResult>

parameters DbParameter[]

Returns

TResult

Type Parameters

TResult

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

Execute a query and produce a single result

public static TResult? Read<TResult>(this IDatabase db, string queryText, TimeSpan? timeout, Func<IDataRecord, TResult> map, params DbParameter[] parameters)

Parameters

db IDatabase

queryText string

timeout TimeSpan?

map Func<IDataRecord, TResult>

parameters DbParameter[]

Returns

TResult

Type Parameters

TResult

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

Produce a forward-only enumerable which will execute a query with default timeout

public static IEnumerable<TResult> Stream<TResult>(this IDatabase db, string queryText, Func<IDataRecord, TResult> map, params DbParameter[] parameters)

Parameters

db IDatabase

queryText string

map Func<IDataRecord, TResult>

parameters DbParameter[]

Returns

IEnumerable<TResult>

Type Parameters

TResult