MongoDB的使用方法与简单操作

傷城~ 2021-12-09 21:59 421阅读 0赞

#### mongodb简介 ####

> MongoDB是一个跨平台，面向文档的数据库，提供高性能，高可用性和易于扩展。MongoDB是工作在集合和文档上一种概念。

##### 数据库 #####

数据库是一个集合的物理容器。每个数据库获取其自己设定在文件系统上的文件。一个单一的MongoDB服务器通常有多个数据库。

##### 集合 #####

集合是一组MongoDB的文件。它与一个RDBMS表是等效的。一个集合存在于数据库中。集合不强制执行模式。集合中的文档可以有不同的字段。通常情况下，在一个集合中的所有文件都是类似或相关目的。

##### 文档 #####

文档是一组键值对。文档具有动态模式。动态模式是指，在同一个集合的文件不必具有相同一组集合的文档字段或结构，并且相同的字段可以保持不同类型的数据。

##### 示例文档 #####

{ 
       _id: ObjectId(7df78ad8902c)
       title: 'MongoDB Overview', 
       description: 'MongoDB is no sql database',
       by: 'yiibai tutorial',
       url: 'http://www.yiibai.com',
       tags: ['mongodb', 'database', 'NoSQL'],
       likes: 100, 
       comments: [	
          { 
             user:'user1',
             message: 'My first comment',
             dateCreated: new Date(2011,1,20,2,15),
             like: 0 
          },
          { 
             user:'user2',
             message: 'My second comments',
             dateCreated: new Date(2011,1,25,7,45),
             like: 5
          }
       ]
    }

#### 软件安装 ####

详细见文档

> sudo apt install mongodb  
> netstat -ant |grep 27017

#### windows安装MongoDB ####

