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()