ETLBox
Class MongoDbDestination<TInput>
A data flow destination for MongoDb.
Inherited Members
Namespace: ETLBox.MongoDb
Assembly: ETLBox.MongoDb.dll
Syntax
public class MongoDbDestination<TInput> : DataFlowBatchDestination<TInput>, IDataFlowBatchDestination<TInput>, IDataFlowDestination<TInput>, IDataFlowBatchDestination, IDataFlowDestination, IDataFlowComponent, ILoggableTaskType 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 |
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()