Python操作MongoDB快速入门教程

Docker安装MongoDB

拉取镜像：

docker pull mongo:6.0.2

创建容器：

docker run --name mongo -d -p 27017:27017 mongo:6.0.2

设置用户名和密码：

# 创建mongo容器后，进入容器
docker exec -it mongo bash# 进入mongo shell
mongosh# 进入admin数据库
use admin# 创建用户名和密码
db.createUser({user:'zhangdapeng',pwd:'zhangdapeng520',roles:[{role:'root',db:'admin'}]})

校验用户名和密码：

# 认证登录db.auth('用户名','密码')，打印1则代表认证通过
db.auth('zhangdapeng','zhangdapeng520')

安装依赖

pip install ./dist/zdppy_mongo-0.1.0.tar.gz

连接MongoDB

import timefrom mongo.pymongo import MongoClient# 会开进程，主进程需要等待
client = MongoClient('mongodb://zhangdapeng:zhangdapeng520@localhost:27017/')
print(client)# 等待1秒钟
time.sleep(1)
print("建立连接成功：", client)

创建和删除数据库

import time
import mongo# 建立链接，会开进程，主进程要等待一会儿
client = mongo.MongoClient('mongodb://zhangdapeng:zhangdapeng520@localhost:27017/')
time.sleep(1)
print("建立连接成功：", client)# 创建数据库
db = client["user_manager"]
print(db)# 删除数据库
client.drop_database("user_manager")

创建集合

import time
import mongo# 建立链接，会开进程，主进程要等待一会儿
client = mongo.MongoClient('mongodb://zhangdapeng:zhangdapeng520@localhost:27017/')
time.sleep(1)
print("建立连接成功：", client)# 创建数据库
db = client["user_manager"]
print(db)# 创建集合
db_user = db["user"]
print(db_user)# 删除数据库
client.drop_database("user_manager")

添加数据

import time
import mongo# 建立链接，会开进程，主进程要等待一会儿
client = mongo.MongoClient('mongodb://zhangdapeng:zhangdapeng520@localhost:27017/')
time.sleep(1)
print("建立连接成功：", client)# 创建数据库
db = client["user_manager"]
print(db)# 创建集合
db_user = db["user"]
print(db_user)# 添加数据
r = db_user.insert_one({"name": "张三", "age": 23})
print(r)# 删除数据库
client.drop_database("user_manager")

查询数据

import time
import mongo# 建立链接，会开进程，主进程要等待一会儿
client = mongo.MongoClient('mongodb://zhangdapeng:zhangdapeng520@localhost:27017/')
time.sleep(1)
print("建立连接成功：", client)# 创建数据库
db = client["user_manager"]
print(db)# 创建集合
db_user = db["user"]
print(db_user)# 添加数据
r = db_user.insert_one({"name": "张三", "age": 23})
print(r)# 查询数据
r = db_user.find_one({"name": "张三"})
print(r)# 删除数据库
client.drop_database("user_manager")

批量添加数据

import time
import mongo# 建立链接，会开进程，主进程要等待一会儿
client = mongo.MongoClient('mongodb://zhangdapeng:zhangdapeng520@localhost:27017/')
time.sleep(1)
print("建立连接成功：", client)# 创建数据库
db = client["user_manager"]
print(db)# 创建集合
db_user = db["user"]
print(db_user)# 添加数据
r = db_user.insert_many([{"name": f"张三{i}", "age": i % 20} for i in range(100)])
print(r)# 删除数据库
client.drop_database("user_manager")

查询所有数据

import time
import mongo# 建立链接，会开进程，主进程要等待一会儿
client = mongo.MongoClient('mongodb://zhangdapeng:zhangdapeng520@localhost:27017/')
time.sleep(1)
print("建立连接成功：", client)# 创建数据库
db = client["user_manager"]
print(db)# 创建集合
db_user = db["user"]
print(db_user)# 添加数据
r = db_user.insert_many([{"name": f"张三{i}", "age": i % 20} for i in range(100)])
print(r)# 查询数据
r = db_user.find()
print(list(r))# 删除数据库
client.drop_database("user_manager")

查询数据总数

import time
import mongo# 建立链接，会开进程，主进程要等待一会儿
client = mongo.MongoClient('mongodb://zhangdapeng:zhangdapeng520@localhost:27017/')
time.sleep(1)
print("建立连接成功：", client)# 创建数据库
db = client["user_manager"]
print(db)# 创建集合
db_user = db["user"]
print(db_user)# 添加数据# 添加数据
r = db_user.insert_many([{"name": f"张三{i}", "age": i % 20} for i in range(100)])
print(r)# 查询数据
r = db_user.find()
print(list(r))# 查询数据
print(db_user.count_documents({}))# 删除数据库
client.drop_database("user_manager")

批量执行操作

