MongoDB Connector in Mule







Mongo DB Connector in Mule

Mongo DB connector is used to perform DDL & DML operations in Mongo DB via Mule.

Below is an example of searching objects in a table in Mongo db.


Mongo DB configuration :

Collection name : demo
Operation: Find objects



connector configuration :

click on +
give username
password if any
database name

and check test connection.




Advanced tab  :



URL : http://localhost:8085/api/mongo
Method : GET

Output :


[

    {
        "_id": {
            "time": 1570080768000,
            "machine": 1908925732,
            "timeSecond": 1570080768,
            "inc": -1391041365,
            "new": false
        },
        "name": "abc"
    },
    {
        "_id": {
            "time": 1570080817000,
            "machine": 1908925732,
            "timeSecond": 1570080817,
            "inc": -1391041364,
            "new": false
        },
        "name": "def"
    },
    {
        "_id": {
            "time": 1570081177000,
            "machine": 1908925732,
            "timeSecond": 1570081177,
            "inc": -1391041363,
            "new": false
        },
        "name": "hhh"
    }
]


XML project code :



<?xml version="1.0" encoding="UTF-8"?>

<mule xmlns:json="http://www.mulesoft.org/schema/mule/json" xmlns:http="http://www.mulesoft.org/schema/mule/http" xmlns:mongo="http://www.mulesoft.org/schema/mule/mongo" xmlns="http://www.mulesoft.org/schema/mule/core" xmlns:doc="http://www.mulesoft.org/schema/mule/documentation"
xmlns:spring="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-current.xsd
http://www.mulesoft.org/schema/mule/core http://www.mulesoft.org/schema/mule/core/current/mule.xsd
http://www.mulesoft.org/schema/mule/http http://www.mulesoft.org/schema/mule/http/current/mule-http.xsd
http://www.mulesoft.org/schema/mule/mongo http://www.mulesoft.org/schema/mule/mongo/current/mule-mongo.xsd
http://www.mulesoft.org/schema/mule/json http://www.mulesoft.org/schema/mule/json/current/mule-json.xsd">
    <mongo:config name="Mongo_DB" database="test" doc:name="Mongo DB" username="admin"/>
    <http:listener-config name="HTTP_Listener_Configuration" host="0.0.0.0" port="8085" basePath="/api" doc:name="HTTP Listener Configuration"/>
    <flow name="test_custombuseventFlow">
        <http:listener config-ref="HTTP_Listener_Configuration" path="/mongo" doc:name="HTTP"/>
        <mongo:find-objects config-ref="Mongo_DB" collection="demo" username="admin" database="test" doc:name="Mongo DB"/>
        <json:object-to-json-transformer doc:name="Object to JSON"/>
    </flow>
</mule>