MongoDB数据库：开启数据存储新纪元

来源：这里教程网时间：2026-03-03 22:55:12 作者：

在当今数据爆炸的时代，传统关系型数据库在处理海量非结构化数据时面临诸多挑战。MongoDB作为领先的NoSQL数据库，以其灵活的文档模型和卓越的扩展性，正在成为企业数据管理的首选解决方案。

什么是MongoDB？

MongoDB是一个基于分布式文件存储的开源数据库系统，采用面向文档的数据模型，使用类似JSON的BSON格式存储数据。与传统关系型数据库相比，MongoDB最大的优势在于其灵活的模式设计，允许开发人员快速适应业务需求的变化。

核心特性

文档数据模型：数据以文档形式存储，每个文档可以包含不同的字段，完美适应半结构化数据。

高性能：内存映射存储引擎和丰富的索引支持，提供卓越的读写性能。

水平扩展：通过分片技术实现数据分布式存储，轻松应对数据增长。

环境搭建

安装MongoDB

以下是在Ubuntu系统上安装MongoDB的步骤：

bash

复制下载

# 导入MongoDB公钥wget -qO - https://www.mongodb.org/static/pgp/server-6.0.asc | sudo apt-key add -# 创建源列表文件echo "deb [ arch=amd64,arm64 ] https://repo.mongodb.org/apt/ubuntu focal/mongodb-org/6.0 multiverse" | sudo tee /etc/apt/sources.list.d/mongodb-org-6.0.list# 更新包管理器sudo apt-get update# 安装MongoDBsudo apt-get install -y mongodb-org# 启动服务sudo systemctl start mongodsudo systemctl enable mongod# 验证安装mongosh --version

基础操作实战

让我们通过一个电商平台的例子来学习MongoDB的基本操作：<"barca.shcc168.cn"><"manc.shcc168.cn"><"manu.shcc168.cn"><"liv.shcc168.cn"><"arse.shcc168.cn"><"chel.shcc168.cn"><"tot.shcc168.cn"><"lt833.shcc168.cn"><"green.shcc168.cn"><"nine.shcc168.cn">

javascript

复制下载

// 创建并使用数据库use ecommerce// 插入商品文档db.products.insertOne({
  product_id: "P10001",
  name: "华为Mate60 Pro",
  category: "智能手机",
  price: 6999,
  specifications: {
    brand: "华为",
    screen: "6.82英寸",
    memory: "12GB",
    storage: "512GB",
    color: "雅川青"
  },
  inventory: {
    stock: 50,
    reserved: 5,
    available: 45
  },
  tags: ["5G", "旗舰", "鸿蒙系统"],
  created_time: new Date(),
  updated_time: new Date()})// 批量插入商品db.products.insertMany([
  {
    product_id: "P10002",
    name: "iPhone 15",
    category: "智能手机",
    price: 5999,
    specifications: {
      brand: "苹果",
      screen: "6.1英寸",
      memory: "8GB",
      storage: "128GB"
    },
    inventory: {
      stock: 30,
      reserved: 2,
      available: 28
    }
  },
  {
    product_id: "P10003",
    name: "小米14",
    category: "智能手机",
    price: 3999,
    specifications: {
      brand: "小米",
      screen: "6.36英寸",
      memory: "12GB",
      storage: "256GB"
    }
  }])// 查询所有商品db.products.find()// 条件查询：价格在4000-8000元之间的手机db.products.find({
  category: "智能手机",
  price: { $gte: 4000, $lte: 8000 }})// 更新商品库存db.products.updateOne(
  { product_id: "P10001" },
  { 
    $inc: { "inventory.stock": 10 },
    $set: { updated_time: new Date() }
  })// 删除商品db.products.deleteOne({ product_id: "P10003" })

高级查询功能

MongoDB提供丰富的查询操作符，支持复杂的数据检索：

<"god.shcc168.cn"><"day.shcc168.cn"><"spid.shcc168.cn"><"lt178.shcc168.cn"><"lt919.shcc168.cn">

<"lt01.shcc168.cn"><"zmspt.shcc168.cn"><"ylpt.shcc168.cn"><"xhpt.shcc168.cn"><"dxpt.shcc168.cn">

javascript

复制下载

