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.ExecuteScalar()

DbTask.ExecuteScalarAsync()

DbTask.ExecuteScalar<T>()

DbTask.ExecuteScalarAsync<T>()

DbTask.ExecuteReader()

DbTask.ExecuteReaderAsync()

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, Func<IConnectionManager, Task>)

DbTask.LogErrorsAndCloseCoreAsync(string, Action<IConnectionManager>, Func<IConnectionManager, Task>, bool)

ControlFlowTask.ConnectionManager

ControlFlowTask.ConnectionType

ControlFlowTask.QB

ControlFlowTask.QE

LoggableTask.TaskType

LoggableTask.DisableLogging

LoggableTask.TaskHash

LoggableTask.CopyLogTaskProperties(ILoggableTask)

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Namespace: ETLBox.ControlFlow

Assembly: ETLBox.dll

Syntax

    public sealed class SqlTask : DbTask, ILoggableTask

Examples

SqlTask.ExecuteNonQuery("Description","insert into demo.table1 select * from demo.table2");

Constructors

SqlTask()

Declaration

    public SqlTask()

Examples

SqlTask.ExecuteNonQuery("Description","insert into demo.table1 select * from demo.table2");

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

Declaration

    public SqlTask(string sql, Action beforeRowReadAction, Action afterRowReadAction, params Action<object>[] actions)

Parameters

Type	Name	Description
string	sql
System.Action	beforeRowReadAction
System.Action	afterRowReadAction
System.Action<T><object>[]	actions

Examples

SqlTask.ExecuteNonQuery("Description","insert into demo.table1 select * from demo.table2");

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

Declaration

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

Parameters

Type	Name	Description
string	sql
System.Action<T><object>[]	actions

Examples

SqlTask.ExecuteNonQuery("Description","insert into demo.table1 select * from demo.table2");

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

Declaration

    public SqlTask(string sql, IEnumerable<QueryParameter> parameter, Action beforeRowReadAction, Action afterRowReadAction, params Action<object>[] actions)

Parameters

Type	Name	Description
string	sql
System.Collections.Generic.IEnumerable<T><QueryParameter>	parameter
System.Action	beforeRowReadAction
System.Action	afterRowReadAction
System.Action<T><object>[]	actions

Examples

SqlTask.ExecuteNonQuery("Description","insert into demo.table1 select * from demo.table2");

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

Declaration

    public SqlTask(string sql, IEnumerable<QueryParameter> parameter, params Action<object>[] actions)

Parameters

Type	Name	Description
string	sql
System.Collections.Generic.IEnumerable<T><QueryParameter>	parameter
System.Action<T><object>[]	actions

Examples

SqlTask.ExecuteNonQuery("Description","insert into demo.table1 select * from demo.table2");

SqlTask(string, IEnumerable<QueryParameter>)

Declaration

    public SqlTask(string sql, IEnumerable<QueryParameter> parameter)

Parameters

Type	Name	Description
string	sql
System.Collections.Generic.IEnumerable<T><QueryParameter>	parameter

Examples

SqlTask.ExecuteNonQuery("Description","insert into demo.table1 select * from demo.table2");

SqlTask(string, string)

Declaration

    public SqlTask(string name, string sql)

Parameters

Type	Name	Description
string	name
string	sql

Examples

SqlTask.ExecuteNonQuery("Description","insert into demo.table1 select * from demo.table2");

SqlTask(string)

Declaration

    public SqlTask(string sql)

Parameters

Type	Name	Description
string	sql	Sets the Sql

Properties

TaskName

A name to identify the task or component. Every component or task comes with a default name that can be overwritten.

Declaration

    public override string TaskName { get; set; }

Property Value

Type	Description
string

Overrides

LoggableTask.TaskName

Methods

BulkDelete(IConnectionManager, ITableData)

Declaration

    public static void BulkDelete(IConnectionManager connectionManager, ITableData data)

Parameters

Type	Name	Description
IConnectionManager	connectionManager
ITableData	data