[https://www.mongodb.org/dl/win32/x86\_64-2008plus-ssl][https_www.mongodb.org_dl_win32_x86_64-2008plus-ssl]

启动，先加到环境变量中

> mongo

#### 一、操作mongoDB数据库 ####

##### 1、创建数据库 #####

语法：use 数据库名  
 注意：如果数据库不存在则创建数据库，否则切换到指定的数据库  
 注意：如果刚刚创建的数据库不在列表内，如果要显示它，我们需要向刚刚创建的数据库中插入一些数据

use school
    
    db.student.insert({name:"tom", age:18,gender:1,address:"北京", isDelete:0})

##### 2、删除数据库 #####

#前提：使用当前数据库(use 数据库名)
    db.dropDatabase()

##### 3、查看所有数据 #####

show dbs

##### 4、查看当前正在使用的数据库 #####

a、db
        b、db.getName()

##### 5、断开连接 #####

exit

##### 6、查看命令api #####

help

#### 二、集合操作 ####

##### 1、查看当前数据库下有哪些集合 #####

show collections

##### 2、创建集合 #####

语法：db.集合名.insert(文档)

db.student.insert({name:"tom", age:18, gender:1,address:"北京", isDelete:0})

> 会自动创建一个student的集合

##### 3、删除当前数据库中的集合 #####

语法：db.集合名.drop()

db.class.drop()

#### 三、文档操作 ####

##### 1、插入文档 #####

a、使用insert()方法插入文档

> 语法：  
> db.集合名.insert(文档)  
> db.集合名.insert(\[文档1, 文档2, ……, 文档n\])

例1：插入一个学生

db.student.insert({name:"lilei", age:19, gender:1,address:"北京", isDelete:0})

例2：插入多个学生：

db.student.insert([{name:"海妹妹", age:17, gender:0,address:"北京", isDelete:0},{name:"韩梅梅", age:20, gender:0,address:"上海", isDelete:0}])

b、使用save()方法插入文档

> 语法：db.集合名.save(文档)

说明：如果不指定\_id字段，save()方法类似于insert()方法。如果指定\_id字段，则会更新\_id字段的数据

db.student.save({name:"poi", age:22, gender:1,address:"石家庄", isDelete:0})

db.student.save({_id:ObjectId("59950962019723fe2a0d8d17"),name:"poi", age:23, gender:1,address:"石家庄", isDelete:0})

##### 2、文档更新 #####

a、update()方法用于更新已存在的文档

语法：

db.集合名.update(
                query,
                update,
                {
                    upsert:<boolean>,
                    multi:<boolean>,
                   
                }
            )

参数说明：

> 1、query：update的查询条件，类似于sql里update语句内where后面的内容  
> 2、update：update的对象和一些更新的操作符($set,$inc,$unset)等，$set直接更新操作，$unset删除某一列，$inc在原有的基础上累加后更新  
> 3、upset：可选，如果不存在update的记录，是否当新数据插入，true为插入，False为不插入，默认为false。  
> 4、multi：可选，mongodb默认是false，只更新找到的第一条记录，如果这个参数为true,就按照条件查找出来的数据全部更新

例：将lilei的年龄更新为25

db.student.update({name:"lilei"},{$set:{age:25}})

例：将lilei的年龄增加25

db.student.update({name:"lilei"},{$inc:{age:25}})

更改多条：

db.student.update({name:"poi"},{$set:{age:42}},{multi:true})

删除所有age列:

db.student.udpate({name:"poi"},{$unset:{age:""}},{multi:true})

#不插入，但是更新多条
    
    db.aaa.update({name:'hule',age:44},{$set:{name:'hule22'}},false,true)
    
    #如果不能匹配则插入，如果匹配则更新多条
    
    db.aaa.update({name:'hule',age:44},{$set:{name:'hule55'}},true,true)

##### 3、文档删除 #####

> 说明：在执行remove()函数前，先执行find()命令来判断执行的条件是否存在是一个良好习惯

语法：

db.集合名.remove(
                query,
                {
                    justOne:<boolean>,
                }
            )

参数说明：

>  query：可选，删除的文档的条件  
>  justOne：可选，如果为true或1，则只删除一个文档

db.student.remove({name:"poi"},{justOne:1})

##### 4、文档查询 #####

a、find()方法

> 语法：db.集合名.find()

查询集合下所有的文档(数据)：

db.student.find()

b、find()方法查询指定列

语法：db.集合名.find(
                query,
                {
                    <key>:1,
                    <key>:1
                }
            )

参数说明：

> query：查询条件  
> key：要显示的字段，1表示显示

db.student.find({gender:0},{name:1,age:1})
     db.student.find({},{name:1,age:1})

c、pretty()方法以格式化的方式来显示文档

db.student.find().pretty()

d、findOne()方法查询匹配结果的第一条数据

db.student.findOne({gender:0})

##### 5、查询条件操作符 #####

> 作用：条件操作符用于比较两个表达式并从Mongodb集合中获取数据

a、大于 : $gt

#语法：
    db.集合名.find({<key>:{$gt:<value>}})
    #示例：
    db.student.find({age:{$gt:20}})

b、大于等于 : $gte

#语法：
    db.集合名.find({<key>:{$gte:<value>}})

c、小于 : $lt

#语法：
    db.集合名.find({<key>:{$lt:<value>}})

d、小于等于 : $lte

#语法：
    db.集合名.find({<key>:{$lte:<value>}})

e、大于等于 和 小于等于 : $gte 和 $lte

#语法：
     db.集合名.find({<key>:{$gte:<value>,$lte:<value>}})

f、等于 : 冒号

#语法：
    db.集合名.find({<key>:<value>})

g、使用\_id进行查询

#语法：
    db.student.find({"_id":ObjectId("id值")})
    
    #示例db.student.find({"_id":ObjectId("5995084b019723fe2a0d8d14")})

h、查询某个结果集的数据条数

db.student.find().count()

i、查询某个字段的值当中是否包含另一个值

#语法：示例：
    db.student.find({name:/ile/})

j、查询某个字段的值是否以另一个值开头

#示例：
    db.student.find({name:/^li/})

##### 6、条件查询and 和 or #####

a、AND条件

#语法：
     db.集合名.find({条件1,条件2,……,条件n})
            
     #示例：
     db.student.find({gender:0,age:{$gt:16}})

b、OR条件

#语法：
                db.集合名.find(
                    {
                        $or:[{条件1},{条件2},……,{条件n}]
                    }
                )

例子：查找age=17 or age>=20的数据

db.student.find({$or:[{age:17},{age:{$gte:20}}]})

c、AND和OR联合使用

db.集合名.find(
                    {
                        条件1,
                        条件2,
                        $or:[{条件3},{条件4}]
                    }
                )

##### 7、limit、skip #####

a、limit()：读取指定数量的数据记录

db.student.find().limit(3)

b、skip()：跳过指定数量的数据

db.student.find().skip(3)

c、skip与limit联合使用

通常用这种方式来实现分页功能

db.student.find().skip(3).limit(3)

##### 8、排序 #####

#语法：
    db.集合名.find().sort({<key>:1|-1})
    #示例：
    db.student.find().sort({age:1})

注意：1表示升序，-1表示降序

#### 三、python and mongodb ####

##### 1. 安装PyMongo #####

pip3 install  PyMongo

##### 2. 建立连接 #####

使用PyMongo时，第一步是运行 mongod 实例创建一个MongoClient。如下：

from pymongo import MongoClient
    client = MongoClient()

上述代码将连接默认主机和端口。 也可以明确指定主机和端口，如下所示：

from pymongo import MongoClient
    #client = MongoClient() 
    client = MongoClient('localhost', 27017)

或使用MongoDB URI格式：

client = MongoClient('mongodb://localhost:27017/')

##### 3. 获取数据库 #####

MongoDB的一个实例可以支持多个独立的数据库。 在使用PyMongo时，可以使用MongoClient实例上的属性的方式来访问数据库，笔者喜欢用字典的形式来获取数据库，一次性解决属性重名的问题：

db = client.pythondb

如果数据库名称使用属性方式访问无法正常工作(如：`python-db`)，则可以使用字典样式访问：

db = client['python-db']

##### 4. 获取集合 #####

集合是存储在MongoDB中的一组文档，可以类似于关系数据库中的表。 在PyMongo中获取集合的工作方式与获取数据库相同：

collection = db.python_collection

或(使用字典方式访问)：

collection = db['python-collection']

##### 5. 文档 #####

MongoDB中的数据使用JSON方式来表示文档(并存储)。 在PyMongo中使用字典来表示文档。例如，以下字典可能用于表示博客文章：

import datetime
    from pymongo import MongoClient
    client = MongoClient()
    
    post = { "author": "Mike",
             "text": "My first blog post!",
             "tags": ["mongodb", "python", "pymongo"],
             "date": datetime.datetime.utcnow()}

##### 6. 插入文档 #####

> 要将文档插入到集合中，可以使用`insert_one()`方法：

#!/usr/bin/python3
    #coding=utf-8
    
    import datetime
    from pymongo import MongoClient
    client = MongoClient()
    
    db = client.pythondb
    
    post = { "author": "Maxsu",
             "text": "My first blog post!",
             "tags": ["mongodb", "python", "pymongo"],
             "date": datetime.datetime.utcnow()}
    
    posts = db.posts
    post_id = posts.insert_one(post).inserted_id
    print ("post id is ", post_id)
    db.close()

插入文档时，如果文档尚未包含“`_id`”键，则会自动添加“`_id`”。 “`_id`”的值在集合中必须是唯一的。 `insert_one()`返回一个`InsertOneResult`的实例

> 直接插入

from pymongo import MongoClient
    
    # 连接服务器
    conn = MongoClient("localhost", 27017)
    
    # 连接数据库
    db = conn.mydb
    
    # 获取集合
    collection = db.student
    
    #添加文档
    #collection.insert(
    { "name":"abc", "age":19, "gender":1,"address":"北京", "isDelete":0})
    # 插入多条需要collection.insert([{..},{..}])
    collection.insert([
    { "name":"abc1", "age":19, "gender":1,"address":"北京", "isDelete":0},
    { "name":"abc2", "age":19, "gender":1,"address":"北京", "isDelete":0}])
    
    #断开
    conn.close()

