

MongoDB Connector Reference¶

The following operations allow you to work with the MongoDB Connector.

Connection configurations¶

The MongoDB connector can be used to deal with two types of connections:

Connection URI (URI): The connection URI used to connect to the MongoDB database.
Connection Parameters: The parameters used for creating the connection URI. Following protocols are supported by the MongoDB connector.
Standard Connection Parameters (STANDARD)
DNS Seed List Connection Parameters (DSL)

There are different connection configurations that can be used for the above protocols. They contain a common set of configurations and some additional configurations specific to the protocol.

Types of MongoDB connections

The supported connection URI types and connection options are listed in the MongoDB Connection String documentation.

Common configs to all connection types¶

Parameter Name	Type	Description	Default Value	Required
Connection Name	String	A unique name to identify the connection.	-	Yes
Connection Type	String	The protocol used to connect to the MongoDB database. Possible values: STANDARD: The standard format of the MongoDB connection URI. DSL: The DNS-constructed seed list format of the MongoDB connection URI. URI: The complete connection URI containing the server details, credentials and the connection options.	-	Yes
Database	String	The name of the database in the MongoDB server.	-	Yes

URI connection configs¶

Parameter Name	Type	Description	Default Value	Required
Connection URI	String	The complete connection URI containing the server details, credentials, and the connection options.	-	Yes

Sample Configuration of URI configs

<?xml version="1.0" encoding="UTF-8"?>
<localEntry key="uriConnection" xmlns="http://ws.apache.org/ns/synapse">
    <mongodb.init>
        <name>uriConnection</name>
        <connectionType>URI</connectionType>
        <connectionURI>mongodb+srv://server.example.com/?connectTimeoutMS=300000&authSource=aDifferentAuthDB</connectionURI>
        <database>users</database>
    </mongodb.init>
</localEntry>

Common configs for STANDARD and DSL types¶

Parameter Name	Type	Description	Default Value	Required
Replica Set	String	If the mongod is a member of a replica set, this parameter specifies the name of the replica set.	-	No
Auth Source	String	The database name associated with the user’s credentials.	-	No
Auth Mechanism	String	The authentication mechanism that MongoDB will use for authenticating the connection.	-	No
Auth Mechanism Properties	String	Properties for the specified authorisation mechanism as a comma-separated list of colon-separated key-value pairs.	-	No
Gssapi Service Name	String	The Kerberos service name when connecting to Kerberized MongoDB instances. This value must match the service name set on MongoDB instances to which you are connecting.	-	No
W	String	Corresponds to the write concern w Option.	-	No
W Timeout MS	Number	The time limit (in milliseconds) of the write concern.	-	No
Journal	String	When this option used, the Micro Integrator requests an acknowledgement from MongoDB that the write operation has been written to the journal. This applies when the write concern is set to 'j'.	-	No
Maximum Pool Size	Number	The maximum number of connections in the connection pool.	100	No
Minimum Pool Size	Number	The minimum number of connections in the connection pool.	0	No
Maximum Idle Time MS	Number	The maximum number of milliseconds that a connection can remain idle in the pool before being removed and closed.	-	No
Wait Queue Multiple	Number	The maximum pool size is multiplied by this value to calculate the maximum number of threads that are allowed to wait for a connection to become available in the pool.	-	No
Wait Queue Timeout MS	Number	The maximum time in milliseconds that a thread can wait for a connection to become available.	-	No
SSL	Boolean	A boolean to enable or disables TLS/SSL for the connection.	-	No
SSL Invalid Host Names Allowed	Boolean	User name used to connect with the file server.	-	No
Connect Timeout TS	Number	The time in milliseconds for attempting a connection before timing out. For most drivers, the default is to never timeout.	-	No
Socket Timeout MS	Number	The time in milliseconds for attempting a send or receive on a socket before the attempt times out. For most drivers, the default is to never timeout.	-	No
Compressors	String	Comma-delimited string of compressors to enable network compression for communication between this client and a mongod/mongos instance.	-	No
Zlib Compression Level	Number	An integer that specifies the compression level when zlib is used for network compression.	-	No
Read Concern Level	String	The level of isolation.	-	No
Read Preference	String	Specifies the read preferences for this connection.	-	No
Maximum Staleness Seconds	Number	The maximum time (in seconds) a connection can remain stale before the client stops using it for read operations.	-	No
Read Preference Tags	String	Document tags as a comma-separated list or colon-separated key-value pairs.	-	No
Local Threshold MS	Number	The latency (in milliseconds) that is allowed when selecting a suitable MongoDB instance from the list of available instances.	15	No
Server Selection Timeout MS	Number	The time (in milliseconds) that is allowed for server selection before an exception is thrown.	30,000	No
Server Selection Try Once	Boolean	When true, the driver scans the MongoDB deployment exactly once after server selection fails and then either selects a server or raises an error. When false, the driver searches for a server until the serverSelectionTimeoutMS value is reached. Only applies for single-threaded drivers.	true	No
Heartbeat Frequency MS	Number	Controls the intervals between which the driver checks the state of the MongoDB deployment. The interval (in milliseconds) between checks, counted from the end of the previous check until the beginning of the next one.	-	No
App Name	String	Specify a custom app name.	-	No
Retry Reads	Boolean	Enables retryable reads.	-	No
Retry Writes	Boolean	Enable retryable writes.	-	No
UUID Representation	String	The type of UUID representation.	-	No

