メニュー
Master MongoDB integration in applications with Node.js, Python, and Java drivers. Learn connections, transactions, error handling, and best practices. Use when building applications with MongoDB.
デフォルトでは、最初にソースを確認する Prompt が選択されています。直接コマンドに切り替えるか、ローカルコピーをダウンロードすることもできます。
インストールを決める前に、SKILL.md と SkillsMP に表示されている付属ファイルをお読みください。
Codex または Claude でインストール この Prompt をコピーして Codex、Claude、または他のアシスタントに貼り付けると、Skill ページを確認してインストールできます。
直接コマンドでは確認用 Prompt が省略されます。実行前にソースを確認してください。
npx skills add https://github.com/pluginagentmarketplace/custom-plugin-mongodb --skill mongodb-app-developmentコマンドは1行のまま表示されます。コピー前に横へスクロールして全体を確認してください。
ローカルで確認しますか？SkillsMP が現在取得できるファイルをダウンロードできます。
Master MongoDB aggregation pipeline for complex data transformations. Learn pipeline stages, grouping, filtering, and data transformation. Use when analyzing data, creating reports, or transforming documents.
Master MongoDB Atlas cloud setup, cluster configuration, security, networking, backups, and monitoring. Get production-ready cloud database in minutes. Use when setting up cloud MongoDB, configuring clusters, or managing Atlas.
Master MongoDB authentication methods including SCRAM, X.509 certificates, LDAP, and Kerberos. Learn user creation, role assignment, and securing MongoDB deployments.
SOC 職業分類に基づく
SKILL.md を表示中
| name | mongodb-app-development |
| version | 2.1.0 |
| description | Master MongoDB integration in applications with Node.js, Python, and Java drivers. Learn connections, transactions, error handling, and best practices. Use when building applications with MongoDB. |
| sasmp_version | 1.3.0 |
| bonded_agent | 07-mongodb-application-development |
| bond_type | PRIMARY_BOND |
| capabilities | ["driver-integration","connection-management","error-handling","transaction-implementation","change-streams"] |
| input_validation | {"required_context":["programming_language","operation_type"],"optional_context":["framework","async_requirement","connection_pool_size"]} |
| output_format | {"code_implementation":"string","error_handling":"string","connection_config":"object","best_practices":"array"} |
| error_handling | {"common_errors":[{"code":"APP001","condition":"Connection pool exhausted","recovery":"Increase maxPoolSize, check for connection leaks"},{"code":"APP002","condition":"Network timeout","recovery":"Increase socketTimeoutMS, check network stability"},{"code":"APP003","condition":"Driver version incompatibility","recovery":"Update driver to latest stable version"}]} |
| prerequisites | {"mongodb_version":"4.0+","required_knowledge":["chosen-language-basics","mongodb-crud"],"driver_requirements":["Official MongoDB driver for target language"]} |
| testing | {"unit_test_template":"// Integration test\nbeforeAll(async () => {\n await client.connect()\n})\nafterAll(async () => {\n await client.close()\n})\nit('should perform CRUD operations', async () => {\n const result = await collection.insertOne({ test: true })\n expect(result.insertedId).toBeDefined()\n})\n"} |
Master MongoDB integration in production applications.
const { MongoClient } = require('mongodb');
const client = new MongoClient('mongodb://localhost:27017', {
useNewUrlParser: true,
useUnifiedTopology: true,
maxPoolSize: 10
});
async function main() {
try {
await client.connect();
const db = client.db('myapp');
const collection = db.collection('users');
// Use collection
} finally {
await client.close();
}
}
main().catch(console.error);
// Configure connection pool
const client = new MongoClient(
'mongodb://localhost:27017',
{
maxPoolSize: 10, // Maximum connections
minPoolSize: 5, // Minimum connections
: ,
:
}
);
const session = client.startSession();
try {
await session.withTransaction(async () => {
// Multiple operations atomic together
await users.insertOne({ name: 'John' }, { session });
await accounts.insertOne({ userId: '...', balance: 100 }, { session });
// If any fails, all roll back
});
} catch (error) {
console.error('Transaction failed:', error);
} finally {
await session.endSession();
}
try {
await collection.insertOne({ email: 'test@example.com' });
} catch (error) {
if (error.code === 11000) {
console.log('Duplicate key error');
} else if (error.name === 'MongoNetworkError') {
console.log('Network error - retry');
} else if (error.name === 'MongoWriteConcernError') {
console.log('Write concern failed');
} else {
console.log('Other error:', error);
}
}
const bulk = collection.initializeUnorderedBulkOp();
bulk.insert({ name: 'John', age: 30 });
bulk.insert({ name: 'Jane', age: 28 });
bulk.find({ age: { $lt: 25 } }).update({ $set: { status: 'young' } });
bulk.find({ name: 'old_user' }).remove();
await bulk.execute();
// Watch collection for changes
const changeStream = collection.watch();
changeStream.on('change', (change) => {
console.log('Change:', change.operationType);
console.log('Document:', change.fullDocument);
});
// With pipeline filtering
const pipeline = [
{ $match: { 'operationType': 'insert' } },
{ $match: { 'fullDocument.status': 'active' } }
];
const filteredStream = collection.watch(pipeline);
from pymongo import MongoClient
from pymongo.errors import DuplicateKeyError
import asyncio
# Synchronous
client = MongoClient('mongodb://localhost:27017')
db = client['myapp']
users = db['users']
# CRUD
user = users.insert_one({'name': 'John', 'email': 'john@example.com'})
found = users.find_one({'_id': user.inserted_id})
users.update_one({'_id': user.inserted_id}, {'$set': {'age': 30}})
users.delete_one({'_id': user.inserted_id})
# Transactions
def transfer_funds(from_user_id, to_user_id, amount):
with client.start_session() as session:
with session.start_transaction():
users.update_one(
{'_id': from_user_id},
{'$inc': {'balance': -amount}},
session=session
)
users.update_one(
{'_id': to_user_id},
{'$inc': {'balance': amount}},
session=session
)
# Error handling
try:
users.insert_one({'email': 'test@example.com'})
except DuplicateKeyError:
print('Email already exists')
import com.mongodb.client.MongoClient;
import com.mongodb.client.MongoClients;
import com.mongodb.client.MongoDatabase;
import com.mongodb.client.MongoCollection;
import org.bson.Document;
public class MongoDB {
public static void main(String[] args) {
// Connect
MongoClient mongoClient = MongoClients.create("mongodb://localhost:27017");
MongoDatabase database = mongoClient.getDatabase("myapp");
MongoCollection<Document> users = database.getCollection("users");
// Insert
Document user = new Document("name", "John")
.append("email", "john@example.com")
.append("age", 30);
users.insertOne(user);
// Find
Document found = users.find(new Document("email", "john@example.com")).first();
// Update
users.updateOne(
new Document("email", "john@example.com"),
new Document("$set", new Document("age", 31))
);
// Delete
users.deleteOne(new Document("email", "john@example.com"));
// Close
mongoClient.close();
}
}
// Pagination
async function paginate(collection, page = 1, limit = 10) {
const skip = (page - 1) * limit;
return collection
.find({})
.skip(skip)
.limit(limit)
.toArray();
}
// Batch processing
async function processBatch(collection, batchSize = 1000) {
const cursor = collection.find({});
let batch = [];
for (const doc of await cursor.toArray()) {
batch.push(doc);
if (batch.length === batchSize) {
await processBatch(batch);
batch = [];
}
}
if (batch.length > 0) {
await processBatch(batch);
}
}
// Lazy loading
class LazyLoader {
constructor(collection, query) {
this.cursor = collection.find(query).batchSize(100);
}
async next() {
return this.cursor.hasNext() ? this.cursor.next() : null;
}
}
✅ Always close connections properly ✅ Use connection pooling ✅ Handle errors appropriately ✅ Use transactions for multi-document operations ✅ Validate input data ✅ Use appropriate write concerns ✅ Monitor connection status ✅ Implement retry logic ✅ Use indexes for queries ✅ Log important operations ✅ Test error scenarios ✅ Use async/await for Node.js