MongoDB数据库：大数据时代下的高性能NoSQL解决方案

在当今数据爆炸的时代，传统的关系型数据库在处理海量数据时逐渐显露出局限性。随着Web 2.0、物联网和移动互联网的快速发展，数据呈现出多样性、高并发和灵活性的特点，这促使了NoSQL数据库的兴起。MongoDB作为其中比较受欢迎的非关系型数据库之一，凭借其灵活的文档模型、强大的扩展性和丰富的功能，已成为众多企业的首选数据存储解决方案。

什么是MongoDB？

MongoDB是一个基于分布式文件存储的开源数据库系统，由C++语言编写，旨在为Web应用提供可扩展的高性能数据存储解决方案。它属于NoSQL数据库类别，使用类似于JSON的BSON格式来存储数据，这意味着数据以文档的形式组织，而不是传统的关系型数据库中的行和列。

与传统的关系型数据库相比，MongoDB最大的优势在于其模式自由（schema-less）的特点。在关系型数据库中，需要预先定义表结构，任何结构调整都需要执行DDL语句。而MongoDB的文档模型允许每个文档拥有不同的字段，这种灵活性特别适合快速迭代的开发环境和半结构化数据的存储。

MongoDB的核心概念

要理解MongoDB，首先需要掌握其核心概念：

数据库（Database）：MongoDB中的最高层次，用于存储集合

1. 集合（Collection）：相当于关系型数据库中的表，但不需要固定的结构

2. 文档（Document）：MongoDB中的基本数据单元，相当于关系型数据库中的行

3. 字段（Field）：文档中的键值对，相当于关系型数据库中的列

4. _id：每个文档都必须有的唯一标识字段

MongoDB的安装与基本操作

让我们从MongoDB的安装开始，了解其基本使用方法。MongoDB提供了社区版和企业版，对于大多数用户来说，社区版已经足够使用。

<"http://m.kswtz.info/ats/1257_61922.tml"><"http://m.kswtz.info/ats/1257_49768.tml">

<"http://m.kswtz.info/ats/1257_81334.tml"><"http://m.kswtz.info/ats/1257_86363.tml">

<"http://m.kswtz.info/ats/1257_65432.tml"><"http://m.kswtz.info/ats/1257_18478.tml">

安装MongoDB（以Ubuntu为例）

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

// 创建或切换到名为mydb的数据库use mydb// 插入文档db.users.insertOne({
  name: "张三",
  age: 30,
  email: "zhangsan@example.com",
  hobbies: ["阅读", "游泳", "编程"],
  address: {
    city: "北京",
    district: "海淀区"
  }})// 查询所有文档db.users.find()// 条件查询db.users.find({age: {$gt: 25}})// 更新文档db.users.updateOne(
  {name: "张三"},
  {$set: {age: 31}})// 删除文档db.users.deleteOne({name: "张三"})

// 用户和地址的嵌入关系db.users.insertOne({
  name: "李四",
  age: 28,
  address: {
    street: "中关村大街",
    city: "北京",
    postalCode: "100080"
  },
  contacts: [
    {type: "手机", number: "13800138000"},
    {type: "邮箱", value: "lisi@example.com"}
  ]})

// 用户集合db.users.insertOne({
  _id: 1,
  name: "王五",
  age: 35})// 订单集合，通过userId引用用户db.orders.insertOne({
  orderId: "ORD001",
  userId: 1,
  total: 299.99,
  items: [
    {product: "笔记本电脑", price: 199.99},
    {product: "鼠标", price: 100.00}
  ]})

// 等于查询db.products.find({category: "电子设备"})// 比较查询db.products.find({price: {$gt: 100, $lt: 500}})// IN查询db.products.find({category: {$in: ["电子设备", "家居用品"]}})// 逻辑查询db.products.find({
  $and: [
    {price: {$gt: 100}},
    {stock: {$gt: 0}}
  ]})// 正则表达式查询db.users.find({name: /^张/})

// 订单数据分析db.orders.aggregate([
  // 阶段1：按日期筛选
  {
    $match: {
      orderDate: {
        $gte: new Date("2023-01-01"),
        $lt: new Date("2023-02-01")
      }
    }
  },
  // 阶段2：按用户分组并计算总金额
  {
    $group: {
      _id: "$userId",
      totalAmount: {$sum: "$total"},
      orderCount: {$sum: 1}
    }
  },
  // 阶段3：按总金额降序排序
  {
    $sort: {totalAmount: -1}
  },
  // 阶段4：限制输出数量
  {
    $limit: 10
  }])

// 创建单字段索引db.users.createIndex({email: 1})// 创建复合索引db.orders.createIndex({userId: 1, orderDate: -1})// 创建唯一索引db.users.createIndex({username: 1}, {unique: true})// 创建TTL索引（自动过期）db.sessions.createIndex({lastAccess: 1}, {expireAfterSeconds: 3600})// 查看索引db.users.getIndexes()// 分析查询性能db.users.find({email: "test@example.com"}).explain("executionStats")

// 初始化复制集rs.initiate({
  _id: "rs0",
  members: [
    {_id: 0, host: "mongodb1:27017"},
    {_id: 1, host: "mongodb2:27017"},
    {_id: 2, host: "mongodb3:27017"}
  ]})// 查看复制集状态rs.status()// 添加节点rs.add("mongodb4:27017")// 移除节点rs.remove("mongodb4:27017")

// 启用分片sh.enableSharding("mydatabase")// 创建分片键sh.shardCollection("mydatabase.users", {userId: 1})// 查看分片状态sh.status()

// 切换到admin数据库use admin// 创建管理员用户db.createUser({
  user: "admin",
  pwd: "password123",
  roles: ["root"]})// 创建应用数据库用户use myapp
db.createUser({
  user: "appuser",
  pwd: "apppassword",
  roles: [
    {role: "readWrite", db: "myapp"},
    {role: "read", db: "reporting"}
  ]})// 查看用户db.getUsers()

const { MongoClient } = require('mongodb');// 连接字符串const uri = "mongodb://localhost:27017";const client = new MongoClient(uri);async function main() {
  try {
    // 连接数据库
    await client.connect();
    console.log("成功连接到MongoDB");
    
    const database = client.db("mydb");
    const collection = database.collection("users");
    
    // 插入数据
    const result = await collection.insertOne({
      name: "赵六",
      age: 25,
      email: "zhaoliu@example.com"
    });
    console.log(`插入文档ID: ${result.insertedId}`);
    
    // 查询数据
    const users = await collection.find({age: {$gt: 20}}).toArray();
    console.log("查询结果:", users);
    
  } finally {
    // 关闭连接
    await client.close();
  }}main().catch(console.error);

from pymongo import MongoClientfrom bson.objectid import ObjectId# 连接MongoDBclient = MongoClient('mongodb://localhost:27017/')db = client['mydb']collection = db['users']# 插入文档user_id = collection.insert_one({
    'name': '钱七',
    'age': 32,
    'email': 'qianqi@example.com'}).inserted_idprint(f"插入的文档ID: {user_id}")# 查询文档for user in collection.find({'age': {'$gt': 25}}):
    print(user)

// 查看数据库状态db.stats()// 查看集合状态db.users.stats()// 查看当前操作db.currentOp()// 查看慢查询db.setProfilingLevel(1, 100) // 记录超过100ms的操作db.system.profile.find().sort({ts: -1}).limit(10)