mongodb-module-skill

MongoDB Module Skill

面向已有后端项目的开发者，快速集成 MongoDB 能力。

能力清单

能力	说明
连接配置	MongoClient/连接池/环境变量配置
文档模型	Document/Entity 设计
CRUD 操作	增删改查/批量操作
聚合查询	Match/Group/Lookup/Pipeline
索引优化	索引设计/慢查询优化
事务处理	多文档事务

触发场景

用户说"帮我加 MongoDB"或"集成 MongoDB"时触发。

核心配置

Java (Spring Boot)

# application.yml
spring:
  data:
    mongodb:
      uri: mongodb://${MONGO_HOST:localhost}:${MONGO_PORT:27017}/${MONGO_DATABASE:myapp}
      uuid-representation: standard

Python (FastAPI)

# config.py
from pydantic_settings import BaseSettings

class Settings(BaseSettings):
    mongo_host: str = "localhost"
    mongo_port: int = 27017
    mongo_database: str = "myapp"

# database.py
from motor.motor_asyncio import AsyncIOMotorClient

client = AsyncIOMotorClient(f"mongodb://{host}:{port}")
db = client[database]

文档模型设计

基础文档模板

@Document(collection = "users")
public class User {
    @Id
    private String id;
    
    @Field("username")
    private String username;
    
    @Field("password")
    private String password;
    
    @Field("nickname")
    private String nickname;
    
    @Field("status")
    private Integer status = 1;
    
    @Field("created_at")
    private LocalDateTime createdAt;
    
    @Field("updated_at")
    private LocalDateTime updatedAt;
}

Python (Motor)

from pydantic import BaseModel
from datetime import datetime
from typing import Optional

class User(BaseModel):
    username: str
    password: str
    nickname: Optional[str] = None
    status: int = 1
    created_at: datetime = datetime.now()
    updated_at: datetime = datetime.now()
    class Config:
        collection = "users"

CRUD 操作

Java

@Repository
public class UserRepository {
    
    @Autowired
    private MongoTemplate mongoTemplate;
    
    // 创建
    public User save(User user) {
        return mongoTemplate.save(user);
    }
    
    // 查询
    public User findById(String id) {
        return mongoTemplate.findById(id, User.class);
    }
    
    public List<User> findByStatus(Integer status) {
        Query query = new Query(Criteria.where("status").is(status));
        return mongoTemplate.find(query, User.class);
    }
    
    // 更新
    public long update(User user) {
        Query query = new Query(Criteria.where("_id").is(user.getId()));
        Update update = new Update()
            .set("nickname", user.getNickname())
            .set("updated_at", LocalDateTime.now());
        return mongoTemplate.updateFirst(query, update, User.class).getModifiedCount();
    }
    
    // 删除
    public long deleteById(String id) {
        Query query = new Query(Criteria.where("_id").is(id));
        return mongoTemplate.remove(query, User.class).getDeletedCount();
    }
}