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

@[toc]

数据库连接与操作

关系数据库：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('w15\mongo_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
<pymongo.results.InsertManyResult object at 0x000001CF7FB8FF08>

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的固态硬盘，速度杠杠的，亲们 
！别犹豫了买吧！

• 排序
  对查询结果进行排序
• 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 = { "$set": { "address": "Canyon 123" } }
update_one(myquery, newvalues) • myquery = { "address": { "$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