import time
import mongo# 建立链接，会开进程，主进程要等待一会儿
client = mongo.MongoClient('mongodb://zhangdapeng:zhangdapeng520@localhost:27017/')
time.sleep(1)
print("建立连接成功：", client)# 创建数据库
db = client["user_manager"]
print(db)# 创建集合
db_user = db["user"]
print(db_user)# 添加数据
r = db_user.bulk_write([mongo.DeleteMany({}),  # 删除所有数据mongo.InsertOne({"name": "张三", "age": 23}),  # 新增一条数据mongo.InsertOne({"name": "李四", "age": 23}),  # 新增一条数据mongo.UpdateOne({"name": "李四"}, {"$set": {"age": 24}}),  # 更新数据mongo.UpdateOne({"name": "李四"}, {"$inc": {"age": 1}}),  # 更新数据mongo.ReplaceOne({"name": "李四"}, {"name": "李四", "age": 34}),  # 替换数据
])
print(r)# 查询数据
r = db_user.find()
print(list(r))# 删除数据库
client.drop_database("user_manager")

获取批量执行错误

import time
import mongo# 建立链接，会开进程，主进程要等待一会儿
client = mongo.MongoClient('mongodb://zhangdapeng:zhangdapeng520@localhost:27017/')
time.sleep(1)
print("建立连接成功：", client)# 创建数据库
db = client["user_manager"]
print(db)# 创建集合
db_user = db["user"]
print(db_user)# 添加数据
data = [mongo.DeleteMany({}),  # 删除所有数据mongo.InsertOne({"name": "张三", "age": 23}),  # 新增一条数据mongo.InsertOne({"name": "李四", "age": 23}),  # 新增一条数据mongo.UpdateOne({"name": "李四"}, {"$set": {"age": 24}}),  # 更新数据mongo.UpdateOne({"name": "李四"}, {"$inc": {"age": 1}}),  # 更新数据mongo.ReplaceOne({"name": "李四"}, {"name": "李四", "age": 34}),  # 替换数据
]
try:r = db_user.bulk_write(data)print(r)
except mongo.BulkWriteError as e:print("批量执行操作失败：", e)# 查询数据
r = db_user.find()
print(list(r))# 删除数据库
client.drop_database("user_manager")

批量更新

import time
import mongo# 建立链接，会开进程，主进程要等待一会儿
client = mongo.MongoClient('mongodb://zhangdapeng:zhangdapeng520@localhost:27017/')
time.sleep(1)
print("建立连接成功：", client)# 创建数据库
db = client["user_manager"]
print(db)# 创建集合
db_user = db["user"]
print(db_user)# 添加数据
data = [{"name": "张三", "age": 23},{"name": "李四", "age": 33},{"name": "王五", "age": 25},
]
r = db_user.insert_many(data)
print(r)# 更新
# 年龄小于30岁的自增1
db_user.update_many({"age": {"$lt": 30}},{"$set": {"age": 33}}
)# 查询数据
r = db_user.find()
print(list(r))# 删除数据库
client.drop_database("user_manager")

日期类型

import time
import datetime
import mongo# 建立链接，会开进程，主进程要等待一会儿
client = mongo.MongoClient('mongodb://zhangdapeng:zhangdapeng520@localhost:27017/')
time.sleep(1)
print("建立连接成功：", client)# 创建数据库
db = client["user_manager"]
print(db)# 创建集合
db_user = db["user"]
print(db_user)# 添加数据
r = db_user.insert_one({"last_modified": datetime.datetime.now()})
print(r)# 查询数据
r = db_user.find()
print(list(r))# 删除数据库
client.drop_database("user_manager")

分页查询

import time
import mongo# 建立链接，会开进程，主进程要等待一会儿
client = mongo.MongoClient('mongodb://zhangdapeng:zhangdapeng520@localhost:27017/')
time.sleep(1)
print("建立连接成功：", client)# 创建数据库
db = client["user_manager"]
print(db)# 创建集合
db_user = db["user"]
print(db_user)# 添加数据
data = [{"name": "张三", "age": 23},{"name": "李四", "age": 33},{"name": "王五", "age": 25},
]
r = db_user.insert_many(data)
print(r)# 查询数据
r = db_user.find().limit(2).skip(2)
print(list(r))# 删除数据库
client.drop_database("user_manager")

聚合查询

import time
import mongo# 建立链接，会开进程，主进程要等待一会儿
client = mongo.MongoClient('mongodb://zhangdapeng:zhangdapeng520@localhost:27017/')
time.sleep(1)
print("建立连接成功：", client)# 创建数据库
db = client["user_manager"]
print(db)# 创建集合
db_user = db["user"]
print(db_user)# 添加数据
data = [{"name": "张三", "age": 23},{"name": "李四", "age": 33},{"name": "王五", "age": 25},
]
r = db_user.insert_many(data)
print(r)# 查询数据
r = db_user.aggregate([{"$group": {"_id": None, "count": {"$sum": 1}, "avg_age": {"$avg": "$age"}}}])
print(list(r))# 删除数据库
client.drop_database("user_manager")

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/615473.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

