python MongoDB数据库 *** 作与连接和ORM

python MongoDB数据库 *** 作与连接和ORM

文章目录
数据库连接与 *** 作

关系数据库：PostgreSQL、MySQL
非关系数据库：MongoDB
pymongo使用

创建连接

from pymongo import MongoClient
client = MongoClient()
client = MongoClient(‘localhost:27017/’)

指定数据库

db = client.test_database
db = client[‘test-database’]

指定集合（collection）

collection = db.test_collection
collection = db[‘test-collection’]

查找所有数据库的名字

import pymongo
myclient = pymongo.MongoClient(“mongodb://localhost:27017/”)
dblist = myclient.list_database_names()
for db in dblist:
print(db)
mydb = myclient[“student”]
mycol = mydb[“comments”]
myclient.close()

admin
config
local
student

插入文档

insert_one()

批量插入

insert_many()

from pymongo import MongoClient
import os
import sys
texts=[]
with open(‘w15mongo_texts.txt’,encoding=‘utf-8’) as f:
for line in f:
items=line.strip().split(’t’)
texts.append({“text”:items[0],“score”:int(items[1])})
print(‘load %d lines’ % len(texts))
client=MongoClient(‘localhost’,27017)
db=client.student
collection=db.comments
result=collection.insert_many(texts)
print(result)
client.close()

load 20000 lines

returns a single document matching a query (or None if there are no matches)

find_one([query])
返回结果为字典

To get more than a single document as the result of a query

find([query])
returns a Cursor instance that can be iterated
find() .limit(size) #控制返回的数目

import sys
from pymongo import MongoClient

#0 差评；1 好评;

with MongoClient(‘localhost’,27017) as client:
db=client.student
collection=db.comments

re=collection.find_one()
re=collection.find_one({"score":1})
if 'text' in re:
    print(re['text'])
res=collection.find({"score":0}).limit(5)  #int(sys.argv[1])}).limit(5)
for index, doc in enumerate(res,start=1):
    if 'text' in doc and 'score' in doc:
        print(index,doc['score'],doc['text'])

开机有点烦锁，联网时有些软件会自动下载安装！！
1 0 用着用着就卡死了 卖家只会说是正常的 太坑了
2 0 垃圾电脑，慢死，刚买的就卡。跟三年前老电脑一个德行，
3 0 服务太垃圾了，客服不理人，根本就没有保障，电脑卡的要死，多开几个网面就死机不动。我怀疑是不是翻新机。这样的店铺怎么不早点
关闭。妈的
4 0 破电脑 我已经去修了两次了 今天是第三次 我想知道 动不动黑屏 开不了机是什么鬼！！！我已经无力吐槽了非常的火大 我想知道上
个 qq 看个电视都卡的卡的电脑 是怎么做打游戏不卡的？
5 0 体验感不好，一是没有发票提供，二是装不了一些系统，如ＧＩＳ，这都没法工作的，郁闷不是一点点

计数
返回满足要求的文档数
count_documents({})

from pymongo import MongoClient
with MongoClient(‘localhost’,27017) as client:
db=client.student
collection=db.comments

c=collection.count_documents({"text":{"$regex":"机箱"}})
print(c)
docs=collection.find({"text":{"$regex":"机箱"}})
for doc in docs:
    print(doc['text'])

1
买之前纠结了很久，本来想买个迷你的台式机箱自己组装个电脑，但是看到台式机箱后面那一坨线心理真是不舒服，还是笔记本好，干干净净
，携带方便，用于工作和娱乐都没有问题，外出不好携带的！电脑外观很漂亮，重量也很轻，关键是自带512G的固态硬盘，速度杠杠的，亲们
！别犹豫了买吧！最后，如果你的时间不是很紧张，并且又想快速的python提高，最重要的是不怕吃苦，建议你可以架尉♥信（同音）：276 3177 065 ，那个真的很不错，很多人进步都很快，需要你不怕吃苦哦！大家可以去添加上看一下~

排序
对查询结果进行排序
sort("name",1) #ascending
sort("name",-1) #descending

from pymongo import MongoClient
with MongoClient(‘localhost’,27017) as client:
db=client.student
collection=db.comments

docs=collection.find({"text":{"$regex":"开机"}}).sort("score",1)
for doc in docs:
    print(doc['text'], doc['score'])

删除文档

delete_one(myquery)
delete_many(myquery)
delete_many({}) #删除collection中的所有文档
drop() #删除整个collection

更新：比较复杂

myquery = { “address”: “Valley 345” }
newvalues = { “KaTeX parse error: Expected 'EOF', got '}' at position 35: …"Canyon 123" } }̲ update_one(myq…regex”: “^S”}}
newvalues = { “$set”: { “name”: “Minnie” }}
x = mycol.update_many(myquery, newvalues)

ORM简介

面向关系数据库的ORM
sqlalchemy / peewee / PonyORM / Django ORM

一般的逻辑
创建mapping，业务逻辑中的实体类与数据库的表建立对应关系
构建数据类和会话后进行存储或查询

面向非关系数据库的ORM
Django ORM / MongoEngine / MongoKit / Ming