Class QueryExecutor

Executes configured queries.

Inheritance
Object
QueryExecutor
Namespace: Gossip.Connection.Fluent
Assembly: Gossip.dll
Syntax
public class QueryExecutor : object, IUpdatableQueryExecutor, IQueryExecutor, IBulkQueryExecutor

Constructors

| Improve this Doc View Source

QueryExecutor(ISqlConnection, QueryConfiguration, FunctionMetadata, IPluginManager, IExecutionStrategy)

Declaration
public QueryExecutor(ISqlConnection conn, QueryConfiguration config, FunctionMetadata metadata, IPluginManager pluginManager, IExecutionStrategy executionStrategy)
Parameters
Type Name Description
ISqlConnection conn
QueryConfiguration config
FunctionMetadata metadata
IPluginManager pluginManager
IExecutionStrategy executionStrategy

Methods

| Improve this Doc View Source

BatchedBy<T>(IEnumerable<T>)

Declaration
public IPartitionConfigurator<T> BatchedBy<T>(IEnumerable<T> partitionedBy)
Parameters
Type Name Description
IEnumerable<T> partitionedBy
Returns
Type Description
IPartitionConfigurator<T>
Type Parameters
Name Description
T
| Improve this Doc View Source

Execute()

Declaration
public int Execute()
Returns
Type Description
Int32
| Improve this Doc View Source

ExecuteAsync()

Declaration
public Task<int> ExecuteAsync()
Returns
Type Description
Task<Int32>
| Improve this Doc View Source

ExecuteScalar<T>()

Declaration
public T ExecuteScalar<T>()
Returns
Type Description
T
Type Parameters
Name Description
T
| Improve this Doc View Source

ExecuteScalarAsync<T>()

Declaration
public Task<T> ExecuteScalarAsync<T>()
Returns
Type Description
Task<T>
Type Parameters
Name Description
T
| Improve this Doc View Source

InsertInBulkAsync<T>(IEnumerable<T>, String, Int32, Dictionary<String, String>)

Declaration
public Task InsertInBulkAsync<T>(IEnumerable<T> data, string tableName, int timeoutInSeconds, Dictionary<string, string> columnMappings)
Parameters
Type Name Description
IEnumerable<T> data
String tableName
Int32 timeoutInSeconds
Dictionary<String, String> columnMappings
Returns
Type Description
Task
Type Parameters
Name Description
T
| Improve this Doc View Source

Query<T>()

Declaration
public IEnumerable<T> Query<T>()
Returns
Type Description
IEnumerable<T>
Type Parameters
Name Description
T
| Improve this Doc View Source

QueryAsync<T>()

Declaration
public Task<IEnumerable<T>> QueryAsync<T>()
Returns
Type Description
Task<IEnumerable<T>>
Type Parameters
Name Description
T
| Improve this Doc View Source

QueryAsync<TFirst, TSecond, TReturn>(Func<TFirst, TSecond, TReturn>)

Declaration
public Task<IEnumerable<TReturn>> QueryAsync<TFirst, TSecond, TReturn>(Func<TFirst, TSecond, TReturn> mapping)
Parameters
Type Name Description
Func<TFirst, TSecond, TReturn> mapping
Returns
Type Description
Task<IEnumerable<TReturn>>
Type Parameters
Name Description
TFirst
TSecond
TReturn
| Improve this Doc View Source

QueryAsync<TFirst, TSecond, TThird, TReturn>(Func<TFirst, TSecond, TThird, TReturn>)

Declaration
public Task<IEnumerable<TReturn>> QueryAsync<TFirst, TSecond, TThird, TReturn>(Func<TFirst, TSecond, TThird, TReturn> mapping)
Parameters
Type Name Description
Func<TFirst, TSecond, TThird, TReturn> mapping
Returns
Type Description
Task<IEnumerable<TReturn>>
Type Parameters
Name Description
TFirst
TSecond
TThird
TReturn
| Improve this Doc View Source

QueryAsync<TFirst, TSecond, TThird, TFourth, TReturn>(Func<TFirst, TSecond, TThird, TFourth, TReturn>)

