# SqlTask {{< rawhtml >}}

Class SqlTask

Executes any sql on the database. Use ExecuteNonQuery for SQL statements returning no data, ExecuteScalar for statements that return only one row and one column or ExecuteReader for SQL that returns multiple rows or columns

Inheritance
object
LoggableTask
ControlFlowTask
DbTask
SqlTask
Implements
ILoggableTask
Inherited Members
DbTask.Sql
DbTask.Actions
DbTask.BeforeRowReadAction
DbTask.AfterRowReadAction
DbTask.Limit
DbTask.RowsAffected
DbTask.Parameter
DbTask.ExecuteNonQuery()
DbTask.ExecuteNonQueryAsync()
DbTask.ExecuteNonQueryAsync(CancellationToken?)
DbTask.ExecuteScalar()
DbTask.ExecuteScalarAsync()
DbTask.ExecuteScalarAsync(CancellationToken?)
DbTask.ExecuteScalar<T>()
DbTask.ExecuteScalarAsync<T>()
DbTask.ExecuteScalarAsync<T>(CancellationToken?)
DbTask.ExecuteReader()
DbTask.ExecuteReaderAsync()
DbTask.ExecuteReaderAsync(CancellationToken?)
DbTask.BulkInsert(ITableData)
DbTask.BulkDelete(ITableData)
DbTask.BulkUpdate(ITableData, ICollection<string>, ICollection<string>)
DbTask.BulkSelect(ITableData, ICollection<string>)
DbTask.LogErrorsAndClose(string, Action<IConnectionManager>)
DbTask.LogErrorsAndCloseAsync(string, CancellationToken?, Func<IConnectionManager, Task>)
DbTask.LogErrorsAndCloseCoreAsync(string, CancellationToken?, Action<IConnectionManager>, Func<IConnectionManager, Task>, bool)
ControlFlowTask.ConnectionManager
ControlFlowTask.ConnectionType
ControlFlowTask.QB
ControlFlowTask.QE
LoggableTask.TaskType
LoggableTask.TaskName
LoggableTask.DisableLogging
LoggableTask.LogThreshold
LoggableTask.TaskHash
LoggableTask.LogInstance
LoggableTask.ParentTask
object.Equals(object)
object.Equals(object, object)
object.GetHashCode()
object.GetType()
object.ReferenceEquals(object, object)
object.ToString()
Namespace: ETLBox.ControlFlow
Assembly: ETLBox.dll
Syntax
{{< /rawhtml >}} ```C# public sealed class SqlTask : DbTask, ILoggableTask ``` {{< rawhtml >}}
Examples
SqlTask.ExecuteNonQuery("Description","insert into demo.table1 select * from demo.table2");

Constructors

SqlTask()

Declaration
{{< /rawhtml >}} ```C# public SqlTask() ``` {{< rawhtml >}}

SqlTask(string)

Declaration
{{< /rawhtml >}} ```C# public SqlTask(string sql) ``` {{< rawhtml >}}
Parameters
Type Name Description
string sql

Sets the Sql

SqlTask(string, Action, Action, params Action<object>[])

Declaration
{{< /rawhtml >}} ```C# public SqlTask(string sql, Action beforeRowReadAction, Action afterRowReadAction, params Action[] actions) ``` {{< rawhtml >}}
Parameters
Type Name Description
string sql
Action beforeRowReadAction
Action afterRowReadAction
Action<object>[] actions

SqlTask(string, params Action<object>[])

Declaration
{{< /rawhtml >}} ```C# public SqlTask(string sql, params Action[] actions) ``` {{< rawhtml >}}
Parameters
Type Name Description
string sql
Action<object>[] actions

SqlTask(string, IEnumerable<QueryParameter>)

Declaration
{{< /rawhtml >}} ```C# public SqlTask(string sql, IEnumerable parameter) ``` {{< rawhtml >}}
Parameters
Type Name Description
string sql
IEnumerable<QueryParameter> parameter

SqlTask(string, IEnumerable<QueryParameter>, Action, Action, params Action<object>[])

