Class DbTask
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
DbTask(ControlFlowTask, string)
Declaration
public DbTask(ControlFlowTask callingTask, string sql)
Parameters
DbTask(string, Action, Action, params Action<object>[])
Declaration
public DbTask(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 | |
DbTask(string, params Action<object>[])
Declaration
public DbTask(string sql, params Action<object>[] actions)
Parameters
Type | Name | Description |
---|
string | sql | |
System.Action<T><object>[] | actions | |
DbTask(string, string)
Declaration
public DbTask(string name, string sql)
Parameters
Type | Name | Description |
---|
string | name | |
string | sql | |
DbTask(string)
Declaration
public DbTask(string sql)
Parameters
Type | Name | Description |
---|
string | sql | |
Properties
Actions
Declaration
public ICollection<Action<object>> Actions { get; set; }
Property Value
Type | Description |
---|
System.Collections.Generic.ICollection<T><System.Action<T><object>> | |
AfterRowReadAction
Declaration
public Action AfterRowReadAction { get; set; }
Property Value
Type | Description |
---|
System.Action | |
BeforeRowReadAction
Declaration
public Action BeforeRowReadAction { get; set; }
Property Value
Type | Description |
---|
System.Action | |
Limit
Declaration
public int Limit { get; set; }
Property Value
Parameter
Declaration
public IEnumerable<QueryParameter> Parameter { get; set; }
Property Value
Type | Description |
---|
System.Collections.Generic.IEnumerable<T><QueryParameter> | |
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
Type | Name | Description |
---|
ITableData | data | |
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
Type | Name | Description |
---|
ITableData | data | |
System.Collections.Generic.ICollection<T><string> | setColumnNames | |
System.Collections.Generic.ICollection<T><string> | joinColumnNames | |
ExecuteNonQuery()
Declaration
public int ExecuteNonQuery()
Returns
ExecuteNonQueryAsync()
Declaration
public Task<int> ExecuteNonQueryAsync()
Returns
Type | Description |
---|
System.Threading.Tasks.Task<TResult><int> | |
ExecuteReader()
Declaration
public void ExecuteReader()
ExecuteReaderAsync()
Declaration
public Task ExecuteReaderAsync()
Returns
Type | Description |
---|
System.Threading.Tasks.Task | |
ExecuteScalar()
Declaration
public object ExecuteScalar()
Returns
ExecuteScalar<T>()
Declaration
public T ExecuteScalar<T>()
Returns
Type Parameters
ExecuteScalarAsync()
Declaration
public Task<object> ExecuteScalarAsync()
Returns
Type | Description |
---|
System.Threading.Tasks.Task<TResult><object> | |
ExecuteScalarAsync<T>()
Declaration
public Task<T> ExecuteScalarAsync<T>()
Returns
Type | Description |
---|
System.Threading.Tasks.Task<TResult><T> | |
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
Type | Name | Description |
---|
string | sqlOperationType | |
System.Func<T, TResult><IConnectionManager, System.Threading.Tasks.Task> | asyncAction | |
Returns
Type | Description |
---|
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
Returns
Type | Description |
---|
System.Threading.Tasks.Task | |
Implements