🤝
n8n node MongoDb Ex _(tended)_

n8n-nodes-mongodb-ex

An extended n8n MongoDB node, tailor-made for native MongoDB developers. This node goes beyond the built-in MongoDB node by providing authentic MongoDB query syntax, advanced update operators, update pipelines, arrayFilters, bulk operations, type coercion and more.

Table of Contents

- Overview
- Installation
- Features
- Operations
- Usage Examples
- Compatibility
- License

Overview

MongoDB Extended (MongoDbEx) is a drop-in replacement for n8n’s base MongoDB node with a richer, MongoDB-native developer experience:

- Use real MongoDB query syntax and aggregation pipelines
- Leverage advanced update operators and update pipelines
- Target array elements precisely with arrayFilters and positional operators
- Perform single or bulk operations (insertMany/updateMany/bulkWrite)
- Automatic type coercion for ObjectId and ISO dates
- Subnode support - use it as a tool for AI Agents

Installation

Follow the community nodes installation guide, then search for and install n8n-nodes-mongodb-ex.

Alternatively, install directly:

``bash
npm install n8n-nodes-mongodb-ex
`

For Docker-based deployments, add to your n8n Docker image:

`dockerfile
RUN cd /usr/local/lib/node_modules/n8n && npm install n8n-nodes-mongodb-ex
`

Features

- MongoDB-native queries and pipelines
- Advanced update operators: $set, $unset, $inc, $push, $pull, etc.
- Update pipelines supported (array of stages)
- Array element targeting with arrayFilters
- Bulk operations: insertMany, updateMany, bulkWrite
- JSON input for queries, documents, updates
- Automatic type coercion of 24-hex ObjectId strings and ISO date strings
- Upsert support for updates

Operations

- Aggregate: Run full MongoDB aggregation pipelines
- Find: Query documents using native MongoDB operators
- Insert: Insert one or many documents
- Update: Update one or many documents with operators or update pipelines
- FindOneAndUpdate: Atomic find-and-update with full MongoDB update support
- FindOneAndReplace: Atomic find-and-replace
- Delete: Delete by native MongoDB filter

Type Coercion

#### Input
`json
{
"_id": "507f1f77bcf86cd799439011",
"name": "John Doe",
"orders": [
{
"productId": "66d6215f9b3c4a18e0f7a2c1",
"quantity": 2,
"timestamp": "2025-02-03T18:46:00Z"
}
],
"createdAt": "2024-01-15T10:44:00Z"
}
`

#### Saved DB Document
`javascript
{
"_id": ObjectId("507f1f77bcf86cd799439011"),
"name": "John Doe",
"orders": [
{
"productId": ObjectId("66d6215f9b3c4a18e0f7a2c1"),
"quantity": 2,
"timestamp": ISODate("2025-02-03T18:46:00Z")
}
],
"createdAt": ISODate("2024-01-15T10:44:00Z")
}
`

$oid and $toDate operators in pipelines are recognized and respected. Any manual type conversions you may already have in place will not be overwritten.

Usage Examples

$3

#### Filter:
`json
{ "_id": 12345 }
`

#### Update:
`json
{
"$set": {
"orders.$[elem].status": "shipped",
"orders.$[elem].shippedAt": "2024-01-15T10:00:00Z"
}
}
`

#### arrayFilters:
`json
[{"elem.status": "pending"}]
`

---

$3

#### Filter:
`json
{
"_id": {
"type": "counter",
"metric": "orders_summary"
}
}
`

#### Update (pipeline):
`json
[
{
"$set": {
"totalSpent": {"$add": ["$totalSpent", "$currentOrder.amount"]},
"lastOrderDate": "$$NOW",
"orderCount": {"$add": ["$orderCount", 1]}
}
},
{
"$push": {
"logs": { "message": "Stats updated", "timestamp": "$$NOW" }
}
}
]
`

---

$3

`json
[
{
"$match": {"status": "active"}
},
{
"$lookup": {
"from": "orders",
"localField": "_id",
"foreignField": "userId",
"as": "userOrders"
}
},
{
"$group": {
"_id": "$department",
"totalOrders": {"$sum": {"$size": "$userOrders"}},
"avgOrderValue": {"$avg": "$userOrders.total"}
}
}
]
`

---

$3

#### Input:
`json
{
[
{
"_id": "507f1f77bcf86cd799439011",
"createdAt": "2024-01-15T10:00:00Z",
"name": "John Doe"
},
{
"_id": "507f1f77bcf86cd799439012",
"createdAt": "2024-01-15T11:00:00Z",
"name": "Jane Smith"
}
]
}
`

#### Many:
Set to true

---

$3

#### Input:
`json
{
[
{
"updateOne": {
"filter": { "_id": "507f1f77bcf86cd799439011" },
"update": {
"$set": { "name.last": "Doe" },
"$currentDate": { "timestamp": true }
}
}
},
{
"updateOne": {
"filter": { "_id": "507f1f77bcf86cd799439013" },
"update": {
"$set": { "active": false }
"$currentDate": { "timestamp": true }
}
}
}
]
}
``

Compatibility

- n8n >= 0.187.0
- Node.js >= 20.15
- MongoDB >= 4.4

License

MIT