C++ Primer 6.2参数传递 知识点+练习题

C++ Primer 6.2参数传递 知识点+练习题

C Primer 6.2参数传递 知识点练习题 指针形参使用引用拷贝Const 形参实参尽量使用常量引用数组形参数组引用形参传递多维数组向main函数传参数含有可变形参的函数练习题待更新 指针形参 void reset(int *p) {*p0;//p指向的整型对象变为0p0;//只是对形参改变p，使其为…
阅读更多...
【Git】查看凭据管理器的账号信息，并删除账号，解决首次认证登录失败后无法重新登录的问题

【Git】查看凭据管理器的账号信息，并删除账号，解决首次认证登录失败后无法重新登录的问题

欢迎来到《小5讲堂》 大家好，我是全栈小5。 这是是《代码管理工具》序列文章，每篇文章将以博主理解的角度展开讲解， 特别是针对知识点的概念进行叙说，大部分文章将会对这些概念进行实际例子验证，以此达到加深对知识点的…
阅读更多...
Axios基本使用，为学习后续的Vue服务【发送请求+并发请求+前端拦截器】

Axios基本使用，为学习后续的Vue服务【发送请求+并发请求+前端拦截器】

目录 1、项目中引入Axios 2、使用Axios发送请求 2.1、例&#xff1a;发送GET请求 2.2、例&#xff1a;发送POST请求 3、axios并发请求 4、拦截器 1、项目中引入Axios <script src"https://unpkg.com/axios/dist/axios.min.js"></script> 注&…
阅读更多...
性能测试分析案例-定位内核线程CPU利用率太高

性能测试分析案例-定位内核线程CPU利用率太高

环境准备 预先安装 docker、perf、hping3、curl 等工具&#xff0c;如 apt install docker.io linux-tools-common hping3 操作和分析 Linux 在启动过程中&#xff0c;有三个特殊的进程&#xff0c;也就是 PID 号最小的三个进程。 0 号进程为 idle 进程&#xff0c;这也是系…
阅读更多...
力扣_数组28—子集

力扣_数组28—子集

题目 给你一个整数数组 nums &#xff0c;数组中的元素 互不相同 。返回该数组所有可能的子集&#xff08;幂集&#xff09;。 解集 不能 包含重复的子集。你可以按 任意顺序 返回解集。 输入&#xff1a; n u m s [ 1 , 2 , 3 ] nums [1,2,3] nums[1,2,3] 输出&#xff1a…
阅读更多...
Windows 项目从0到1的部署

Windows 项目从0到1的部署

目录 一. 安装jdk 1.1 安装jdk 1.2 配置jdk的环境配置jdk 1.3 配置成功 二. 配置tomcat 2.1 启动tomcat 2.2 防火墙设置 三. 安装MySQL 3.1 安装步骤 3.2 内部连接 3.3 外部连接 四. 部署项目 4.1 项目部署 4.2 修改mysql的用户密码 一. 安装jdk 这里给大家准备好了jdk和…
阅读更多...
2024.1.8 Day04_SparkCore_homeWork

2024.1.8 Day04_SparkCore_homeWork

目录 1. 简述Spark持久化中缓存和checkpoint检查点的区别 2 . 如何使用缓存和检查点? 3 . 代码题 浏览器Nginx案例 先进行数据清洗,做后续需求用 1、需求一&#xff1a;点击最多的前10个网站域名 2、需求二&#xff1a;用户最喜欢点击的页面排序TOP10 3、需求三&#x…
阅读更多...
【Kubernetes】K8s 查看 Pod 的状态

【Kubernetes】K8s 查看 Pod 的状态

K8s 查看 Pod 的状态 [rootk8s-master1 ~]# kubectl get pods NAME READY STATUS RESTARTS AGE nginx-3 1/1 Running 2 (34m ago) 14hNAME&#xff1a;Pod 的名称。READY&#xff1a;代表 Pod 里面有几个容器&#xff0c;前面是启动的&#xff0c;后面…
阅读更多...
一卡通水控电控开发踩过的坑

一卡通水控电控开发踩过的坑

最近在做一个项目&#xff0c;是对接一卡通设备的。我一开始只拿到设备和3个文档开局。不知道从哪下手。一步一步踩坑过来。踩了很多没有必要的坑&#xff0c;写出来给有用的人吧。 读卡器怎么用&#xff1f; 有个读卡器&#xff0c;一开始什么软件也不提供。我都不知道是干嘛…
阅读更多...
Jupyter Notebook

Jupyter Notebook

2017年左右在大学里都听说过Jupyter Notebook&#xff0c;并且也安装用了一段时间&#xff0c;后来不知道什么原因没有用了。估计是那时候写代码的时候多一些&#xff0c;因为它可以直接写代码并运行结果&#xff0c;现在不怎么写代码了。 介绍 后缀名为.ipynb的json格式文件…
阅读更多...
laravel框架的用途有哪些

laravel框架的用途有哪些

Laravel框架是一个开源的PHP框架&#xff0c;用于开发Web应用程序。它有很多用途&#xff0c;包括&#xff1a; Web应用程序开发&#xff1a;Laravel框架提供了丰富的功能和工具&#xff0c;用于开发各种类型的Web应用程序&#xff0c;包括企业应用、电子商务平台、博客、社交…
阅读更多...
Kotlin-数组

Kotlin-数组

数组 创建数组 可以通过Array来创建数组&#xff0c;也可以通过arrayOf()等工具创建数组 Kotlin中创建数组有两种方式 arrayOf(),arrayOfNulls()&#xff0c;emptyArray(&#xff09;工具函数使用Array&#xff08;size:int&#xff0c;initial:&#xff08;Int&#xff09;…
阅读更多...
《YOLO算法：基础+进阶+改进》报错解决 专栏答疑

《YOLO算法：基础+进阶+改进》报错解决 专栏答疑

前言&#xff1a;Hello大家好&#xff0c;我是小哥谈。《YOLO算法&#xff1a;基础进阶改进》专栏上线后&#xff0c;部分同学在学习过程中提出了一些问题&#xff0c;笔者相信这些问题其他同学也有可能遇到。为了让大家可以更好地学习本专栏内容&#xff0c;笔者特意推出了该篇…
阅读更多...
SpringBoot集成Camunda

SpringBoot集成Camunda

一&#xff1a;SpringBoot集成 1.1&#xff1a;pom.xml 因camunda集成SpringBoot对SpringBoot的版本和JDK的版本都有一定的要求&#xff0c;所以这里贴个完整的依赖。可以去官网找每个SpringBoot的版本对应的camunda版本。 <?xml version"1.0" encoding"…
阅读更多...
前端入门教程：学完即可单独完成前端项目

前端入门教程：学完即可单独完成前端项目

目录 目录 1.HTML: 1.1概念 1.2结构 1.3常见的标签使用分类&#xff1a; 2.CSS: 2.1概念 2.2样式实践&#xff1a; 以下的举例都来自于博客&#xff1a; 2.3css选择器&#xff1a; 什么是css选择器&#xff1a; 举例如下&#xff1a; 2.4Demo 3.JavaScript&#…
阅读更多...
Spring 容器的初始化过程

Spring 容器的初始化过程

Spring 容器的初始化过程包括以下主要步骤&#xff1a; 加载配置文件&#xff1a; Spring 容器通常会从 XML 文件、Java 注解或者 Java Config 等方式加载配置信息&#xff0c;这些配置信息定义了应用中的 bean、依赖关系、切面等内容。 创建容器实例&#xff1a; 一旦配置…
阅读更多...
算法34：贴纸拼词（力扣691题）

算法34：贴纸拼词（力扣691题）

题目&#xff1a; 我们有 n 种不同的贴纸。每个贴纸上都有一个小写的英文单词。 您想要拼写出给定的字符串 target &#xff0c;方法是从收集的贴纸中切割单个字母并重新排列它们。如果你愿意&#xff0c;你可以多次使用每个贴纸&#xff0c;每个贴纸的数量是无限的。 返回你…
阅读更多...
vivado IP Revision Control

vivado IP Revision Control

2020.2 只需要git 管理 prj.xpr 和 prj.srcs/ https://china.xilinx.com/video/hardware/ip-revision-control.html https://www.xilinx.com/video/hardware/vivado-design-suite-revision-control.html
阅读更多...
每日一题：LeetCode-LCR 007. 三数之和

每日一题：LeetCode-LCR 007. 三数之和

每日一题系列&#xff08;day 18&#xff09; 前言&#xff1a; &#x1f308; &#x1f308; &#x1f308; &#x1f308; &#x1f308; &#x1f308; &#x1f308; &#x1f308; &#x1f308; &#x1f308; &#x1f308; &#x1f308; &#x1f308; &#x1f50e…
阅读更多...
解决chromebook kabylake安装linux没有声音问题

解决chromebook kabylake安装linux没有声音问题

chromebook kabylake安装arch没有声音&#xff0c;好长时间没有解决&#xff0c;一直用的蓝牙耳机。 今天搜搜帖子解决了&#xff0c; 分享供参考 git clone https://github.com/eupnea-project/chromebook-linux-audiocd chromebook-linux-audio ./setup-audio提示 I Underst…
阅读更多...
最新文章

Copyright @ 2022~2023