Class DbTask
Namespace: ETLBox.ControlFlow
Assembly: ETLBox.dll
Syntax
public abstract class DbTask : ControlFlowTask, ILoggableTask
Constructors
DbTask()
Declaration
DbTask(string)
Declaration
public DbTask(string sql)
Parameters
DbTask(string, Action, Action, params Action<object>[])
Declaration
public DbTask(string sql, Action beforeRowReadAction, Action afterRowReadAction, params Action<object>[] actions)
Parameters
DbTask(string, params Action<object>[])
Declaration
public DbTask(string sql, params Action<object>[] actions)
Parameters
DbTask(string, string)
Declaration
public DbTask(string name, string sql)
Parameters
Properties
Actions
Declaration
public ICollection<Action<object>> Actions { get; set; }
Property Value
AfterRowReadAction
Declaration
public Action AfterRowReadAction { get; set; }
Property Value
BeforeRowReadAction
Declaration
public Action BeforeRowReadAction { get; set; }
Property Value
Limit
Declaration
public int Limit { get; set; }
Property Value
Parameter
Declaration
public IEnumerable<QueryParameter> Parameter { get; set; }
Property Value
RowsAffected
Declaration
public int? RowsAffected { get; }
Property Value
Sql
Declaration
public string Sql { get; set; }
Property Value
Methods
BulkDelete(ITableData)
Declaration
public void BulkDelete(ITableData data)
Parameters
BulkInsert(ITableData)
Declaration
public void BulkInsert(ITableData data)
Parameters
BulkSelect(ITableData, ICollection<string>)
Declaration
public void BulkSelect(ITableData data, ICollection<string> selectColumnNames)
Parameters
BulkUpdate(ITableData, ICollection<string>, ICollection<string>)
Declaration
public void BulkUpdate(ITableData data, ICollection<string> setColumnNames, ICollection<string> joinColumnNames)
Parameters
ExecuteNonQuery()
Declaration
public int ExecuteNonQuery()
Returns
ExecuteNonQueryAsync()
Declaration
public Task<int> ExecuteNonQueryAsync()
Returns
ExecuteReader()
Declaration
public void ExecuteReader()
ExecuteReaderAsync()
Declaration
public Task ExecuteReaderAsync()
Returns
ExecuteScalar()
Declaration
public object ExecuteScalar()
Returns
ExecuteScalarAsync()
Declaration
public Task<object> ExecuteScalarAsync()
Returns
ExecuteScalarAsync<T>()
Declaration
public Task<T> ExecuteScalarAsync<T>()
Returns
Type Parameters
ExecuteScalar<T>()
Declaration
public T ExecuteScalar<T>()
Returns
Type Parameters
LogErrorsAndClose(string, Action<IConnectionManager>)
Declaration
public void LogErrorsAndClose(string sqlOperationType, Action<IConnectionManager> syncAction = null)
Parameters
LogErrorsAndCloseAsync(string, Func<IConnectionManager, Task>)
Declaration
public Task LogErrorsAndCloseAsync(string sqlOperationType, Func<IConnectionManager, Task> asyncAction = null)
Parameters
Returns
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
Returns
Implements