Declaration
{{< /rawhtml >}} ```C# public SqlTask(string sql, IEnumerable parameter, Action beforeRowReadAction, Action afterRowReadAction, params Action[] actions) ``` {{< rawhtml >}}
Parameters
Type Name Description
string sql
IEnumerable<QueryParameter> parameter
Action beforeRowReadAction
Action afterRowReadAction
Action<object>[] actions

SqlTask(string, IEnumerable<QueryParameter>, params Action<object>[])

Declaration
{{< /rawhtml >}} ```C# public SqlTask(string sql, IEnumerable parameter, params Action[] actions) ``` {{< rawhtml >}}
Parameters
Type Name Description
string sql
IEnumerable<QueryParameter> parameter
Action<object>[] actions

Methods

BulkDelete(IConnectionManager, ITableData)

Declaration
{{< /rawhtml >}} ```C# public static void BulkDelete(IConnectionManager connectionManager, ITableData data) ``` {{< rawhtml >}}
Parameters
Type Name Description
IConnectionManager connectionManager
ITableData data

BulkDelete(string, ITableData)

Declaration
{{< /rawhtml >}} ```C# public static void BulkDelete(string name, ITableData data) ``` {{< rawhtml >}}
Parameters
Type Name Description
string name
ITableData data

BulkInsert(IConnectionManager, ITableData)

Declaration
{{< /rawhtml >}} ```C# public static void BulkInsert(IConnectionManager connectionManager, ITableData data) ``` {{< rawhtml >}}
Parameters
Type Name Description
IConnectionManager connectionManager
ITableData data

BulkInsert(string, ITableData)

Declaration
{{< /rawhtml >}} ```C# public static void BulkInsert(string name, ITableData data) ``` {{< rawhtml >}}
Parameters
Type Name Description
string name
ITableData data

BulkUpdate(IConnectionManager, ITableData, ICollection<string>, ICollection<string>)

Declaration
{{< /rawhtml >}} ```C# public static void BulkUpdate(IConnectionManager connectionManager, ITableData data, ICollection setColumnNames, ICollection joinColumnNames) ``` {{< rawhtml >}}
Parameters
Type Name Description
IConnectionManager connectionManager
ITableData data
ICollection<string> setColumnNames
ICollection<string> joinColumnNames

BulkUpdate(string, ITableData, ICollection<string>, ICollection<string>)

Declaration
{{< /rawhtml >}} ```C# public static void BulkUpdate(string name, ITableData data, ICollection setColumnNames, ICollection joinColumnNames) ``` {{< rawhtml >}}
Parameters
Type Name Description
string name
ITableData data
ICollection<string> setColumnNames
ICollection<string> joinColumnNames

ExecuteNonQuery(IConnectionManager, string)

Declaration
{{< /rawhtml >}} ```C# public static int ExecuteNonQuery(IConnectionManager connectionManager, string sql) ``` {{< rawhtml >}}
Parameters
Type Name Description
IConnectionManager connectionManager
string sql
Returns
Type Description
int

ExecuteNonQuery(IConnectionManager, string, IEnumerable<QueryParameter>)

Declaration
{{< /rawhtml >}} ```C# public static int ExecuteNonQuery(IConnectionManager connectionManager, string sql, IEnumerable parameterList) ``` {{< rawhtml >}}
Parameters
Type Name Description
IConnectionManager connectionManager
string sql
IEnumerable<QueryParameter> parameterList
Returns
Type Description
int

ExecuteNonQuery(string)

Declaration
{{< /rawhtml >}} ```C# public static int ExecuteNonQuery(string sql) ``` {{< rawhtml >}}
Parameters
Type Name Description
string sql
Returns
Type Description
int

ExecuteNonQuery(string, IEnumerable<QueryParameter>)

Declaration
{{< /rawhtml >}} ```C# public static int ExecuteNonQuery(string sql, IEnumerable parameterList) ``` {{< rawhtml >}}
Parameters
Type Name Description
string sql
IEnumerable<QueryParameter> parameterList
Returns
Type Description
int

ExecuteNonQueryAsync(IConnectionManager, string)