Examples

SqlTask.ExecuteNonQuery("Description","insert into demo.table1 select * from demo.table2");

BulkDelete(string, ITableData)

Declaration

    public static void BulkDelete(string name, ITableData data)

Parameters

Type	Name	Description
string	name
ITableData	data

Examples

SqlTask.ExecuteNonQuery("Description","insert into demo.table1 select * from demo.table2");

BulkInsert(IConnectionManager, ITableData)

Declaration

    public static void BulkInsert(IConnectionManager connectionManager, ITableData data)

Parameters

Type	Name	Description
IConnectionManager	connectionManager
ITableData	data

Examples

SqlTask.ExecuteNonQuery("Description","insert into demo.table1 select * from demo.table2");

BulkInsert(string, ITableData)

Declaration

    public static void BulkInsert(string name, ITableData data)

Parameters

Type	Name	Description
string	name
ITableData	data

Examples

SqlTask.ExecuteNonQuery("Description","insert into demo.table1 select * from demo.table2");

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

Declaration

    public static void BulkUpdate(IConnectionManager connectionManager, ITableData data, ICollection<string> setColumnNames, ICollection<string> joinColumnNames)

Parameters

Type	Name	Description
IConnectionManager	connectionManager
ITableData	data
System.Collections.Generic.ICollection<T><string>	setColumnNames
System.Collections.Generic.ICollection<T><string>	joinColumnNames

Examples

SqlTask.ExecuteNonQuery("Description","insert into demo.table1 select * from demo.table2");

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

Declaration

    public static void BulkUpdate(string name, ITableData data, ICollection<string> setColumnNames, ICollection<string> joinColumnNames)

Parameters

Type	Name	Description
string	name
ITableData	data
System.Collections.Generic.ICollection<T><string>	setColumnNames
System.Collections.Generic.ICollection<T><string>	joinColumnNames

Examples

SqlTask.ExecuteNonQuery("Description","insert into demo.table1 select * from demo.table2");

ExecuteNonQuery(IConnectionManager, string, IEnumerable<QueryParameter>)

Declaration

    public static int ExecuteNonQuery(IConnectionManager connectionManager, string sql, IEnumerable<QueryParameter> parameterList)

Parameters

Type	Name	Description
IConnectionManager	connectionManager
string	sql
System.Collections.Generic.IEnumerable<T><QueryParameter>	parameterList

Returns

Type	Description
int

Examples

SqlTask.ExecuteNonQuery("Description","insert into demo.table1 select * from demo.table2");

ExecuteNonQuery(IConnectionManager, string)

Declaration

    public static int ExecuteNonQuery(IConnectionManager connectionManager, string sql)

Parameters

Type	Name	Description
IConnectionManager	connectionManager
string	sql

Returns

Type	Description
int

Examples

SqlTask.ExecuteNonQuery("Description","insert into demo.table1 select * from demo.table2");

ExecuteNonQuery(string, IEnumerable<QueryParameter>)

Declaration

    public static int ExecuteNonQuery(string sql, IEnumerable<QueryParameter> parameterList)

Parameters

Type	Name	Description
string	sql
System.Collections.Generic.IEnumerable<T><QueryParameter>	parameterList

Returns

Type	Description
int

Examples

SqlTask.ExecuteNonQuery("Description","insert into demo.table1 select * from demo.table2");

ExecuteNonQuery(string)

Declaration

    public static int ExecuteNonQuery(string sql)

Parameters

Type	Name	Description
string	sql

Returns

Type	Description
int

Examples

SqlTask.ExecuteNonQuery("Description","insert into demo.table1 select * from demo.table2");

ExecuteNonQueryAsync(IConnectionManager, string, IEnumerable<QueryParameter>)

Declaration

    public static Task<int> ExecuteNonQueryAsync(IConnectionManager connectionManager, string sql, IEnumerable<QueryParameter> parameterList)

Parameters

