初窥Python(一)——使用pymongo连接MongoDB

Python 可以使用 pymongo 库方便的操作 MongoDB 。插播一句,MongoDB 不同于关系型结构的三层结构——database--> table --> record,它的层级为 database -->collection --> document 。这里不重点介绍 MongoDB  用法,主要来看一下如何用 Python 使用 MongoDB。

1.安装MongoDB和pymongo

[[email protected] ~]# pip install pymongo
[[email protected] ~]# yum install -y mongodb-server

启动 MongoDB ,其中 --dbpath 指定数据存放目录,默认为 /data/db ,如果目录不存在会报错; --logpath 指定日志输出文件,日志会按照时间自动切分:

[[email protected] ~]# mongod --dbpath=/data/mongodb/db/--logpath=/data/mongodb/mongodb.log

注:如果没有 pip 命令,需要使用 yum 进行安装:

[[email protected] ~]# yum install -y python-pip

2.建立连接:

[[email protected] ~]# python
>>> import pymongo
>>> client = MongoClient() 
//与以下两种方式等同
>>> client = MongoClient(“localhost”, 27017)
>>> client = MongoClient(“mongodb://localhost:27017/”)

3.指定将要进行操作的database和collection

>>> db = client.test_db
>>> collection = db.test_collection

4.常规操作:

4.1 插入:

>>> mydict = {“name”:”Lucy”, “sex”:”female”,”job”:”nurse”}
>>> collection.insert(mydict)
>>> collection.insert_one(mydict)
>>> collection.insert_many(mydict) //会报错,.insert_many()时参数必须为 list 形式,做如下包装:
>>> mylist = []
>>> mylist.append(mydict)
>>> collection.insert_many(mylist) //不会报错

4.2 查询:

.find_one() 显示满足条件的第一个 collection,find() 的结果则是一个满足条件的对象数组:

>>> collection.find({“name”:”Lucy”})[0]
>>> collection.find({“name”:”Lucy”})[1]
……

可以使用 for-in 循环进行查看:

>>> for i in collection.find({“name”:”Lucy”})
…     print i
…
{u‘job‘: u‘nurse‘, u‘_id‘: ObjectId(‘554bd2e1e1382306bba8ade9‘),u‘name‘: u‘Lucy‘, u‘sex‘: u‘female‘}
{u‘nationality‘: u‘US‘, u‘age‘: 24, u‘_id‘: ObjectId(‘554be1cce138230714d0ab0d‘),u‘name‘: u‘Lucy‘}

查询指定条件的collection,可以指定一个或多个条件:

>>> collection.find_one({“name”:”Lucy”})
>>> collection.find_one({“name”:”Lucy”, “sex”:”female”})

.count() 统计结果总条数:

>>> collection.find().count() //等同于collection.count()
>>> collection.find({“name”:”Lucy”}).count()

指定大于小于等于等条件进行查询:

>>> collection.find({“age”: {“$lt”: 30}})

这样的查询符号有 $lt(小于), $gt(大于), $lte(小于等于), $gte(大于等于), $ne(不等于),这与原生 MongoDB 中相同。

将查询结果按条件排序:

>>> collection.find().sort("age")  //默认,升序
>>> collection.find().sort("age", pymongo.ASCENDING)   //升序
>>> collection.find().sort("age", pymongo.DESCENDING)  //降序

查询 database中所有collection :

>>> db.collection_names()
>>> db.collection_names(include_system_collections=Flase) //不包括系统collection,一般指的是system.indexes

注:这里的 db 为建立连接后的db = client.test_db 。

4.3 更新:

>>> temp = collection.find_one({"name":"Lucy"})
>>> temp2 = temp.copy()
>>> temp["name"] = "Jordan"
>>> collection.save(temp)   //或 .update() ,注意参数形式
>>> collection.update(temp, temp2)  //将temp更新为temp2

注:如果此时temp[“_id”]在该collection中已经存在,则.save()为更新操作,与 .replace_one() 作用相同,否则 .save() 为插入操作,与 .insert_one() 作用相同。

还要注意的一点是,.replace_one()需要传入两个参数,分别为当前document和要更新为的 document ,与 .update() 相同(update和save的区别暂且略过,有兴趣可以搜索引擎一下):

>>> collection.replace_one(old_document, new_document)

4.4 删除:

>>> collection.remove(temp)//即便该temp不存在也不会报错
>>> collection.delete_one(temp)
>>> collection.delete_many(temp) //与 .insert_many() 不同,在temp不是list类型时也不会报错

补充:

1.JSON序列化与反序列化:

如果想序列化为标准 JSON 格式,两种方式,方式一,json 包中的 dumps:

>>> import json
>>> for i in collection.find(“{“name”:”Lucy”})
…     del i[“_id”]    //不能直接转换,无法识别ObjectId
…     json.dumps(i)

对应的反序列化方法为json.loads()

方式二,bson.json_util包中封装的 dumps:

>>> from bson import Binary, Code
>>> from bson.json_util import dumps
>>> dumps([{‘foo‘: [1, 2]},
...     {‘bar‘: {‘hello‘:‘world‘}},
...     {‘code‘: Code("function x() { return1; }")},
...     {‘bin‘: Binary("")}])
‘[{"foo": [1, 2]}, {"bar": {"hello":"world"}}, {"code": {"$code": "function x(){ return 1; }", "$scope": {}}}, {"bin":{"$binary": "", "$type": "00"}}]‘

对应的反序列化方法为bson.json_util.loads()

2.Deprecated与”Modern”

在pymongo中,有一些方法虽然没有被弃用,但也已经不再建议使用,使用这些方法不会出现 error ,但会报出 warning :

__main__:1:DeprecationWarning: insert is deprecated. Use insert_one or insert_manyinstead.

下面列出一些Deprecated Method 和 “Mordern” Method ,供了解(建议不要使用 Deprecated Method,因为没准哪天就真的被弃用了):

Deprecated            “Mordern”

insert               insert_one   insert_many

save                replace_one   insert_one

remove               delete_one   delete_many

update               replace_one   update_one   update_many

参考资料:

http://api.mongodb.org/python/current/tutorial.html

http://api.mongodb.org/python/current/api/bson/json_util.html

时间: 2024-12-31 03:51:31

初窥Python(一)——使用pymongo连接MongoDB的相关文章

pymongo连接MongoDB

导语 pymongo 是目前用的相对普遍一个python用来连接MongoDB的库,是工作中各种基本需求都能满足具体api可以参考 pymongo APIpymongo github 安装 MongoDB 为了测试pyMongo连接mongodb,首先当然需要在centos下安装mongo,详细参考Centos下安装MongoDB 安装 pymongo 如果没有pip, 建议先安装,至于为啥要用pip你懂得 yum install python-pip pip 安装 pymongo pip in

使用pymongo连接mongodb时报错:pymongo.errors.OperationFailure: not authorized

连接本机或局域网部署的mongodb时可以用以下方法: 1 from urllib import parse 2 from pymongo import MongoClient 3 4 host = '*.*.*.*' 5 username = '*****' 6 password = '****' 7 passwd = parse.quote(password) # 对密码先进行编码 8 port = '3717' 9 mongo_url = 'mongodb://{0}:{1}@{2}:{3

初窥Python(三)——python版本升级及ipython的安装使用

在使用 CentOS6.6 X64 系统时,由于系统自带的 python 版本为 2.6.6,而 2.x 版本中当前普遍使用的为2.7 版本,所以我们要对系统的 python 版本做一个升级.ipython 是一个增强版的shell,支持TAB补全,自动缩进等供能,比默认的 python shell 要好用很多.下面主要介绍如何升级 python 版本,安装 pip 并使用 pip install 安装 ipython,搭建一个简易的 python 环境. 1.官网下载安装包: [[email 

初窥Python(二)——修改pip源

pip 默认使用的源在国外(https://pypi.python.org/simple/),有时在 pip install 时下载会比较慢,为了解决这一问题,只需做如下简单配置. 创建目录及 pip.conf 配置文件: [[email protected] ~]# mkdir -p $HOME/.config/pip/ [[email protected] ~]# cd !$ [[email protected] pip]# vim pip.conf 添加如下内容: [global] tim

初窥Python(五)——python中的decorator

1. 介绍 decorator是用来在代码运行期间动态增加功能的,本质上是一个返回函数的高阶函数.假设现在有这样一种需求,即在每个函数调用前记录日志,记录被调用的函数名称,可以这样实现: def log(func):     def wrapper(*args, **kwargs):         print "CALL %s()" % func.__name__         return func(*args, **kwargs)     return wrapper def 

初窥Python(四)——三种方法判断python变量类型

python 是动态语言,定义变量时不用指定变量类型,在代码执行过程中,会根据变量的值确定变量类型.python 中常用的变量类型有 int  float  long  bool  str  list  tuple set dict 等,常用的变量类型的有 types 库及内置的 type(object) 和 isinstance(object,class-or-type-or-tuple) 方法,下面分别来看一下如何通过这些方法进行变量类型的判断. 1.使用types库结合type(objec

Python 连接MongoDB并比较两个字符串相似度的简单示例

本文介绍一个示例:使用 pymongo 连接 MongoDB,查询MongoDB中的 字符串 记录,并比较字符串之间的相似度. 一,Python连接MongoDB 大致步骤:创建MongoClient---> 获取 DataBase --->获取Collection,代码如下: client = MongoClient(host="127.0.0.1", port=10001) db = client['database_name'] db.authenticate(nam

远程连接mongodb时,27017端口连接不上的解决办法

一.背景描述: 我在linux  RED7上安装了mongodb,并没有修改mongodb的配置文件.然后通过另外一台电脑用pymongo连接mongodb时,报错:timeout. ping IP 是成功的. telnet IP 27017 的时候,提示:27017端口连接不上. 二.解决过程: 各种百度,远程连接mongodb失败,网上资料显示原因有两个: 1.mongodb的配置文件中的bind_ip 默认为127.0.0.1,默认只有本机可以连接.  此时,需要将bind_ip配置为0.

python连接mongodb并操作

安装python连接mongodb的库文件pymongo pip install pymongo python连接mongodb程序 import pymongo conn = pymongo.MongoClient("ip",端口) db = conn.admin #连接库 db.authenticate("账号","密码") #用户认证 db=conn.jwh db.test.insert({'id':1,'name':'kaka','sex