// 多条件组合查询db.orders.find({
  status: { $in: ["pending", "shipped"] },
  total_amount: { $gt: 1000 },
  order_date: {
    $gte: new Date("2023-12-01"),
    $lt: new Date("2024-01-01")
  }})// 数组查询：查找包含特定标签的商品db.products.find({
  tags: { $all: ["5G", "旗舰"] }})// 正则表达式查询db.products.find({
  name: /华为/})// 嵌套文档查询db.products.find({
  "specifications.brand": "华为",
  "specifications.memory": "12GB"})// 排序和分页db.products.find()
  .sort({ price: -1 })
  .skip(0)
  .limit(10)

聚合框架实战

聚合管道提供强大的数据分析能力：

javascript

复制下载

// 销售数据分析db.orders.aggregate([
  // 筛选条件
  {
    $match: {
      status: "completed",
      order_date: {
        $gte: new Date("2023-12-01")
      }
    }
  },
  // 展开订单项
  {
    $unwind: "$items"
  },
  // 按商品分类统计
  {
    $group: {
      _id: "$items.category",
      total_sales: { $sum: "$items.amount" },
      total_quantity: { $sum: "$items.quantity" },
      average_price: { $avg: "$items.unit_price" },
      order_count: { $sum: 1 }
    }
  },
  // 结果排序
  {
    $sort: { total_sales: -1 }
  },
  // 输出格式调整
  {
    $project: {
      category: "$_id",
      total_sales: 1,
      total_quantity: 1,
      average_price: { $round: ["$average_price", 2] },
      _id: 0
    }
  }])

索引优化

合理的索引设计是保证性能的关键：

<"yhpt.shcc168.cn"><"yxpt.shcc168.cn"><"xfzpt.shcc168.cn"><"sspt.shcc168.cn"><"dpt.shcc168.cn">

<"sqd.shcc168.cn"><"ball.shcc168.cn"><"lt198.shcc168.cn"><"lqty.shcc168.cn"><"yyty.shcc168.cn">

javascript

复制下载

// 创建单字段索引db.products.createIndex({ product_id: 1 })// 创建复合索引db.orders.createIndex({ 
  customer_id: 1, 
  order_date: -1 })// 创建唯一索引db.users.createIndex(
  { email: 1 },
  { unique: true })// 创建文本索引db.products.createIndex({
  name: "text",
  description: "text"})// 创建TTL索引db.sessions.createIndex(
  { created_at: 1 },
  { expireAfterSeconds: 3600 })// 查看索引db.products.getIndexes()// 分析查询性能db.orders.find({
  customer_id: "C1001",
  status: "completed"}).explain("executionStats")

实战案例：用户管理系统

javascript

复制下载

// 用户文档结构db.users.insertOne({
  user_id: "U1001",
  username: "zhang_san",
  profile: {
    name: "张三",
    gender: "male",
    birth_date: new Date("1990-05-15"),
    avatar: "/avatars/u1001.jpg"
  },
  contact: {
    email: "zhangsan@example.com",
    mobile: "+8613800138000",
    addresses: [
      {
        type: "home",
        province: "北京市",
        city: "北京市",
        district: "海淀区",
        detail: "中关村大街100号",
        is_default: true
      }
    ]
  },
  account: {
    status: "active",
    level: "VIP1",
    points: 1000,
    last_login: new Date()
  },
  created_time: new Date()})// 用户行为分析const userStats = db.users.aggregate([
  {
    $project: {
      user_id: 1,
      username: 1,
      account_level: "$account.level",
      last_login: "$account.last_login",
      membership_days: {
        $floor: {
          $divide: [
            { $subtract: [new Date(), "$created_time"] },
            1000 * 60 * 60 * 24
          ]
        }
      }
    }
  },
  {
    $sort: { membership_days: -1 }
  }])

数据安全

javascript

复制下载

// 创建管理员用户use admin
db.createUser({
  user: "admin",
  pwd: "SecurePassword123!",
  roles: ["root"]})// 创建应用用户use ecommerce
db.createUser({
  user: "app_user",
  pwd: "AppPassword456!",
  roles: [
    {
      role: "readWrite",
      db: "ecommerce"
    }
  ]})

性能监控

javascript

复制下载

// 查看数据库状态db.stats()// 查看集合状态db.products.stats(1024)// 启用慢查询日志db.setProfilingLevel(1, 100)// 查看慢查询db.system.profile.find()
  .sort({ ts: -1 })
  .limit(5)// 监控当前操作db.currentOp()// 服务器状态const status = db.serverStatus()print(`当前连接数: ${status.connections.current}`)print(`内存使用: ${status.mem.resident}MB`)