Class MongoDbDestination<TInput>
A data flow destination for MongoDb.
Inheritance
MongoDbDestination<TInput>
Namespace: ETLBox.MongoDb
Assembly: ETLBox.MongoDb.dll
Syntax
public class MongoDbDestination<TInput> : DataFlowBatchDestination<TInput>, IDataFlowLogging, IDataFlowBatchDestination<TInput>, IDataFlowDestination<TInput>, IDataFlowBatchDestination, IDataFlowDestination, IDataFlowComponent, ILoggableTask
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
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
DatabaseName
Declaration
public string DatabaseName { get; set; }
Property Value
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 | |
Methods
BulkInsertData(TInput[])
Declaration
protected override void BulkInsertData(TInput[] data)
Parameters
| Type | Name | Description |
|---|
| TInput[] | data | |
Overrides
CheckParameter()
Declaration
protected override void CheckParameter()
Overrides
FinishWrite()
Declaration
protected override void FinishWrite()
Overrides
InitCheckedParameter()
Declaration
protected override void InitCheckedParameter()
Overrides
PrepareWrite()
Declaration
protected override void PrepareWrite()
Overrides
Implements