Class MongoDbDestination<TInput>
A data flow destination for MongoDb.
Inheritance
object
DataFlowDestination<TInput>
DataFlowBatchDestination<TInput>
MongoDbDestination<TInput>
Inherited Members
object.Equals(object)
object.Equals(object, object)
object.GetHashCode()
object.GetType()
object.MemberwiseClone()
object.ReferenceEquals(object, object)
object.ToString()
Namespace: ETLBox.MongoDb
Assembly: ETLBox.MongoDb.dll
Syntax
public class MongoDbDestination<TInput> : DataFlowBatchDestination<TInput>, ILoggableTask, IDataFlowLogging, IDataFlowBatchDestination<TInput>, IDataFlowDestination<TInput>, IDataFlowBatchDestination, IDataFlowDestination, IDataFlowComponent
Type Parameters
| Name | Description |
|---|---|
| TInput | Type of ingoing data. |
Constructors
MongoDbDestination()
Declaration
public MongoDbDestination()
MongoDbDestination(int)
Declaration
public MongoDbDestination(int batchSize)
Parameters
| Type | Name | Description |
|---|---|---|
| int | batchSize |
Properties
CollectionName
Name of the collection to retrieve the documents from.
Declaration
public string CollectionName { get; set; }
Property Value
| Type | Description |
|---|---|
| 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
| Type | Description |
|---|---|
| string |
DatabaseName
The used database.
Declaration
public string DatabaseName { get; set; }
Property Value
| Type | Description |
|---|---|
| string |
DbClient
An existing MongoClient that holds a MongoDb connection.
Declaration
public MongoClient DbClient { get; set; }
Property Value
| Type | Description |
|---|---|
| MongoClient |
Session
An existing session handle that will be used when inserting the data.
Declaration
public IClientSessionHandle Session { get; set; }
Property Value
| Type | Description |
|---|---|
| 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
| Type | Description |
|---|---|
| string |
Overrides
Methods
BulkInsertData(TInput[])
Declaration
protected override void BulkInsertData(TInput[] data)
Parameters
| Type | Name | Description |
|---|---|---|
| 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()