【fastapi+mongodb】使用motor操作mongodb(二)

2024-06-09 16:12

本文主要是介绍【fastapi+mongodb】使用motor操作mongodb(二),希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

这篇文章本来要介绍valgrind的,但是valgrind只能安装在 Linux 上,不得已,就继续上一篇文章写motor的用法。

如果你还没看过上一篇文章,地址在这:【fastapi+mongodb】使用motor操作mongodb

select

删除和修改都是基于查询的语法的。
使用 find_one() 得到匹配查询的第一个文档:

async def find_user_by_name():document_user = await collection_users.find_one({'name':'bluebonnet27'})print(document_user)

find_one支持匹配词进行辅助,和mongodb的方法一样。比如你只想返回名字(这要求很奇怪),可以这么写:

async def find_user_by_name_return_name():document_user = await collection_users.find_one({'name':'bluebonnet27'}, {'name': 1})print(document_user)

输出如下:

{'_id': ObjectId('6653321bbca655e427d1196f'), 'name': 'bluebonnet27'}

当然,同样的办法,如果_id也不想看到,也可以把它排除掉:

async def find_user_by_name_return_name():document_user = await collection_users.find_one({'name':'bluebonnet27'}, {'name': 1, '_id': 0})print(document_user)

find_one()同样支持条件匹配。比如,我们要查询年龄小于某个数字的user(lt是 less than):

async def find_user_by_lower_age(age: int):document_user = await collection_users.find_one({'age':{'$lt': age}})print(document_user)

使用 find() 可以查询一组文档。 find() 没有I / O,也不需要 await 表达式。它只是创建一个 AsyncIOMotorCursor 实例。调用to_list时,才需要进行await操作。注意,需要在to_list中指定length的大小,否则无法处理缓冲区溢出的问题:

async def find_users_by_name(name: str):users_cursor = collection_users.find({'name':name})for document_user in await users_cursor.to_list(length=100):print(document_user)

输出如下:

{'_id': ObjectId('6653321bbca655e427d1196f'), 'name': 'bluebonnet27', 'age': 24}
{'_id': ObjectId('6653323a3a2f7378d4fee103'), 'name': 'bluebonnet27', 'age': 24}
{'_id': ObjectId('6653325dfba58f88883ecd31'), 'name': 'bluebonnet27', 'age': 24}
{'_id': ObjectId('666404d0bd455a936bbf9dee'), 'name': 'bluebonnet27', 'age': 24}
{'_id': ObjectId('66650ee7ba035059d15c5b1d'), 'name': 'bluebonnet27', 'age': 24}
{'_id': ObjectId('666510181342c1d39f1b17e8'), 'name': 'bluebonnet27', 'age': 24}
{'_id': ObjectId('6665116aec1e9c66564df13d'), 'name': 'bluebonnet27', 'age': 24}

另一种写法是直接用async forcursor进行遍历:

async def find_users_by_name2(name: str):async for document_user in collection_users.find({'name':name}):print(document_user)

效果是一样的。

如果只是希望查询满足某个条件的文档的数量,可以使用count_documents(),这是更简单的函数:

async def get_users_num_by_name(name: str):return await collection_users.count_documents({'name':name})

main

    count: int = loop.run_until_complete(get_users_num_by_name('bluebonnet27'))print(count)

这篇关于【fastapi+mongodb】使用motor操作mongodb(二)的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1045659

相关文章

Python自动化处理PDF文档的操作完整指南

《Python自动化处理PDF文档的操作完整指南》在办公自动化中,PDF文档处理是一项常见需求,本文将介绍如何使用Python实现PDF文档的自动化处理,感兴趣的小伙伴可以跟随小编一起学习一下... 目录使用pymupdf读写PDF文件基本概念安装pymupdf提取文本内容提取图像添加水印使用pdfplum

GO语言中函数命名返回值的使用

《GO语言中函数命名返回值的使用》在Go语言中,函数可以为其返回值指定名称,这被称为命名返回值或命名返回参数,这种特性可以使代码更清晰,特别是在返回多个值时,感兴趣的可以了解一下... 目录基本语法函数命名返回特点代码示例命名特点基本语法func functionName(parameters) (nam

Python从Word文档中提取图片并生成PPT的操作代码

《Python从Word文档中提取图片并生成PPT的操作代码》在日常办公场景中,我们经常需要从Word文档中提取图片,并将这些图片整理到PowerPoint幻灯片中,手动完成这一任务既耗时又容易出错,... 目录引言背景与需求解决方案概述代码解析代码核心逻辑说明总结引言在日常办公场景中,我们经常需要从 W

使用shardingsphere实现mysql数据库分片方式

《使用shardingsphere实现mysql数据库分片方式》本文介绍如何使用ShardingSphere-JDBC在SpringBoot中实现MySQL水平分库,涵盖分片策略、路由算法及零侵入配置... 目录一、ShardingSphere 简介1.1 对比1.2 核心概念1.3 Sharding-Sp

Java 正则表达式的使用实战案例

《Java正则表达式的使用实战案例》本文详细介绍了Java正则表达式的使用方法,涵盖语法细节、核心类方法、高级特性及实战案例,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要... 目录一、正则表达式语法详解1. 基础字符匹配2. 字符类([]定义)3. 量词(控制匹配次数)4. 边

Python Counter 函数使用案例

《PythonCounter函数使用案例》Counter是collections模块中的一个类,专门用于对可迭代对象中的元素进行计数,接下来通过本文给大家介绍PythonCounter函数使用案例... 目录一、Counter函数概述二、基本使用案例(一)列表元素计数(二)字符串字符计数(三)元组计数三、C

使用Spring Cache本地缓存示例代码

《使用SpringCache本地缓存示例代码》缓存是提高应用程序性能的重要手段,通过将频繁访问的数据存储在内存中,可以减少数据库访问次数,从而加速数据读取,:本文主要介绍使用SpringCac... 目录一、Spring Cache简介核心特点:二、基础配置1. 添加依赖2. 启用缓存3. 缓存配置方案方案

使用Python的requests库来发送HTTP请求的操作指南

《使用Python的requests库来发送HTTP请求的操作指南》使用Python的requests库发送HTTP请求是非常简单和直观的,requests库提供了丰富的API,可以发送各种类型的HT... 目录前言1. 安装 requests 库2. 发送 GET 请求3. 发送 POST 请求4. 发送

Nginx中配置使用非默认80端口进行服务的完整指南

《Nginx中配置使用非默认80端口进行服务的完整指南》在实际生产环境中,我们经常需要将Nginx配置在其他端口上运行,本文将详细介绍如何在Nginx中配置使用非默认端口进行服务,希望对大家有所帮助... 目录一、为什么需要使用非默认端口二、配置Nginx使用非默认端口的基本方法2.1 修改listen指令

Python WebSockets 库从基础到实战使用举例

《PythonWebSockets库从基础到实战使用举例》WebSocket是一种全双工、持久化的网络通信协议,适用于需要低延迟的应用,如实时聊天、股票行情推送、在线协作、多人游戏等,本文给大家介... 目录1. 引言2. 为什么使用 WebSocket?3. 安装 WebSockets 库4. 使用 We