Declaration
public Task<IEnumerable<TReturn>> QueryAsync<TFirst, TSecond, TThird, TFourth, TReturn>(Func<TFirst, TSecond, TThird, TFourth, TReturn> mapping)
Parameters
Type Name Description
Func<TFirst, TSecond, TThird, TFourth, TReturn> mapping
Returns
Type Description
Task<IEnumerable<TReturn>>
Type Parameters
Name Description
TFirst
TSecond
TThird
TFourth
TReturn
| Improve this Doc View Source

QueryAsync<TFirst, TSecond, TThird, TFourth, TFifth, TReturn>(Func<TFirst, TSecond, TThird, TFourth, TFifth, TReturn>)

Declaration
public Task<IEnumerable<TReturn>> QueryAsync<TFirst, TSecond, TThird, TFourth, TFifth, TReturn>(Func<TFirst, TSecond, TThird, TFourth, TFifth, TReturn> mapping)
Parameters
Type Name Description
Func<TFirst, TSecond, TThird, TFourth, TFifth, TReturn> mapping
Returns
Type Description
Task<IEnumerable<TReturn>>
Type Parameters
Name Description
TFirst
TSecond
TThird
TFourth
TFifth
TReturn
| Improve this Doc View Source

QueryAsync<TFirst, TSecond, TThird, TFourth, TFifth, TSixth, TReturn>(Func<TFirst, TSecond, TThird, TFourth, TFifth, TSixth, TReturn>)

Declaration
public Task<IEnumerable<TReturn>> QueryAsync<TFirst, TSecond, TThird, TFourth, TFifth, TSixth, TReturn>(Func<TFirst, TSecond, TThird, TFourth, TFifth, TSixth, TReturn> mapping)
Parameters
Type Name Description
Func<TFirst, TSecond, TThird, TFourth, TFifth, TSixth, TReturn> mapping
Returns
Type Description
Task<IEnumerable<TReturn>>
Type Parameters
Name Description
TFirst
TSecond
TThird
TFourth
TFifth
TSixth
TReturn
| Improve this Doc View Source

QueryAsync<TFirst, TSecond, TThird, TFourth, TFifth, TSixth, TSeventh, TReturn>(Func<TFirst, TSecond, TThird, TFourth, TFifth, TSixth, TSeventh, TReturn>)

Declaration
public Task<IEnumerable<TReturn>> QueryAsync<TFirst, TSecond, TThird, TFourth, TFifth, TSixth, TSeventh, TReturn>(Func<TFirst, TSecond, TThird, TFourth, TFifth, TSixth, TSeventh, TReturn> mapping)
Parameters
Type Name Description
Func<TFirst, TSecond, TThird, TFourth, TFifth, TSixth, TSeventh, TReturn> mapping
Returns
Type Description
Task<IEnumerable<TReturn>>
Type Parameters
Name Description
TFirst
TSecond
TThird
TFourth
TFifth
TSixth
TSeventh
TReturn
| Improve this Doc View Source

QueryFirstOrDefault<T>()

Declaration
public T QueryFirstOrDefault<T>()
Returns
Type Description
T
Type Parameters
Name Description
T
| Improve this Doc View Source

QueryFirstOrDefaultAsync<T>()

Declaration
public Task<T> QueryFirstOrDefaultAsync<T>()
Returns
Type Description
Task<T>
Type Parameters
Name Description
T
| Improve this Doc View Source

QuerySingleOrDefault<T>()

Declaration
public T QuerySingleOrDefault<T>()
Returns
Type Description
T
Type Parameters
Name Description
T
| Improve this Doc View Source

QuerySingleOrDefaultAsync<T>()

Declaration
public Task<T> QuerySingleOrDefaultAsync<T>()
Returns
Type Description
Task<T>
Type Parameters
Name Description
T
| Improve this Doc View Source

UpdateConfig(QueryConfiguration)

Declaration
public void UpdateConfig(QueryConfiguration config)
Parameters
Type Name Description
QueryConfiguration config

Implements