STANDARD connection configs¶

Parameter Name	Type	Description	Default Value	Required
Host	String	The name of the host. It identifies either a hostname, IP address, or unix domain socket. Defaults to 127.0.0.1 if not provided.	127.0.0.1	No
Port	Number	The port number. Defaults to 27017 if not provided.	27017	No
Seed List	String	A seed list is used by drivers and clients (like the mongo shell) for initial discovery of the replica set configuration. Seed lists can be provided as host:port pairs. This is used in replica sets and shared clusters.	-	No
Username	String	The user name to authenticate the database associated with the user.	-	No
Password	String	The password to authenticate the database associated with the user.	-	No

Sample configuration of STANDARD configs

Sample configuration of STANDARD (standalone) configs.

<?xml version="1.0" encoding="UTF-8"?>
<localEntry key="standaloneStandardConnection" xmlns="http://ws.apache.org/ns/synapse">
    <mongodb.init>
        <name>standaloneStandardConnection</name>
        <connectionType>STANDARD</connectionType>
        <host>localhost</host>
        <port>27017</port>
        <database>users</database>
        <username>administrator</username>
        <password>1234</password>
    </mongodb.init>
</localEntry>

Sample configuration of STANDARD (replica set) configs

<?xml version="1.0" encoding="UTF-8"?>
<localEntry key="replicaSetStandardConnection" xmlns="http://ws.apache.org/ns/synapse">
    <mongodb.init>
        <name>replicaSetStandardConnection</name>
        <connectionType>STANDARD</connectionType>
        <seedList>mongodb1.example.com:27317,mongodb2.example.com:27017</seedList>
        <database>users</database>
        <username>administrator</username>
        <password>1234</password>
        <authSource>aDifferentAuthDB</authSource>
        <ssl>true</ssl>
        <w>majority</w>
        <replicaSet>mySet</replicaSet>
        <retryWrites>true</retryWrites>
    </mongodb.init>
</localEntry>

DSL connection configs¶

Parameter Name	Type	Description	Default Value	Required
Host	String	The name of the host. It identifies either a hostname, IP address, or unix domain socket.	-	Yes
Username	String	The user name to authenticate the database associated with the user.	-	No
Password	String	The password to authenticate the database associated with the user.	-	No

Sample Configuration of DSL configs

<?xml version="1.0" encoding="UTF-8"?>
<localEntry key="dslConnection" xmlns="http://ws.apache.org/ns/synapse">
    <mongodb.init>
        <name>dslConnection</name>
        <connectionType>DSL</connectionType>
        <host>server.example.com</host>
        <database>users</database>
        <username>administrator</username>
        <password>1234</password>
        <authSource>aDifferentAuthDB</authSource>
        <retryWrites>true</retryWrites>
        <w>majority</w>
    </mongodb.init>
</localEntry>

Operations¶

The following operations allow you to work with the MongoDB connector. Click an operation name to see parameter details and samples on how to use it.

insertOne

Inserts a document into a collection. See the related insertOne documentation for more information.

Parameter Name	Type	Description	Default Value	Required
Collection	String	The name of the MongoDB collection.	-	Yes
Document	JSON String	A document to insert into the collection.	-	Yes

**Sample Configuration**

```xml
<mongodb.insertOne configKey="connectionURI">
    <collection>{json-eval($.collection)}</collection>
    <document>{json-eval($.document)}</document>
</mongodb.insertOne>

```

**Sample Request**