Type	Name	Description
IConnectionManager	connectionManager
string	sql
System.Collections.Generic.IEnumerable<T><QueryParameter>	parameterList

Returns

Type	Description
System.Threading.Tasks.Task<TResult><int>

Examples

SqlTask.ExecuteNonQuery("Description","insert into demo.table1 select * from demo.table2");

ExecuteNonQueryAsync(IConnectionManager, string)

Declaration

    public static Task<int> ExecuteNonQueryAsync(IConnectionManager connectionManager, string sql)

Parameters

Type	Name	Description
IConnectionManager	connectionManager
string	sql

Returns

Type	Description
System.Threading.Tasks.Task<TResult><int>

Examples

SqlTask.ExecuteNonQuery("Description","insert into demo.table1 select * from demo.table2");

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

Declaration

    public static void ExecuteReader(IConnectionManager connectionManager, string sql, Action beforeRowReadAction, Action afterRowReadAction, params Action<object>[] actions)

Parameters

Type	Name	Description
IConnectionManager	connectionManager
string	sql
System.Action	beforeRowReadAction
System.Action	afterRowReadAction
System.Action<T><object>[]	actions

Examples

SqlTask.ExecuteNonQuery("Description","insert into demo.table1 select * from demo.table2");

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

Declaration

    public static void ExecuteReader(IConnectionManager connectionManager, string sql, params Action<object>[] actions)

Parameters

Type	Name	Description
IConnectionManager	connectionManager
string	sql
System.Action<T><object>[]	actions

Examples

SqlTask.ExecuteNonQuery("Description","insert into demo.table1 select * from demo.table2");

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

Declaration

    public static void ExecuteReader(IConnectionManager connectionManager, string sql, IEnumerable<QueryParameter> parameterList, Action beforeRowReadAction, Action afterRowReadAction, params Action<object>[] actions)

Parameters

Type	Name	Description
IConnectionManager	connectionManager
string	sql
System.Collections.Generic.IEnumerable<T><QueryParameter>	parameterList
System.Action	beforeRowReadAction
System.Action	afterRowReadAction
System.Action<T><object>[]	actions

Examples

SqlTask.ExecuteNonQuery("Description","insert into demo.table1 select * from demo.table2");

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

Declaration

    public static void ExecuteReader(IConnectionManager connectionManager, string sql, IEnumerable<QueryParameter> parameterList, params Action<object>[] actions)

Parameters

Type	Name	Description
IConnectionManager	connectionManager
string	sql
System.Collections.Generic.IEnumerable<T><QueryParameter>	parameterList
System.Action<T><object>[]	actions

Examples

SqlTask.ExecuteNonQuery("Description","insert into demo.table1 select * from demo.table2");

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

Declaration

    public static void ExecuteReader(string sql, Action beforeRowReadAction, Action afterRowReadAction, params Action<object>[] actions)

Parameters

Type	Name	Description
string	sql
System.Action	beforeRowReadAction
System.Action	afterRowReadAction
System.Action<T><object>[]	actions

Examples

SqlTask.ExecuteNonQuery("Description","insert into demo.table1 select * from demo.table2");

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

Declaration

    public static void ExecuteReader(string sql, params Action<object>[] actions)

Parameters

Type	Name	Description
string	sql
System.Action<T><object>[]	actions

Examples

SqlTask.ExecuteNonQuery("Description","insert into demo.table1 select * from demo.table2");

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

Declaration

    public static void ExecuteReader(string sql, IEnumerable<QueryParameter> parameterList, Action beforeRowReadAction, Action afterRowReadAction, params Action<object>[] actions)

Parameters

Type	Name	Description
string	sql
System.Collections.Generic.IEnumerable<T><QueryParameter>	parameterList
System.Action	beforeRowReadAction
System.Action	afterRowReadAction
System.Action<T><object>[]	actions

Examples

SqlTask.ExecuteNonQuery("Description","insert into demo.table1 select * from demo.table2");

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

Declaration

    public static void ExecuteReader(string sql, IEnumerable<QueryParameter> parameterList, params Action<object>[] actions)

