通过eve对mongodb数据库进行操作

2020-12-16  本文已影响0人  公输昊少

本文主要参考了
https://docs.python-eve.org/en/stable/features.html
eve的安装参考该文档的安装部分
本问仅涉及数据查询、插入、修改。
其中http://mongoeve.com是一个虚拟的URL

import json
import requests

查询

headers = {
    'Content-Type': 'application/json'
}
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'}}}

上一篇 下一篇

猜你喜欢

热点阅读