Class BaseSqlReader
- Namespace
- Dynamicweb.DataIntegration.Integration
- Assembly
- Dynamicweb.DataIntegration.dll
public abstract class BaseSqlReader : ISourceReader, IDisposable, IResponseWriter
- Inheritance
-
BaseSqlReader
- Implements
- Derived
- Inherited Members
Constructors
BaseSqlReader()
protected BaseSqlReader()
BaseSqlReader(Mapping, SqlConnection)
public BaseSqlReader(Mapping mapping, SqlConnection connection)
Parameters
mappingMappingconnectionSqlConnection
Fields
_command
protected SqlCommand? _command
Field Value
_reader
protected SqlDataReader? _reader
Field Value
mapping
protected Mapping mapping
Field Value
Properties
PkColumnsForResponseMapping
protected IEnumerable<string> PkColumnsForResponseMapping { get; }
Property Value
Methods
Close()
Closes this instance.
public void Close()
Dispose()
Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources.
public void Dispose()
GetColumns()
protected virtual string GetColumns()
Returns
GetColumnsFromMappingConditions()
protected string GetColumnsFromMappingConditions()
Returns
GetColumnsFromMappingConditions(string[])
protected string GetColumnsFromMappingConditions(string[] columnsToSkip)
Parameters
columnsToSkipstring[]
Returns
GetDistinctColumnsFromMapping()
protected string GetDistinctColumnsFromMapping()
Returns
GetDistinctColumnsFromMapping(string[])
protected string GetDistinctColumnsFromMapping(string[] columnsToSkip)
Parameters
columnsToSkipstring[]
Returns
GetFromTables()
protected virtual string GetFromTables()
Returns
GetNext()
base implementation,
public virtual Dictionary<string, object> GetNext()
Returns
GetPrimaryKeyColumns(bool)
protected IEnumerable<string> GetPrimaryKeyColumns(bool returnOnlyMissedInMappings = true)
Parameters
returnOnlyMissedInMappingsbool
Returns
IsDone()
Determines whether this instance is done reading from the source.
public virtual bool IsDone()
Returns
- bool
trueif this instance is done; otherwise,false.
Write(Dictionary<string, object>)
Writes the specified row.
public void Write(Dictionary<string, object> row)
Parameters
rowDictionary<string, object>The row to be written.