Class BaseSqlReader
- Namespace
- Dynamicweb.DataIntegration.Integration
- Assembly
- Dynamicweb.DataIntegration.dll
public abstract class BaseSqlReader : ISourceReader, IDisposable, IResponseWriter
- Inheritance
-
BaseSqlReader
- Implements
- Inherited Members
Constructors
BaseSqlReader()
protected BaseSqlReader()
BaseSqlReader(Mapping, SqlConnection)
public BaseSqlReader(Mapping mapping, SqlConnection connection)
Parameters
mapping
Mappingconnection
SqlConnection
Fields
_command
protected SqlCommand _command
Field Value
_reader
protected SqlDataReader _reader
Field Value
mapping
protected Mapping mapping
Field 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
columnsToSkip
string[]
Returns
GetDistinctColumnsFromMapping()
protected string GetDistinctColumnsFromMapping()
Returns
GetDistinctColumnsFromMapping(string[])
protected string GetDistinctColumnsFromMapping(string[] columnsToSkip)
Parameters
columnsToSkip
string[]
Returns
GetFromTables()
protected virtual string GetFromTables()
Returns
GetNext()
base implementation,
public virtual Dictionary<string, object> GetNext()
Returns
IsDone()
Determines whether this instance is done reading from the source.
public virtual bool IsDone()
Returns
- bool
true
if this instance is done; otherwise,false
.
Write(Dictionary<string, object>)
Writes the specified row.
public void Write(Dictionary<string, object> row)
Parameters
row
Dictionary<string, object>The row to be written.