##### 7. 查询文档 #####

import pymongo
    from pymongo import MongoClient
    from bson.objectid import ObjectId#用于ID查询
    
    # 连接服务器
    conn = MongoClient("localhost", 27017)
    
    # 连接数据库
    db = conn.mydb
    
    # 获取集合
    collection = db.student
    
    # 查询文档
    
    # 查询部分文档
    res = collection.find({ "age":{ "$gt":18}})
    for row in res:
        print(row)
        print(type(row))
    
    
    # 查询所有文档
    res = collection.find()
    for row in res:
        print(row)
        print(type(row))
    
    #统计查询
    res = collection.find({ "age":{ "$gt":18}}).count()
    print(res)
    
    
    #根据id查询
    
    res = collection.find({ "_id":ObjectId("5995084b019723fe2a0d8d14")})
    print(res[0])
    
    
    # 排序
    res = collection.find().sort("age")#升序
    res = collection.find().sort("age", pymongo.DESCENDING)#降序
    for row in res:
        print(row)
    
    # 分页查询
    res = collection.find().skip(3).limit(5)
    for row in res:
        print(row)
    
    #断开
    conn.close()

##### 8.更新文档 #####

from pymongo import MongoClient
    
    # 连接服务器
    conn = MongoClient("localhost", 27017)
    # 连接数据库
    db = conn.mydb
    # 获取集合
    collection = db.student
    
    collection.update({ "name":"lilei"},{ "$set":{ "age":25}})
    
    #断开
    conn.close()

##### 9.删除文档 #####

from pymongo import MongoClient
    
    # 连接服务器
    conn = MongoClient("localhost", 27017)
    # 连接数据库
    db = conn.mydb
    # 获取集合
    collection = db.student
    
    collection.remove({ "name":"lilei"})
    #全部删除
    collection.remove()
    #断开
    conn.close()

[https_www.mongodb.org_dl_win32_x86_64-2008plus-ssl]: https://www.mongodb.org/dl/win32/x86_64-2008plus-ssl