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