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.ControlFlowAssembly : ETLBox.dllSyntax# 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 ExecuteNonQueryAsync(IConnectionManager, string, IEnumerable<QueryParameter>, CancellationToken)#
Declaration public static Task < int > ExecuteNonQueryAsync ( IConnectionManager connectionManager , string sql , IEnumerable < QueryParameter > parameterList , CancellationToken cancellationToken )
Parameters Returns ExecuteNonQueryAsync(IConnectionManager, string, CancellationToken)#
Declaration public static Task < int > ExecuteNonQueryAsync ( IConnectionManager connectionManager , string sql , CancellationToken cancellationToken )
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 ExecuteReaderAsync(IConnectionManager, string, IEnumerable<QueryParameter>, CancellationToken, Action, Action, params Action<object>[])#
Declaration public static Task ExecuteReaderAsync ( IConnectionManager connectionManager , string sql , IEnumerable < QueryParameter > parameterList , CancellationToken cancellationToken , Action beforeRowReadAction , Action afterRowReadAction , params Action < object >[] actions )
Parameters Returns ExecuteReaderAsync(IConnectionManager, string, IEnumerable<QueryParameter>, CancellationToken, params Action<object>[])#
Declaration public static Task ExecuteReaderAsync ( IConnectionManager connectionManager , string sql , IEnumerable < QueryParameter > parameterList , CancellationToken cancellationToken , params Action < object >[] actions )
Parameters Returns ExecuteReaderAsync(IConnectionManager, string, CancellationToken, Action, Action, params Action<object>[])#
Declaration public static Task ExecuteReaderAsync ( IConnectionManager connectionManager , string sql , CancellationToken cancellationToken , Action beforeRowReadAction , Action afterRowReadAction , params Action < object >[] actions )
Parameters Returns ExecuteReaderAsync(IConnectionManager, string, CancellationToken, params Action<object>[])#
Declaration public static Task ExecuteReaderAsync ( IConnectionManager connectionManager , string sql , CancellationToken cancellationToken , 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(IConnectionManager, string, IEnumerable<QueryParameter>, CancellationToken)#
Declaration public static Task < object > ExecuteScalarAsync ( IConnectionManager connectionManager , string sql , IEnumerable < QueryParameter > parameterList , CancellationToken cancellationToken )
Parameters Returns ExecuteScalarAsync(IConnectionManager, string, CancellationToken)#
Declaration public static Task < object > ExecuteScalarAsync ( IConnectionManager connectionManager , string sql , CancellationToken cancellationToken )
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 ExecuteScalarAsync<T>(IConnectionManager, string, IEnumerable<QueryParameter>, CancellationToken)#
Declaration public static Task < T > ExecuteScalarAsync < T >( IConnectionManager connectionManager , string sql , IEnumerable < QueryParameter > parameterList , CancellationToken cancellationToken )
Parameters Returns Type Parameters ExecuteScalarAsync<T>(IConnectionManager, string, CancellationToken)#
Declaration public static Task < T > ExecuteScalarAsync < T >( IConnectionManager connectionManager , string sql , CancellationToken cancellationToken )
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#