Declaration
{{< /rawhtml >}} ```C# public static Task ExecuteNonQueryAsync(IConnectionManager connectionManager, string sql) ``` {{< rawhtml >}}
Parameters
Type Name Description
IConnectionManager connectionManager
string sql
Returns
Type Description
Task<int>

ExecuteNonQueryAsync(IConnectionManager, string, IEnumerable<QueryParameter>)

Declaration
{{< /rawhtml >}} ```C# public static Task ExecuteNonQueryAsync(IConnectionManager connectionManager, string sql, IEnumerable parameterList) ``` {{< rawhtml >}}
Parameters
Type Name Description
IConnectionManager connectionManager
string sql
IEnumerable<QueryParameter> parameterList
Returns
Type Description
Task<int>

ExecuteNonQueryAsync(IConnectionManager, string, IEnumerable<QueryParameter>, CancellationToken)

Declaration
{{< /rawhtml >}} ```C# public static Task ExecuteNonQueryAsync(IConnectionManager connectionManager, string sql, IEnumerable parameterList, CancellationToken cancellationToken) ``` {{< rawhtml >}}
Parameters
Type Name Description
IConnectionManager connectionManager
string sql
IEnumerable<QueryParameter> parameterList
CancellationToken cancellationToken
Returns
Type Description
Task<int>

ExecuteNonQueryAsync(IConnectionManager, string, CancellationToken)

Declaration
{{< /rawhtml >}} ```C# public static Task ExecuteNonQueryAsync(IConnectionManager connectionManager, string sql, CancellationToken cancellationToken) ``` {{< rawhtml >}}
Parameters
Type Name Description
IConnectionManager connectionManager
string sql
CancellationToken cancellationToken
Returns
Type Description
Task<int>

ExecuteReader(IConnectionManager, string, Action, Action, params Action<object>[])

Declaration
{{< /rawhtml >}} ```C# public static void ExecuteReader(IConnectionManager connectionManager, string sql, Action beforeRowReadAction, Action afterRowReadAction, params Action[] actions) ``` {{< rawhtml >}}
Parameters
Type Name Description
IConnectionManager connectionManager
string sql
Action beforeRowReadAction
Action afterRowReadAction
Action<object>[] actions

ExecuteReader(IConnectionManager, string, params Action<object>[])

Declaration
{{< /rawhtml >}} ```C# public static void ExecuteReader(IConnectionManager connectionManager, string sql, params Action[] actions) ``` {{< rawhtml >}}
Parameters
Type Name Description
IConnectionManager connectionManager
string sql
Action<object>[] actions

ExecuteReader(IConnectionManager, string, IEnumerable<QueryParameter>, Action, Action, params Action<object>[])

Declaration
{{< /rawhtml >}} ```C# public static void ExecuteReader(IConnectionManager connectionManager, string sql, IEnumerable parameterList, Action beforeRowReadAction, Action afterRowReadAction, params Action[] actions) ``` {{< rawhtml >}}
Parameters
Type Name Description
IConnectionManager connectionManager
string sql
IEnumerable<QueryParameter> parameterList
Action beforeRowReadAction
Action afterRowReadAction
Action<object>[] actions

ExecuteReader(IConnectionManager, string, IEnumerable<QueryParameter>, params Action<object>[])

Declaration
{{< /rawhtml >}} ```C# public static void ExecuteReader(IConnectionManager connectionManager, string sql, IEnumerable parameterList, params Action[] actions) ``` {{< rawhtml >}}
Parameters
Type Name Description
IConnectionManager connectionManager
string sql
IEnumerable<QueryParameter> parameterList
Action<object>[] actions

ExecuteReader(string, Action, Action, params Action<object>[])

Declaration
{{< /rawhtml >}} ```C# public static void ExecuteReader(string sql, Action beforeRowReadAction, Action afterRowReadAction, params Action[] actions) ``` {{< rawhtml >}}
Parameters
Type Name Description
string sql
Action beforeRowReadAction
Action afterRowReadAction
Action<object>[] actions

ExecuteReader(string, params Action<object>[])

