Class SqlServerBulkUpdate

Class for fast data update for SQL Server.

Inheritance

System.Object

BulkUpdateBase

SqlServerBulkUpdate

Implements

IBulkUpdate

Inherited Members

BulkUpdateBase.PrefixTempTable

BulkUpdateBase._connection

BulkUpdateBase._disposeOfConnection

BulkUpdateBase.ExternalTransaction

BulkUpdateBase.DestinationTableName

BulkUpdateBase.TempTableAction

BulkUpdateBase.PrimaryKeyColumn

BulkUpdateBase.Update(IBulkActionDataReader)

BulkUpdateBase.UpdateAsync(IBulkActionDataReader)

BulkUpdateBase.Update(IDataReader)

BulkUpdateBase.UpdateAsync(IDataReader)

BulkUpdateBase.Update(DataTable)

BulkUpdateBase.UpdateAsync(DataTable)

BulkUpdateBase.GetTempTableNameForBulkInsert(String)

BulkUpdateBase.GetColumnNamesForTempTable(IDataReader)

BulkUpdateBase.GetUpdateColumnNames(IDataReader, String)

BulkUpdateBase.Dispose(Boolean)

BulkUpdateBase.Dispose()

Namespace: Kros.Data.BulkActions.SqlServer

Assembly: Kros.Utils.dll

Syntax

public class SqlServerBulkUpdate : BulkUpdateBase, IBulkUpdate, IDisposable

Examples

Constructors

SqlServerBulkUpdate(SqlConnection)

Initialize new instance of SqlServerBulkUpdate with database connection connection.

Declaration

public SqlServerBulkUpdate(SqlConnection connection)

Parameters

Type	Name	Description
System.Data.SqlClient.SqlConnection	connection	Database connection where data will be updated, connection has to be opened. If transaction is running on connection, contructor with defined external transaction has to be used.

SqlServerBulkUpdate(SqlConnection, SqlTransaction)

Initialize new instance of SqlServerBulkUpdate with database connection connection, and external transaction externalTransaction.

Declaration

public SqlServerBulkUpdate(SqlConnection connection, SqlTransaction externalTransaction)

Parameters

Type	Name	Description
System.Data.SqlClient.SqlConnection	connection	Database connection where data will be updated, connection has to be opened. If transaction is running on connection, transaction has to be defined in externalTransaction.
System.Data.SqlClient.SqlTransaction	externalTransaction	External transaction, in which bulk update is executed.

SqlServerBulkUpdate(String)

Initialize new instance of SqlServerBulkUpdate with connectionString.

Declaration

public SqlServerBulkUpdate(string connectionString)

Parameters

Type	Name	Description
System.String	connectionString	Connection string for database connection.

Methods

CreateBulkInsert()

Declaration

protected override IBulkInsert CreateBulkInsert()

Returns

Type	Description
IBulkInsert

Overrides

BulkUpdateBase.CreateBulkInsert()

CreateCommandForPrimaryKey()

Declaration

protected override IDbCommand CreateCommandForPrimaryKey()

Returns

Type	Description
System.Data.IDbCommand

Overrides

BulkUpdateBase.CreateCommandForPrimaryKey()

CreateTempTable(IDataReader, String)

Declaration

protected override void CreateTempTable(IDataReader reader, string tempTableName)

Parameters

Type	Name	Description
System.Data.IDataReader	reader
System.String	tempTableName

Overrides

BulkUpdateBase.CreateTempTable(IDataReader, String)

DoneTempTableAsync(String, Boolean)

Declaration

protected override Task DoneTempTableAsync(string tempTableName, bool useAsync)

Parameters

Type	Name	Description
System.String	tempTableName
System.Boolean	useAsync

Returns

Type	Description
System.Threading.Tasks.Task

Overrides

BulkUpdateBase.DoneTempTableAsync(String, Boolean)

GetTempTableName()

Declaration

protected override string GetTempTableName()

Returns

Type	Description
System.String

Overrides

BulkUpdateBase.GetTempTableName()

InvokeAction(String)

Declaration

protected override void InvokeAction(string tempTableName)

Parameters

Type	Name	Description
System.String	tempTableName

Overrides

BulkUpdateBase.InvokeAction(String)

UpdateDestinationTableAsync(IDataReader, String, Boolean)

Declaration

protected override Task UpdateDestinationTableAsync(IDataReader reader, string tempTableName, bool useAsync)

Parameters

Type	Name	Description
System.Data.IDataReader	reader
System.String	tempTableName
System.Boolean	useAsync

Returns

Type	Description
System.Threading.Tasks.Task

Overrides

BulkUpdateBase.UpdateDestinationTableAsync(IDataReader, String, Boolean)

Implements

IBulkUpdate