```json
{
    "collection": "TestCollection",
    "document": {
        "_id": "123",
        "name": "John Doe"
    }
}
```

insertMany

Inserts multiple documents into a collection. See the related insertMany documentation for more information.

Parameter Name	Type	Description	Default Value	Required
Collection	String	The name of the MongoDB collection.	-	Yes
Documents	JSON String	An array of documents to insert into the collection.	-	Yes
Ordered	Boolean	A boolean specifying whether the MongoDB instance should perform an ordered or unordered insert.	true	No

**Sample Configuration**

```xml
<mongodb.insertMany configKey="connectionURI">
    <collection>{json-eval($.collection)}</collection>
    <documents>{json-eval($.documents)}</documents>
    <ordered>True</ordered>
</mongodb.insertMany>
```

**Sample Request**

```json
{
    "collection": "TestCollection",
    "documents": [
        {
            "name": "Jane Doe",
            "_id": "123"
        },
        {
            "name": "Jane Doe",
            "_id": "1234"
        },
        {
            "name": "Jane Doe",
            "_id": "12345"
        }
    ]
}
```

findOne

Returns one document that satisfies the specified query criteria on the collection. If multiple documents satisfy the query, this method returns the first document according to the natural order. See the related find documentation for more information.

Parameter Name	Type	Description	Default Value	Required
Collection	String	The name of the MongoDB collection.	-	Yes
Query	JSON String	Specifies query selection criteria using query operators. To return the first document in a collection, omit this parameter or pass an empty document ({}).	{}	No
Projection	JSON String	Specifies the fields to return using projection operators. Omit this parameter to return all fields in the matching document.	-	No
Collation	JSON String	Collation allows users to specify language-specific rules for string comparison, such as rules for letter case and accent marks.	-	No

**Sample Configuration**

```xml
<mongodb.findOne configKey="connectionURI">
    <collection>{json-eval($.collection)}</collection>
    <query>{json-eval($.query)}</query>
</mongodb.findOne>
```

**Sample Request**

```json
{
    "collection": "TestCollection",
    "query": {
        "name": "Jane Doe"
    }
}
```

find

Selects documents in a collection or view and returns a cursor to the selected documents. See the related find documentation for more information.

Parameter Name	Type	Description	Default Value	Required
Collection	String	The name of the MongoDB collection.	-	Yes
Query	JSON String	Selection filter using query operators. To return all documents in a collection, omit this parameter or pass an empty document ({}).	{}	No
Projection	JSON String	Specifies the fields to return using projection operators. Omit this parameter to return all fields in the matching document.	-	No
Collation	JSON String	Collation allows users to specify language-specific rules for string comparison, such as rules for letter case and accent marks.	-	No
Sort	JSON String	A document that defines the sort order of the result set.	-	No

**Sample Configuration**

```xml
<mongodb.find configKey="connectionURI">
    <collection>{json-eval($.collection)}</collection>
    <query>{json-eval($.query)}</query>
</mongodb.find>
```

**Sample Request**

```json
{
    "collection": "TestCollection",
    "query": {
        "name": "John Doe"
    }
}
```

updateOne

Updates a single document within the collection based on the filter. See the related updateOne documentation for more information.

Parameter Name	Type	Description	Default Value	Required
Collection	String	The name of the MongoDB collection.	-	Yes
Query	JSON String	The selection criteria for the update. The same query selectors as in the find() method are available. Specify an empty document {} to update the first document returned in the collection.	{}	No
Update	JSON String	The modifications to apply.	-	Yes
Upsert	Boolean	Creates a new document if no documents match the filter.	false	No
Collation	JSON String	Collation allows users to specify language-specific rules for string comparison, such as rules for letter case and accent marks.	-	No
Array Filters	JSON String	An array of filter documents that determine which array elements to modify for an update operation on an array field.	-	No

!!! Info
    Array Filters parameter should be in a JSON object format. See the example given below.

    ```
    {
        "collection": "TestCollection",
        "query": {
            "grades": {
                "$gte": 100
            }
        },
        "update": {
            "$set": {
                "grades.$[element]": 100
            }
        },
        "arrayFilters": {
            "element": {
                "$gte": 100
            }
        }
    }
    ```

**Sample Configuration**

```xml
<mongodb.updateOne configKey="connectionURI">
    <collection>{json-eval($.collection)}</collection>
    <query>{json-eval($.query)}</query>
    <update>{json-eval($.update)}</update>
    <upsert>False</upsert>
</mongodb.updateOne>
```