Declaration
{{< /rawhtml >}} ```C# public static void ExecuteReader(string sql, params Action[] actions) ``` {{< rawhtml >}}
Parameters
Type Name Description
string sql
Action<object>[] actions

ExecuteReader(string, IEnumerable<QueryParameter>, Action, Action, params Action<object>[])

Declaration
{{< /rawhtml >}} ```C# public static void ExecuteReader(string sql, IEnumerable parameterList, Action beforeRowReadAction, Action afterRowReadAction, params Action[] actions) ``` {{< rawhtml >}}
Parameters
Type Name Description
string sql
IEnumerable<QueryParameter> parameterList
Action beforeRowReadAction
Action afterRowReadAction
Action<object>[] actions

ExecuteReader(string, IEnumerable<QueryParameter>, params Action<object>[])

Declaration
{{< /rawhtml >}} ```C# public static void ExecuteReader(string sql, IEnumerable parameterList, params Action[] actions) ``` {{< rawhtml >}}
Parameters
Type Name Description
string sql
IEnumerable<QueryParameter> parameterList
Action<object>[] actions

ExecuteReaderAsync(IConnectionManager, string, Action, Action, params Action<object>[])

Declaration
{{< /rawhtml >}} ```C# public static Task ExecuteReaderAsync(IConnectionManager connectionManager, string sql, Action beforeRowReadAction, Action afterRowReadAction, params Action[] actions) ``` {{< rawhtml >}}
Parameters
Type Name Description
IConnectionManager connectionManager
string sql
Action beforeRowReadAction
Action afterRowReadAction
Action<object>[] actions
Returns
Type Description
Task

ExecuteReaderAsync(IConnectionManager, string, params Action<object>[])

Declaration
{{< /rawhtml >}} ```C# public static Task ExecuteReaderAsync(IConnectionManager connectionManager, string sql, params Action[] actions) ``` {{< rawhtml >}}
Parameters
Type Name Description
IConnectionManager connectionManager
string sql
Action<object>[] actions
Returns
Type Description
Task

ExecuteReaderAsync(IConnectionManager, string, IEnumerable<QueryParameter>, Action, Action, params Action<object>[])

Declaration
{{< /rawhtml >}} ```C# public static Task ExecuteReaderAsync(IConnectionManager connectionManager, string sql, IEnumerable parameterList, Action beforeRowReadAction, Action afterRowReadAction, params Action[] actions) ``` {{< rawhtml >}}
Parameters
Type Name Description
IConnectionManager connectionManager
string sql
IEnumerable<QueryParameter> parameterList
Action beforeRowReadAction
Action afterRowReadAction
Action<object>[] actions
Returns
Type Description
Task

ExecuteReaderAsync(IConnectionManager, string, IEnumerable<QueryParameter>, params Action<object>[])

Declaration
{{< /rawhtml >}} ```C# public static Task ExecuteReaderAsync(IConnectionManager connectionManager, string sql, IEnumerable parameterList, params Action[] actions) ``` {{< rawhtml >}}
Parameters
Type Name Description
IConnectionManager connectionManager
string sql
IEnumerable<QueryParameter> parameterList
Action<object>[] actions
Returns
Type Description
Task

ExecuteReaderAsync(IConnectionManager, string, IEnumerable<QueryParameter>, CancellationToken, Action, Action, params Action<object>[])

Declaration
{{< /rawhtml >}} ```C# public static Task ExecuteReaderAsync(IConnectionManager connectionManager, string sql, IEnumerable parameterList, CancellationToken cancellationToken, Action beforeRowReadAction, Action afterRowReadAction, params Action[] actions) ``` {{< rawhtml >}}
Parameters
Type Name Description
IConnectionManager connectionManager
string sql
IEnumerable<QueryParameter> parameterList
CancellationToken cancellationToken
Action beforeRowReadAction
Action afterRowReadAction
Action<object>[] actions
Returns
Type Description
Task

ExecuteReaderAsync(IConnectionManager, string, IEnumerable<QueryParameter>, CancellationToken, params Action<object>[])

