Class SqlDestinationWriter

Namespace

Dynamicweb.DataIntegration.Providers.SqlProvider

Assembly

Dynamicweb.DataIntegration.dll

Sql destination writer

public class SqlDestinationWriter : BaseSqlWriter, IDestinationWriter, IDisposable

Inheritance

object

BaseDestinationWriter

BaseSqlWriter

SqlDestinationWriter

Implements

IDestinationWriter

IDisposable

Inherited Members

BaseSqlWriter.RowsAffected

BaseSqlWriter.GetExtraConditions(Mapping, string, string)

BaseSqlWriter.DeactivateMissingProductsInMainTable(Mapping, SqlCommand, string, string, bool)

BaseSqlWriter.DeleteRowsFromMainTable(bool, Mapping, string, SqlCommand, string)

BaseSqlWriter.DeleteRowsFromMainTable(bool, Dictionary<string, Mapping>, string, SqlCommand)

BaseSqlWriter.DeleteExcessFromMainTable(Mapping, string, SqlCommand, string, bool)

BaseSqlWriter.DeleteExcessFromMainTable(SqlCommand, Mapping, string, string, bool)

BaseSqlWriter.DeleteExcessFromMainTable(SqlCommand, Dictionary<string, Mapping>, string)

BaseSqlWriter.DeleteExistingFromMainTable(Mapping, string, SqlCommand, string)

BaseSqlWriter.DeleteExistingFromMainTable(SqlCommand, Mapping, string, string)

BaseSqlWriter.SqlBulkCopierWriteToServer(SqlBulkCopy, DataTable, bool, Mapping, ILogger)

BaseSqlWriter.MoveDataToMainTable(Mapping, SqlCommand, SqlTransaction, string)

BaseSqlWriter.MoveDataToMainTable(SqlCommand, Mapping, SqlTransaction, string)

BaseSqlWriter.MoveDataToMainTable(Mapping, SqlCommand, SqlTransaction, string, bool)

BaseSqlWriter.MoveDataToMainTable(SqlCommand, Mapping, SqlTransaction, string, bool)

BaseSqlWriter.MoveDataToMainTable(Mapping, SqlCommand, SqlTransaction, string, bool, bool)

BaseSqlWriter.HasIdentity(Mapping)

BaseSqlWriter.HasIdentity(ColumnMappingCollection)

BaseSqlWriter.GetMoveDataToMainTableException(Exception, SqlCommand, Mapping, string, List<string>)

BaseSqlWriter.GetMoveDataToMainTableException(Exception, SqlCommand, Mapping, string, List<string>, string, string)

BaseDestinationWriter.Initialize()

BaseDestinationWriter.DeleteRowsMissingFromSource()

BaseDestinationWriter.GetRowValueNotFoundMessage(Dictionary<string, object>, string, string)

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

SqlDestinationWriter(Mapping, SqlCommand, bool, ILogger?, string, bool)

Initializes a new instance of the SqlDestinationWriter class.

public SqlDestinationWriter(Mapping mapping, SqlCommand mockSqlCommand, bool removeMissingAfterImport, ILogger? logger, string tempTablePrefix, bool discardDuplicates)

Parameters

mapping Mapping

Mapping

mockSqlCommand SqlCommand

Mock SqlCommand

removeMissingAfterImport bool

Delete rows not present in the import

logger ILogger

Logger instance

tempTablePrefix string

Temporary table prefix

discardDuplicates bool

Discard duplicates

SqlDestinationWriter(Mapping, SqlConnection, bool, ILogger?, bool)

Initializes a new instance of the SqlDestinationWriter class.

public SqlDestinationWriter(Mapping mapping, SqlConnection connection, bool removeMissingAfterImport, ILogger? logger, bool discardDuplicates)

Parameters

mapping Mapping

Mapping

connection SqlConnection

Connection

removeMissingAfterImport bool

Delete rows not present in the import

logger ILogger

Logger instance

discardDuplicates bool

Discard duplicates

SqlDestinationWriter(Mapping, SqlConnection, bool, ILogger?, string, bool)

Initializes a new instance of the SqlDestinationWriter class.

public SqlDestinationWriter(Mapping mapping, SqlConnection connection, bool removeMissingAfterImport, ILogger? logger, string tempTablePrefix, bool discardDuplicates)

Parameters

mapping Mapping

Mapping

connection SqlConnection

Connection

removeMissingAfterImport bool

Delete rows not present in the import

logger ILogger

Logger instance

tempTablePrefix string

Temporary table prefix

discardDuplicates bool

Discard duplicates

SqlDestinationWriter(Mapping, SqlConnection, bool, ILogger?, string, bool, bool)

Initializes a new instance of the SqlDestinationWriter class.

public SqlDestinationWriter(Mapping mapping, SqlConnection connection, bool removeMissingAfterImport, ILogger? logger, string tempTablePrefix, bool discardDuplicates, bool removeMissingAfterImportDestinationTablesOnly)

Parameters

mapping Mapping

Mapping

connection SqlConnection

Connection

removeMissingAfterImport bool

Delete rows not present in the import

logger ILogger

Logger instance

tempTablePrefix string

Temporary table prefix

discardDuplicates bool

Discard duplicates

removeMissingAfterImportDestinationTablesOnly bool

Remove missing rows after import in the destination tables only

SqlDestinationWriter(Mapping, SqlConnection, bool, ILogger?, string, bool, bool, bool)

Initializes a new instance of the SqlDestinationWriter class.

public SqlDestinationWriter(Mapping mapping, SqlConnection connection, bool removeMissingAfterImport, ILogger? logger, string tempTablePrefix, bool discardDuplicates, bool removeMissingAfterImportDestinationTablesOnly, bool skipFailingRows)

Parameters

mapping Mapping

Mapping

connection SqlConnection

Connection

removeMissingAfterImport bool

Delete rows not present in the import

logger ILogger

Logger instance

tempTablePrefix string

Temporary table prefix

discardDuplicates bool

Discard duplicates

removeMissingAfterImportDestinationTablesOnly bool

Remove missing rows after import in the destination tables only

skipFailingRows bool

Skip failing rows

Properties

Mapping

Gets the mapping.

public Mapping Mapping { get; }

Property Value

Mapping

RowsToWriteCount

Return rows to write count

public int RowsToWriteCount { get; }

Property Value

int

Methods

Close()

Close writer

public virtual void Close()

DeleteExcessFromMainTable(string)

Deletes rows not present in the import source

public virtual void DeleteExcessFromMainTable(string extraConditions)

Parameters

extraConditions string

Where condition to filter data for deletion

DeleteRowsNotInSourceFromMainTable(string)

Deletes rows not present in the import source

public virtual long DeleteRowsNotInSourceFromMainTable(string extraConditions)

Parameters

extraConditions string

Where condition to filter data for deletion

Returns

long

Dispose()

Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources.

public void Dispose()

Dispose(bool)

protected virtual void Dispose(bool disposing)

Parameters

disposing bool

FinishWriting()

Write data using SQL bulk copier

public virtual void FinishWriting()

MoveDataToMainTable(SqlTransaction)

protected int MoveDataToMainTable(SqlTransaction sqlTransaction)

Parameters

sqlTransaction SqlTransaction

Returns

int

Write(Dictionary<string, object>)

Writes the specified row.

public virtual void Write(Dictionary<string, object> row)

Parameters

row Dictionary<string, object>

The row to be written.