通过eve对mongodb数据库进行操作
本文主要参考了
https://docs.python-eve.org/en/stable/features.html
eve的安装参考该文档的安装部分
本问仅涉及数据查询、插入、修改。
其中http://mongoeve.com是一个虚拟的URL
import json
import requests
查询
- 我们希望系统返回json格式的诗句,所以首先定义header
- 经过测试,采用requests请求数据,默认返回json
- 但是最好能够自己定义一下,以防万一
headers = {
'Content-Type': 'application/json'
}
- “http://mongoeve.com/test” 中的test是collection的名称。
如果将test换成news_articles,那么操作的就是news_articles这个表。 - 查询条件定义为
q
,然后加入到url里即可
q = {"to_filter": False}
url = 'http://mongoeve.com/test?where=' + json.dumps(q)
res = requests.get(url, headers=headers)
每次操作后,为了验证操作成功,最好检查一下status_code,是200则没有问题
查询操作倒是没太大必要检查status_code,但是插入数据、更新数据的时候一定要检查
res.status_code
200
返回一下这样的信息,则说明查询成功,_items
下的列表就是我们的查询结果
res.json()
{'_items': [{'_id': '5fd9cecf4100fb64ca4d7c5e',
'firstname': 'ronald',
'lastname': 'obama',
'to_filter': False,
'_updated': 'Wed, 16 Dec 2020 12:24:34 GMT',
'_created': 'Wed, 16 Dec 2020 09:09:35 GMT',
'_etag': 'b162566228e1eda8986b88fb4110525e92906e3a',
'_links': {'self': {'title': 'test',
'href': 'test/5fd9cecf4100fb64ca4d7c5e'}}}],
'_links': {'parent': {'title': 'home', 'href': '/'},
'self': {'title': 'test', 'href': 'test?where={"to_filter": false}'}},
'_meta': {'page': 1, 'max_results': 25, 'total': 1}}
插入数据
data
中就是我们要插入的数据,参照以下代码即可
这里状态码是201则说明插入成功,或者返回数据中_status是OK,则说明插入成功
之前给我的schema中,必填的选项是必须要指定的,否则会报错
url = 'http://mongoeve.com/test'
data = [{"firstname": "barack", "lastname": "obama", "to_filter": False}, {"firstname": "mitt", "lastname": "romney"}]
res = requests.post(url, data=json.dumps(data), headers=headers)
res.status_code
201
res.json()
{'_status': 'OK',
'_items': [{'_updated': 'Wed, 16 Dec 2020 12:39:26 GMT',
'_created': 'Wed, 16 Dec 2020 12:39:26 GMT',
'_etag': '300176dbcbc75d9b2db44ee46c4a9c0123e79844',
'_id': '5fd9fffe4100fb64ca4d7c60',
'_links': {'self': {'title': 'test',
'href': 'test/5fd9fffe4100fb64ca4d7c60'}},
'_status': 'OK'},
{'_updated': 'Wed, 16 Dec 2020 12:39:26 GMT',
'_created': 'Wed, 16 Dec 2020 12:39:26 GMT',
'_etag': '4259d99aec575fa64d653093f14da29252ae2e1a',
'_id': '5fd9fffe4100fb64ca4d7c61',
'_links': {'self': {'title': 'test',
'href': 'test/5fd9fffe4100fb64ca4d7c61'}},
'_status': 'OK'}]}
修改数据
如果想修改数据,我们需要先获取所修改数据的_etag,可以通过查询得到,比如我们想修改_id为5fd9cecf4100fb64ca4d7c5e的数据,则有如下操作
注:当字段的值类型为ObjectId时可以这样查询,但是可以通过设置additional_lookup增加其他的可以以这种方式查询的字段。我们的系统里,只有_id字段才可以这样查询,如果不知道_id,根据其他条件查询,需要参照上面的查询方式,然后取查询结果中的_id和_etag
url = 'http://mongoeve.com/test/5fd9cecf4100fb64ca4d7c5e'
res = requests.get(url).json()
headers = {
"If-Match": res["_etag"],
"Content-Type": "application/json"
}
q = {"firstname": "abc"}
res = requests.patch(url, data=json.dumps(q), headers=headers)
res.status_code
200
# 这是请求结果
res.json()
{'_id': '5fd9cecf4100fb64ca4d7c5e',
'_updated': 'Wed, 16 Dec 2020 12:52:31 GMT',
'_created': 'Wed, 16 Dec 2020 09:09:35 GMT',
'_etag': '37c9610cc2e4c64c7fab325dee894c7299f28e23',
'_links': {'self': {'title': 'test',
'href': 'test/5fd9cecf4100fb64ca4d7c5e'}},
'_status': 'OK'}
我们查询验证一下,发现修改成功
requests.get(url).json()
{'_id': '5fd9cecf4100fb64ca4d7c5e',
'firstname': 'abc',
'lastname': 'obama',
'to_filter': False,
'_updated': 'Wed, 16 Dec 2020 12:52:31 GMT',
'_created': 'Wed, 16 Dec 2020 09:09:35 GMT',
'_etag': '37c9610cc2e4c64c7fab325dee894c7299f28e23',
'_links': {'self': {'title': 'test', 'href': 'test/5fd9cecf4100fb64ca4d7c5e'},
'parent': {'title': 'home', 'href': '/'},
'collection': {'title': 'test', 'href': 'test'}}}