Declaration
{{< /rawhtml >}} ```C# public static Task ExecuteReaderAsync(IConnectionManager connectionManager, string sql, IEnumerable parameterList, CancellationToken cancellationToken, params Action[] actions) ``` {{< rawhtml >}}
Parameters
Type Name Description
IConnectionManager connectionManager
string sql
IEnumerable<QueryParameter> parameterList
CancellationToken cancellationToken
Action<object>[] actions
Returns
Type Description
Task

ExecuteReaderAsync(IConnectionManager, string, CancellationToken, Action, Action, params Action<object>[])

Declaration
{{< /rawhtml >}} ```C# public static Task ExecuteReaderAsync(IConnectionManager connectionManager, string sql, CancellationToken cancellationToken, Action beforeRowReadAction, Action afterRowReadAction, params Action[] actions) ``` {{< rawhtml >}}
Parameters
Type Name Description
IConnectionManager connectionManager
string sql
CancellationToken cancellationToken
Action beforeRowReadAction
Action afterRowReadAction
Action<object>[] actions
Returns
Type Description
Task

ExecuteReaderAsync(IConnectionManager, string, CancellationToken, params Action<object>[])

Declaration
{{< /rawhtml >}} ```C# public static Task ExecuteReaderAsync(IConnectionManager connectionManager, string sql, CancellationToken cancellationToken, params Action[] actions) ``` {{< rawhtml >}}
Parameters
Type Name Description
IConnectionManager connectionManager
string sql
CancellationToken cancellationToken
Action<object>[] actions
Returns
Type Description
Task

ExecuteScalar(IConnectionManager, string)

Declaration
{{< /rawhtml >}} ```C# public static object ExecuteScalar(IConnectionManager connectionManager, string sql) ``` {{< rawhtml >}}
Parameters
Type Name Description
IConnectionManager connectionManager
string sql
Returns
Type Description
object

ExecuteScalar(IConnectionManager, string, IEnumerable<QueryParameter>)

Declaration
{{< /rawhtml >}} ```C# public static object ExecuteScalar(IConnectionManager connectionManager, string sql, IEnumerable parameterList) ``` {{< rawhtml >}}
Parameters
Type Name Description
IConnectionManager connectionManager
string sql
IEnumerable<QueryParameter> parameterList
Returns
Type Description
object

ExecuteScalar(string)

Declaration
{{< /rawhtml >}} ```C# public static object ExecuteScalar(string sql) ``` {{< rawhtml >}}
Parameters
Type Name Description
string sql
Returns
Type Description
object

ExecuteScalar(string, IEnumerable<QueryParameter>)

Declaration
{{< /rawhtml >}} ```C# public static object ExecuteScalar(string sql, IEnumerable parameterList) ``` {{< rawhtml >}}
Parameters
Type Name Description
string sql
IEnumerable<QueryParameter> parameterList
Returns
Type Description
object

ExecuteScalarAsync(IConnectionManager, string)

Declaration
{{< /rawhtml >}} ```C# public static Task ExecuteScalarAsync(IConnectionManager connectionManager, string sql) ``` {{< rawhtml >}}
Parameters
Type Name Description
IConnectionManager connectionManager
string sql
Returns
Type Description
Task<object>

ExecuteScalarAsync(IConnectionManager, string, IEnumerable<QueryParameter>)

Declaration
{{< /rawhtml >}} ```C# public static Task ExecuteScalarAsync(IConnectionManager connectionManager, string sql, IEnumerable parameterList) ``` {{< rawhtml >}}
Parameters
Type Name Description
IConnectionManager connectionManager
string sql
IEnumerable<QueryParameter> parameterList
Returns
Type Description
Task<object>

ExecuteScalarAsync(IConnectionManager, string, IEnumerable<QueryParameter>, CancellationToken)

Declaration
{{< /rawhtml >}} ```C# public static Task ExecuteScalarAsync(IConnectionManager connectionManager, string sql, IEnumerable parameterList, CancellationToken cancellationToken) ``` {{< rawhtml >}}
Parameters
Type Name Description
IConnectionManager connectionManager
string sql
IEnumerable<QueryParameter> parameterList
CancellationToken cancellationToken
Returns
Type Description
Task<object>