Parameters

Type	Name	Description
string	sql
System.Collections.Generic.IEnumerable<T><QueryParameter>	parameterList
System.Action<T><object>[]	actions

Examples

SqlTask.ExecuteNonQuery("Description","insert into demo.table1 select * from demo.table2");

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

Declaration

    public static Task ExecuteReaderAsync(IConnectionManager connectionManager, string sql, Action beforeRowReadAction, Action afterRowReadAction, params Action<object>[] actions)

Parameters

Type	Name	Description
IConnectionManager	connectionManager
string	sql
System.Action	beforeRowReadAction
System.Action	afterRowReadAction
System.Action<T><object>[]	actions

Returns

Type	Description
System.Threading.Tasks.Task

Examples

SqlTask.ExecuteNonQuery("Description","insert into demo.table1 select * from demo.table2");

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

Declaration

    public static Task ExecuteReaderAsync(IConnectionManager connectionManager, string sql, params Action<object>[] actions)

Parameters

Type	Name	Description
IConnectionManager	connectionManager
string	sql
System.Action<T><object>[]	actions

Returns

Type	Description
System.Threading.Tasks.Task

Examples

SqlTask.ExecuteNonQuery("Description","insert into demo.table1 select * from demo.table2");

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

Declaration

    public static Task ExecuteReaderAsync(IConnectionManager connectionManager, string sql, IEnumerable<QueryParameter> parameterList, Action beforeRowReadAction, Action afterRowReadAction, params Action<object>[] actions)

Parameters

Type	Name	Description
IConnectionManager	connectionManager
string	sql
System.Collections.Generic.IEnumerable<T><QueryParameter>	parameterList
System.Action	beforeRowReadAction
System.Action	afterRowReadAction
System.Action<T><object>[]	actions

Returns

Type	Description
System.Threading.Tasks.Task

Examples

SqlTask.ExecuteNonQuery("Description","insert into demo.table1 select * from demo.table2");

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

Declaration

    public static Task ExecuteReaderAsync(IConnectionManager connectionManager, string sql, IEnumerable<QueryParameter> parameterList, params Action<object>[] actions)

Parameters

Type	Name	Description
IConnectionManager	connectionManager
string	sql
System.Collections.Generic.IEnumerable<T><QueryParameter>	parameterList
System.Action<T><object>[]	actions

Returns

Type	Description
System.Threading.Tasks.Task

Examples

SqlTask.ExecuteNonQuery("Description","insert into demo.table1 select * from demo.table2");

ExecuteScalar(IConnectionManager, string, IEnumerable<QueryParameter>)

Declaration

    public static object ExecuteScalar(IConnectionManager connectionManager, string sql, IEnumerable<QueryParameter> parameterList)

Parameters

Type	Name	Description
IConnectionManager	connectionManager
string	sql
System.Collections.Generic.IEnumerable<T><QueryParameter>	parameterList

Returns

Type	Description
object

Examples

SqlTask.ExecuteNonQuery("Description","insert into demo.table1 select * from demo.table2");

ExecuteScalar(IConnectionManager, string)

Declaration

    public static object ExecuteScalar(IConnectionManager connectionManager, string sql)

Parameters

Type	Name	Description
IConnectionManager	connectionManager
string	sql

Returns

Type	Description
object

Examples

SqlTask.ExecuteNonQuery("Description","insert into demo.table1 select * from demo.table2");

ExecuteScalar(string, IEnumerable<QueryParameter>)

Declaration

    public static object ExecuteScalar(string sql, IEnumerable<QueryParameter> parameterList)

Parameters

Type	Name	Description
string	sql
System.Collections.Generic.IEnumerable<T><QueryParameter>	parameterList

Returns

Type	Description
object

Examples

SqlTask.ExecuteNonQuery("Description","insert into demo.table1 select * from demo.table2");

ExecuteScalar(string)

Declaration

    public static object ExecuteScalar(string sql)

