mongo — MongoDB 客户端

mongo 模块提供了 MongoDB 数据库操作功能。

引入方式

var mongo = require("mongo")

获取集合

var db = mongo.Database("mydb")
var users = db.Collection("users")

CRUD 操作

Find — 查询多文档

var docs = users.Find({ age: { $gt: 18 } })

FindOne — 查询单文档

var doc = users.FindOne({ _id: "507f1f77bcf86cd799439011" })

InsertOne — 插入单文档

users.InsertOne({ name: "张三", age: 25, email: "zhangsan@example.com" })

Insert — 插入单文档（简化版）

users.Insert({ name: "张三", age: 25, email: "zhangsan@example.com" })

InsertMany — 批量插入

users.InsertMany([
    { name: "张三", age: 25 },
    { name: "李四", age: 30 }
])

UpdateOne — 更新单文档

users.UpdateOne({ name: "张三" }, { $set: { age: 26 } })

Update — 更新单文档（简化版）

users.Update({ name: "张三" }, { $set: { age: 26 } })

UpdateMany — 批量更新

users.UpdateMany({ age: { $lt: 18 } }, { $set: { status: "minor" } })

DeleteOne — 删除单文档

users.DeleteOne({ name: "张三" })

Delete — 删除单文档（简化版）

users.Delete({ id: 1 })

DeleteMany — 批量删除

users.DeleteMany({ status: "inactive" })

其他操作

CountDocuments — 统计文档数

var count = users.CountDocuments({ age: { $gt: 18 } })

Distinct — 去重查询

var names = users.Distinct("name", {})

Aggregate — 聚合查询

var result = users.Aggregate([
    { $match: { age: { $gte: 18 } } },
    { $group: { _id: "$city", count: { $sum: 1 } } }
])

索引管理

users.CreateIndex({ name: 1 })       // 创建索引
users.ListIndexes()                    // 列出索引
users.DropIndex("name_1")             // 删除索引

完整示例

var mongo = require("mongo")

var db = mongo.Database("myapp")
var users = db.Collection("users")

// 插入文档
users.InsertOne({
    name: "张三",
    age: 25,
    email: "zhangsan@example.com",
    createdAt: now()
})

// 查询文档
var adults = users.Find({ age: { $gte: 18 } })

// 更新文档
users.UpdateOne({ name: "张三" }, { $set: { age: 26 } })

// 聚合查询
var stats = users.Aggregate([
    { $group: { _id: null, avgAge: { $avg: "$age" }, total: { $sum: 1 } } }
])

// 统计数量
var count = users.CountDocuments({})