ExecuteScalarAsync(IConnectionManager, string, CancellationToken)

Declaration
{{< /rawhtml >}} ```C# public static Task ExecuteScalarAsync(IConnectionManager connectionManager, string sql, CancellationToken cancellationToken) ``` {{< rawhtml >}}
Parameters
Type Name Description
IConnectionManager connectionManager
string sql
CancellationToken cancellationToken
Returns
Type Description
Task<object>

ExecuteScalarAsync<T>(IConnectionManager, string)

Declaration
{{< /rawhtml >}} ```C# public static Task ExecuteScalarAsync(IConnectionManager connectionManager, string sql) ``` {{< rawhtml >}}
Parameters
Type Name Description
IConnectionManager connectionManager
string sql
Returns
Type Description
Task<T>
Type Parameters
Name Description
T

ExecuteScalarAsync<T>(IConnectionManager, string, IEnumerable<QueryParameter>)

Declaration
{{< /rawhtml >}} ```C# public static Task ExecuteScalarAsync(IConnectionManager connectionManager, string sql, IEnumerable parameterList) ``` {{< rawhtml >}}
Parameters
Type Name Description
IConnectionManager connectionManager
string sql
IEnumerable<QueryParameter> parameterList
Returns
Type Description
Task<T>
Type Parameters
Name Description
T

ExecuteScalarAsync<T>(IConnectionManager, string, IEnumerable<QueryParameter>, CancellationToken)

Declaration
{{< /rawhtml >}} ```C# public static Task ExecuteScalarAsync(IConnectionManager connectionManager, string sql, IEnumerable parameterList, CancellationToken cancellationToken) ``` {{< rawhtml >}}
Parameters
Type Name Description
IConnectionManager connectionManager
string sql
IEnumerable<QueryParameter> parameterList
CancellationToken cancellationToken
Returns
Type Description
Task<T>
Type Parameters
Name Description
T

ExecuteScalarAsync<T>(IConnectionManager, string, CancellationToken)

Declaration
{{< /rawhtml >}} ```C# public static Task ExecuteScalarAsync(IConnectionManager connectionManager, string sql, CancellationToken cancellationToken) ``` {{< rawhtml >}}
Parameters
Type Name Description
IConnectionManager connectionManager
string sql
CancellationToken cancellationToken
Returns
Type Description
Task<T>
Type Parameters
Name Description
T

ExecuteScalar<T>(IConnectionManager, string)

Declaration
{{< /rawhtml >}} ```C# public static T ExecuteScalar(IConnectionManager connectionManager, string sql) ``` {{< rawhtml >}}
Parameters
Type Name Description
IConnectionManager connectionManager
string sql
Returns
Type Description
T
Type Parameters
Name Description
T

ExecuteScalar<T>(IConnectionManager, string, IEnumerable<QueryParameter>)

Declaration
{{< /rawhtml >}} ```C# public static T ExecuteScalar(IConnectionManager connectionManager, string sql, IEnumerable parameterList) ``` {{< rawhtml >}}
Parameters
Type Name Description
IConnectionManager connectionManager
string sql
IEnumerable<QueryParameter> parameterList
Returns
Type Description
T
Type Parameters
Name Description
T

ExecuteScalar<T>(string)

Declaration
{{< /rawhtml >}} ```C# public static T ExecuteScalar(string sql) ``` {{< rawhtml >}}
Parameters
Type Name Description
string sql
Returns
Type Description
T
Type Parameters
Name Description
T

ExecuteScalar<T>(string, IEnumerable<QueryParameter>)

Declaration
{{< /rawhtml >}} ```C# public static T ExecuteScalar(string sql, IEnumerable parameterList) ``` {{< rawhtml >}}
Parameters
Type Name Description
string sql
IEnumerable<QueryParameter> parameterList
Returns
Type Description
T
Type Parameters
Name Description
T

Implements

{{< /rawhtml >}}