Class DbTask

Implements
Inherited Members
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 abstract class DbTask : ControlFlowTask, ILoggableTask

Constructors

DbTask()

Declaration
    public DbTask()

DbTask(ControlFlowTask, string)

Declaration
    public DbTask(ControlFlowTask callingTask, string sql)
Parameters
TypeNameDescription
ControlFlowTaskcallingTask
stringsql

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

Declaration
    public DbTask(string sql, Action beforeRowReadAction, Action afterRowReadAction, params Action<object>[] actions)
Parameters
TypeNameDescription
stringsql
System.ActionbeforeRowReadAction
System.ActionafterRowReadAction
System.Action<T><object>[]actions

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

Declaration
    public DbTask(string sql, params Action<object>[] actions)
Parameters
TypeNameDescription
stringsql
System.Action<T><object>[]actions

DbTask(string, string)

Declaration
    public DbTask(string name, string sql)
Parameters
TypeNameDescription
stringname
stringsql

DbTask(string)

Declaration
    public DbTask(string sql)
Parameters
TypeNameDescription
stringsql

Properties

Actions

Declaration
    public ICollection<Action<object>> Actions { get; set; }
Property Value
TypeDescription
System.Collections.Generic.ICollection<T><System.Action<T><object>>

AfterRowReadAction

Declaration
    public Action AfterRowReadAction { get; set; }
Property Value
TypeDescription
System.Action

BeforeRowReadAction

Declaration
    public Action BeforeRowReadAction { get; set; }
Property Value
TypeDescription
System.Action

Limit

Declaration
    public int Limit { get; set; }
Property Value
TypeDescription
int

Parameter

Declaration
    public IEnumerable<QueryParameter> Parameter { get; set; }
Property Value
TypeDescription
System.Collections.Generic.IEnumerable<T><QueryParameter>

RowsAffected

Declaration
    public int? RowsAffected { get; }
Property Value
TypeDescription
int?

Sql

Declaration
    public string Sql { get; set; }
Property Value
TypeDescription
string

Methods

BulkDelete(ITableData)

Declaration
    public void BulkDelete(ITableData data)
Parameters
TypeNameDescription
ITableDatadata

BulkInsert(ITableData)

Declaration
    public void BulkInsert(ITableData data)
Parameters
TypeNameDescription
ITableDatadata

BulkSelect(ITableData, ICollection<string>)

Declaration
    public void BulkSelect(ITableData data, ICollection<string> selectColumnNames)
Parameters
TypeNameDescription
ITableDatadata
System.Collections.Generic.ICollection<T><string>selectColumnNames

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

Declaration
    public void BulkUpdate(ITableData data, ICollection<string> setColumnNames, ICollection<string> joinColumnNames)
Parameters
TypeNameDescription
ITableDatadata
System.Collections.Generic.ICollection<T><string>setColumnNames
System.Collections.Generic.ICollection<T><string>joinColumnNames

ExecuteNonQuery()

Declaration
    public int ExecuteNonQuery()
Returns
TypeDescription
int

ExecuteNonQueryAsync()

Declaration
    public Task<int> ExecuteNonQueryAsync()
Returns
TypeDescription
System.Threading.Tasks.Task<TResult><int>

ExecuteReader()

Declaration
    public void ExecuteReader()

ExecuteReaderAsync()

Declaration
    public Task ExecuteReaderAsync()
Returns
TypeDescription
System.Threading.Tasks.Task

ExecuteScalar()

Declaration
    public object ExecuteScalar()
Returns
TypeDescription
object

ExecuteScalar<T>()

Declaration
    public T ExecuteScalar<T>()
Returns
TypeDescription
T
Type Parameters
NameDescription
T

ExecuteScalarAsync()

Declaration
    public Task<object> ExecuteScalarAsync()
Returns
TypeDescription
System.Threading.Tasks.Task<TResult><object>

ExecuteScalarAsync<T>()

Declaration
    public Task<T> ExecuteScalarAsync<T>()
Returns
TypeDescription
System.Threading.Tasks.Task<TResult><T>
Type Parameters
NameDescription
T

LogErrorsAndClose(string, Action<IConnectionManager>)

Declaration
    public void LogErrorsAndClose(string sqlOperationType, Action<IConnectionManager> syncAction = null)
Parameters
TypeNameDescription
stringsqlOperationType
System.Action<T><IConnectionManager>syncAction

LogErrorsAndCloseAsync(string, Func<IConnectionManager, Task>)

Declaration
    public Task LogErrorsAndCloseAsync(string sqlOperationType, Func<IConnectionManager, Task> asyncAction = null)
Parameters
TypeNameDescription
stringsqlOperationType
System.Func<T, TResult><IConnectionManager, System.Threading.Tasks.Task>asyncAction
Returns
TypeDescription
System.Threading.Tasks.Task

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

Declaration
    public Task LogErrorsAndCloseCoreAsync(string sqlOperationType, Action<IConnectionManager> syncAction = null, Func<IConnectionManager, Task> asyncAction = null, bool sync = false)
Parameters
TypeNameDescription
stringsqlOperationType
System.Action<T><IConnectionManager>syncAction
System.Func<T, TResult><IConnectionManager, System.Threading.Tasks.Task>asyncAction
boolsync
Returns
TypeDescription
System.Threading.Tasks.Task

Implements