Title here
Summary here
A data flow destination for MongoDb.
public class MongoDbDestination<TInput> : DataFlowBatchDestination<TInput>, IDataFlowBatchDestination<TInput>, IDataFlowDestination<TInput>, IDataFlowBatchDestination, IDataFlowDestination, IDataFlowComponent, ILoggableTask| Name | Description |
|---|---|
| TInput | Type of ingoing data. |
public MongoDbDestination() public MongoDbDestination(int batchSize)| Type | Name | Description |
|---|---|---|
| int | batchSize |
Name of the collection to retrieve the documents from.
public string CollectionName { get; set; }| Type | Description |
|---|---|
| string |
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.
public string ConnectionString { get; set; }| Type | Description |
|---|---|
| string |
The used database.
public string DatabaseName { get; set; }| Type | Description |
|---|---|
| string |
An existing MongoClient that holds a MongoDb connection.
public MongoClient DbClient { get; set; }| Type | Description |
|---|---|
| MongoClient |
An existing session handle that will be used when inserting the data.
public IClientSessionHandle Session { get; set; }| Type | Description |
|---|---|
| IClientSessionHandle |
protected override void BulkInsertData(TInput[] data)| Type | Name | Description |
|---|---|---|
| TInput[] | data |
protected override void CheckParameter() protected override void FinishWrite() protected override void InitCheckedParameter() protected override void PrepareWrite()