Parameters

Type	Name	Description
string	sql

Returns

Type	Description
object

Examples

SqlTask.ExecuteNonQuery("Description","insert into demo.table1 select * from demo.table2");

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

Declaration

    public static T ExecuteScalar<T>(IConnectionManager connectionManager, string sql, IEnumerable<QueryParameter> parameterList)

Parameters

Type	Name	Description
IConnectionManager	connectionManager
string	sql
System.Collections.Generic.IEnumerable<T><QueryParameter>	parameterList

Returns

Type	Description
T

Type Parameters

Name	Description
T

Examples

SqlTask.ExecuteNonQuery("Description","insert into demo.table1 select * from demo.table2");

ExecuteScalar<T>(IConnectionManager, string)

Declaration

    public static T ExecuteScalar<T>(IConnectionManager connectionManager, string sql)

Parameters

Type	Name	Description
IConnectionManager	connectionManager
string	sql

Returns

Type	Description
T

Type Parameters

Name	Description
T

Examples

SqlTask.ExecuteNonQuery("Description","insert into demo.table1 select * from demo.table2");

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

Declaration

    public static T ExecuteScalar<T>(string sql, IEnumerable<QueryParameter> parameterList)

Parameters

Type	Name	Description
string	sql
System.Collections.Generic.IEnumerable<T><QueryParameter>	parameterList

Returns

Type	Description
T

Type Parameters

Name	Description
T

Examples

SqlTask.ExecuteNonQuery("Description","insert into demo.table1 select * from demo.table2");

ExecuteScalar<T>(string)

Declaration

    public static T ExecuteScalar<T>(string sql)

Parameters

Type	Name	Description
string	sql

Returns

Type	Description
T

Type Parameters

Name	Description
T

Examples

SqlTask.ExecuteNonQuery("Description","insert into demo.table1 select * from demo.table2");

ExecuteScalarAsync(IConnectionManager, string, IEnumerable<QueryParameter>)

Declaration

    public static Task<object> ExecuteScalarAsync(IConnectionManager connectionManager, string sql, IEnumerable<QueryParameter> parameterList)

Parameters

Type	Name	Description
IConnectionManager	connectionManager
string	sql
System.Collections.Generic.IEnumerable<T><QueryParameter>	parameterList

Returns

Type	Description
System.Threading.Tasks.Task<TResult><object>

Examples

SqlTask.ExecuteNonQuery("Description","insert into demo.table1 select * from demo.table2");

ExecuteScalarAsync(IConnectionManager, string)

Declaration

    public static Task<object> ExecuteScalarAsync(IConnectionManager connectionManager, string sql)

Parameters

Type	Name	Description
IConnectionManager	connectionManager
string	sql

Returns

Type	Description
System.Threading.Tasks.Task<TResult><object>

Examples

SqlTask.ExecuteNonQuery("Description","insert into demo.table1 select * from demo.table2");

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

Declaration

    public static Task<T> ExecuteScalarAsync<T>(IConnectionManager connectionManager, string sql, IEnumerable<QueryParameter> parameterList)

Parameters

Type	Name	Description
IConnectionManager	connectionManager
string	sql
System.Collections.Generic.IEnumerable<T><QueryParameter>	parameterList

Returns

Type	Description
System.Threading.Tasks.Task<TResult><T>

Type Parameters

Name	Description
T

Examples

SqlTask.ExecuteNonQuery("Description","insert into demo.table1 select * from demo.table2");

ExecuteScalarAsync<T>(IConnectionManager, string)

Declaration

    public static Task<T> ExecuteScalarAsync<T>(IConnectionManager connectionManager, string sql)

Parameters

Type	Name	Description
IConnectionManager	connectionManager
string	sql

Returns

Type	Description
System.Threading.Tasks.Task<TResult><T>

Type Parameters

Name	Description
T

Examples

SqlTask.ExecuteNonQuery("Description","insert into demo.table1 select * from demo.table2");

Implements

ILoggableTask