Class MongoDbDestination<TInput>

A data flow destination for MongoDb.

Inheritance
System.Object
MongoDbDestination<TInput>
Inherited Members
System.Object.Equals(System.Object)
System.Object.Equals(System.Object, System.Object)
System.Object.GetHashCode()
System.Object.GetType()
System.Object.MemberwiseClone()
System.Object.ReferenceEquals(System.Object, System.Object)
System.Object.ToString()
Namespace: ETLBox.DataFlow.Connectors
Assembly: ETLBox.MongoDb.dll
Syntax
    public class MongoDbDestination<TInput> : DataFlowBatchDestination<TInput>, ILoggableTask, IDataFlowLogging, IDataFlowBatchDestination<TInput>, IDataFlowDestination<TInput>, IDataFlowDestination, IDataFlowComponent, IDataFlowBatchDestination
Type Parameters
NameDescription
TInput

Type of ingoing data.

Constructors

MongoDbDestination()

Declaration
    public MongoDbDestination()

MongoDbDestination(Int32)

Declaration
    public MongoDbDestination(int batchSize)
Parameters
TypeNameDescription
System.Int32batchSize

Properties

CollectionName

Name of the collection to retrieve the documents from.

Declaration
    public string CollectionName { get; set; }
Property Value
TypeDescription
System.String

ConnectionString

If you provide a connection string, this component will create a new MongoClient object to connect with MongoDb. If you already have a client object instantiated in your application, use DbClient instead to pass it directly to the component.

Declaration
    public string ConnectionString { get; set; }
Property Value
TypeDescription
System.String

DatabaseName

The used database.

Declaration
    public string DatabaseName { get; set; }
Property Value
TypeDescription
System.String

DbClient

An existing MongoClient that holds a MongoDb connection.

Declaration
    public MongoClient DbClient { get; set; }
Property Value
TypeDescription
MongoDB.Driver.MongoClient

Session

An existing session handle that will be used when inserting the data.

Declaration
    public IClientSessionHandle Session { get; set; }
Property Value
TypeDescription
MongoDB.Driver.IClientSessionHandle

TaskName

A name to identify the task or component. Every component or task comes with a default name that can be overwritten.

Declaration
    public override string TaskName { get; set; }
Property Value
TypeDescription
System.String
Overrides

Methods

BulkInsertData(TInput[])

Declaration
    protected override void BulkInsertData(TInput[] data)
Parameters
TypeNameDescription
TInput[]data
Overrides
ETLBox.DataFlow.DataFlowBatchDestination<TInput>.BulkInsertData(TInput[])

CheckParameter()

Declaration
    protected override void CheckParameter()
Overrides

FinishWrite()

Declaration
    protected override void FinishWrite()
Overrides
ETLBox.DataFlow.DataFlowBatchDestination<TInput>.FinishWrite()

InitParameter()

Declaration
    protected override void InitParameter()
Overrides

PrepareWrite()

Declaration
    protected override void PrepareWrite()
Overrides
ETLBox.DataFlow.DataFlowBatchDestination<TInput>.PrepareWrite()

Implements