**Sample Request**

```json
{
    "collection": "TestCollection",
    "query": {
        "_id": "123"
    },
    "update": {
        "$set": {
            "name": "Jane Doe"
        }
    }
}
```

updateMany

Updates all documents that match the specified filter for a collection. See the related updateMany documentation for more information.

Parameter Name	Type	Description	Default Value	Required
Collection	String	The name of the MongoDB collection.	-	Yes
Query	JSON String	The selection criteria for the update. The same query selectors as in the find() method are available. Specify an empty document {} to update all documents in the collection.	{}	No
Update	JSON String	The modifications to apply.	-	Yes
Upsert	Boolean	Creates a new document if no documents match the filter.	false	No
Collation	JSON String	Collation allows users to specify language-specific rules for string comparison, such as rules for letter case and accent marks.	-	No
Array Filters	JSON String	An array of filter documents that determine which array elements to modify for an update operation on an array field.	-	No

!!! Info
    Array filters parameter should be in a JSON object format. See the example given below.

    ```
    {
        "collection": "TestCollection",
        "query": {
            "grades": {
                "$gte": 100
            }
        },
        "update": {
            "$set": {
                "grades.$[element]": 100
            }
        },
        "arrayFilters": {
            "element": {
                "$gte": 100
            }
        }
    }
    ```

**Sample Configuration**

```xml
<mongodb.updateMany configKey="connectionURI">
    <collection>{json-eval($.collection)}</collection>
    <query>{json-eval($.query)}</query>
    <update>{json-eval($.update)}</update>
    <upsert>False</upsert>
</mongodb.updateMany>
```

**Sample Request**

```json
{
    "collection": "TestCollection",
    "query": {
        "_id": "123"
    },
    "update": {
        "$set": {
            "name": "Jane Doe"
        }
    }
}
```

deleteOne

Removes a single document from a collection. See the related deleteOne documentation for more information.

Parameter Name	Type	Description	Default Value	Required
Collection	String	The name of the MongoDB collection.	-	Yes
Query	JSON String	Specifies deletion criteria using query operators. Specify an empty document {} to delete the first document returned in the collection.	{}	No
Collation	JSON String	Collation allows users to specify language-specific rules for string comparison, such as rules for letter case and accent marks.	-	No

**Sample Configuration**

```xml
<mongodb.deleteOne configKey="connectionURI">
    <collection>{json-eval($.collection)}</collection>
    <query>{json-eval($.query)}</query>
</mongodb.deleteOne>
```

**Sample Request**

```json
{
    "collection": "TestCollection",
    "query": {
        "name": "Jane Doe"
    }
}
```

deleteMany

Removes all documents that match the query from a collection. See the related deleteMany documentation for more information.

Parameter Name	Type	Description	Default Value	Required
Collection	String	The name of the MongoDB collection.	-	Yes
Query	JSON String	Specifies deletion criteria using query operators. To delete all documents in a collection, pass in an empty document ({}).	{}	No
Collation	JSON String	Collation allows users to specify language-specific rules for string comparison, such as rules for letter case and accent marks.	-	No

**Sample Configuration**

```xml
<mongodb.deleteMany configKey="connectionURI">
    <collection>{json-eval($.collection)}</collection>
    <query>{json-eval($.query)}</query>
</mongodb.deleteMany>
```

**Sample Request**

```json
{
    "collection": "TestCollection",
    "query": {
        "name": "John Doe"
    }
}
```

aggregate

Process data in collections and return computed results. For more information, see the documentation for aggregate.

Parameter Name	Type	Description	Default Value	Required
Collection	String	The name of the MongoDB collection.	-	Yes
Stages	JSON Array	The stages of the aggregation/aggregation pipeline. Each stage is a document with a corresponding operator name, such as $match or $group.	-	Yes

**Sample Configuration**

```xml
<mongodb.aggregate configKey="connectionURI">
    <collection>{json-eval($.collection)}</collection>
    <stages>{json-eval($.stages)}</stages>
</mongodb.aggregate>
```

**Sample Request**

```json
{
    "collection": "TestCollection",
    "stages": {
        {
            "$match": {
                "category": "Bakery"
            }
        },
        {
            "$group": {
                "_id": "$star",
                "totalStarCount": {
                    "$sum": {
                        "$multiply": [
                            "$star",
                            "$count"
                        ]
                    }
                },
                "averageStar": {
                    "$avg": "$star"
                }
            }
        }
    }
}
```

Top