[大数据]Mongodb 使用

mongodb的操作

一、基本概念

mongodb是属于文档型的非关系型数据库，是开源、高性能、高可用、可扩展的

二、MySQL redis 和mongo之间的对比

三、基本操作

展示所有数据库

show databases

使用或创建数据库

use databases_name(表名称);

创建表

db.createCollection("code");  # 创建code表

展示表

db.code.find();

删除表

db.code.drop();

删除表中数据

db.code.remove({'name':'admin','age':20});

添加数据

db.code.insert({name:"admin",age:20});

修改数据

db.code.update({name:"admin"},{$set:{name:"dong"}})

创建过期索引

# datetime: 创建索引所在的字段 为date形式 
# expireAfterSeconds：为过期时间 表示30秒后删除数据
db.code.createIndex({"datetime":1},{expireAfterSeconds:30});

查看所有索引

db.code.getIndexes()

查看当前使用的数据库

db

删除当前使用的数据库

db.dropDatabase()

四、封装pymongo，方便项目集成

pip install pymongo

import datetime
import pymongo
import pytz


# 设置时区
tzinfo = pytz.timezone("Asia/Shanghai")

# 连接mongo数据库类
class MyMongo:
    def __init__(self):
        # 初始化数据库链接
        self.client = pymongo.MongoClient(host="localhost",port=27017,tz_aware=True,tzinfo=tzinfo)
        # 声明数据库
        self.db = self.client.mytornado
        # 声明具体的表
        self.table = self.db.code


    # 插入数据
    def insert(self,data):
        return self.table.insert_one(data)


    # 查询操作
    def find(self,data):
        res = self.table.find_one(data)
        return res