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
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
SqlTask(string)
Declaration
public SqlTask(string sql)
Parameters
SqlTask(string, Action, Action, params Action<object>[])
Declaration
public SqlTask(string sql, Action beforeRowReadAction, Action afterRowReadAction, params Action<object>[] actions)
Parameters
SqlTask(string, params Action<object>[])
Declaration
public SqlTask(string sql, params Action<object>[] actions)
Parameters
SqlTask(string, IEnumerable<QueryParameter>)
Declaration
public SqlTask(string sql, IEnumerable<QueryParameter> parameter)
Parameters
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
SqlTask(string, IEnumerable<QueryParameter>, params Action<object>[])
Declaration
public SqlTask(string sql, IEnumerable<QueryParameter> parameter, params Action<object>[] actions)
Parameters
Methods
BulkDelete(IConnectionManager, ITableData)
Declaration
public static void BulkDelete(IConnectionManager connectionManager, ITableData data)
Parameters
BulkDelete(string, ITableData)
Declaration
public static void BulkDelete(string name, ITableData data)
Parameters
BulkInsert(IConnectionManager, ITableData)
Declaration
public static void BulkInsert(IConnectionManager connectionManager, ITableData data)
Parameters
BulkInsert(string, ITableData)
Declaration
public static void BulkInsert(string name, ITableData data)
Parameters
BulkUpdate(IConnectionManager, ITableData, ICollection<string>, ICollection<string>)
Declaration
public static void BulkUpdate(IConnectionManager connectionManager, ITableData data, ICollection<string> setColumnNames, ICollection<string> joinColumnNames)
Parameters
BulkUpdate(string, ITableData, ICollection<string>, ICollection<string>)
Declaration
public static void BulkUpdate(string name, ITableData data, ICollection<string> setColumnNames, ICollection<string> joinColumnNames)
Parameters
ExecuteNonQuery(IConnectionManager, string)
Declaration
public static int ExecuteNonQuery(IConnectionManager connectionManager, string sql)
Parameters
Returns
ExecuteNonQuery(IConnectionManager, string, IEnumerable<QueryParameter>)
Declaration
public static int ExecuteNonQuery(IConnectionManager connectionManager, string sql, IEnumerable<QueryParameter> parameterList)
Parameters
Returns
ExecuteNonQuery(string)
Declaration
public static int ExecuteNonQuery(string sql)
Parameters
Returns
ExecuteNonQuery(string, IEnumerable<QueryParameter>)
Declaration
public static int ExecuteNonQuery(string sql, IEnumerable<QueryParameter> parameterList)
Parameters
Returns
ExecuteNonQueryAsync(IConnectionManager, string)
Declaration
public static Task<int> ExecuteNonQueryAsync(IConnectionManager connectionManager, string sql)
Parameters
Returns
ExecuteNonQueryAsync(IConnectionManager, string, IEnumerable<QueryParameter>)
Declaration
public static Task<int> ExecuteNonQueryAsync(IConnectionManager connectionManager, string sql, IEnumerable<QueryParameter> parameterList)
Parameters
Returns
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
ExecuteReader(IConnectionManager, string, params Action<object>[])
Declaration
public static void ExecuteReader(IConnectionManager connectionManager, string sql, params Action<object>[] actions)
Parameters
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
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
ExecuteReader(string, Action, Action, params Action<object>[])
Declaration
public static void ExecuteReader(string sql, Action beforeRowReadAction, Action afterRowReadAction, params Action<object>[] actions)
Parameters
ExecuteReader(string, params Action<object>[])
Declaration
public static void ExecuteReader(string sql, params Action<object>[] actions)
Parameters
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
ExecuteReader(string, IEnumerable<QueryParameter>, params Action<object>[])
Declaration
public static void ExecuteReader(string sql, IEnumerable<QueryParameter> parameterList, params Action<object>[] actions)
Parameters
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
Returns
ExecuteReaderAsync(IConnectionManager, string, params Action<object>[])
Declaration
public static Task ExecuteReaderAsync(IConnectionManager connectionManager, string sql, params Action<object>[] actions)
Parameters
Returns
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
Returns
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
Returns
ExecuteScalar(IConnectionManager, string)
Declaration
public static object ExecuteScalar(IConnectionManager connectionManager, string sql)
Parameters
Returns
ExecuteScalar(IConnectionManager, string, IEnumerable<QueryParameter>)
Declaration
public static object ExecuteScalar(IConnectionManager connectionManager, string sql, IEnumerable<QueryParameter> parameterList)
Parameters
Returns
ExecuteScalar(string)
Declaration
public static object ExecuteScalar(string sql)
Parameters
Returns
ExecuteScalar(string, IEnumerable<QueryParameter>)
Declaration
public static object ExecuteScalar(string sql, IEnumerable<QueryParameter> parameterList)
Parameters
Returns
ExecuteScalarAsync(IConnectionManager, string)
Declaration
public static Task<object> ExecuteScalarAsync(IConnectionManager connectionManager, string sql)
Parameters
Returns
ExecuteScalarAsync(IConnectionManager, string, IEnumerable<QueryParameter>)
Declaration
public static Task<object> ExecuteScalarAsync(IConnectionManager connectionManager, string sql, IEnumerable<QueryParameter> parameterList)
Parameters
Returns
ExecuteScalarAsync<T>(IConnectionManager, string)
Declaration
public static Task<T> ExecuteScalarAsync<T>(IConnectionManager connectionManager, string sql)
Parameters
Returns
Type Parameters
ExecuteScalarAsync<T>(IConnectionManager, string, IEnumerable<QueryParameter>)
Declaration
public static Task<T> ExecuteScalarAsync<T>(IConnectionManager connectionManager, string sql, IEnumerable<QueryParameter> parameterList)
Parameters
Returns
Type Parameters
ExecuteScalar<T>(IConnectionManager, string)
Declaration
public static T ExecuteScalar<T>(IConnectionManager connectionManager, string sql)
Parameters
Returns
Type Parameters
ExecuteScalar<T>(IConnectionManager, string, IEnumerable<QueryParameter>)
Declaration
public static T ExecuteScalar<T>(IConnectionManager connectionManager, string sql, IEnumerable<QueryParameter> parameterList)
Parameters
Returns
Type Parameters
ExecuteScalar<T>(string)
Declaration
public static T ExecuteScalar<T>(string sql)
Parameters
Returns
Type Parameters
ExecuteScalar<T>(string, IEnumerable<QueryParameter>)
Declaration
public static T ExecuteScalar<T>(string sql, IEnumerable<QueryParameter> parameterList)
Parameters
Returns
Type Parameters
Implements