目录

• MongoDB
• 连接数据库
• 增删改查
• 封装
• MySQL
• 连接数据库
• 执行操作
• 查询数据
• 异常处理
• Redis
• 连接数据库
• 执行操作

MongoDB

安装模块pip install pymongo

连接数据库

import pymongo
 
client = pymongo.MongoClient()
db = client["database_name"]  # 跟上数据库名
collection = db["set_name"]  # 指定集合名

增删改查

添加--->insert_one | insert_many

collection.insert_one({"name":"kongshang","age":12})

查找--->find | find_one

collection.find()

注意要用list转换得到的数据

修改--->update_one | update_many

collection.update_one({"name":"kongshang"},{'$set':{"age":13}})

删除--->delete_one | delete_many

collection.delete_one({"name":"kongshang"})

封装

import pymongo
 
 
class MyMonDB:
    def __init__(self, database, collection):  # 数据库及集合
        self.client = pymongo.MongoClient()  # 连接数据库使用
        self.db = self.client[database]  # 指定使用的数据库
        self.col = self.db[collection]  # 指定使用的集合
 
    def insert(self, data, onlyOne=True):  # onlyOne用来控制插入单条还是多条数据
        if onlyOne:
            self.col.insert_one(data)
        else:
            self.col.insert_many(data)
    
        def find(self, query=None, onlyOne=True):  # query是查询条件
        if onlyOne:
            ret = self.col.find_one(query)
            return ret
        else:
            ret = self.col.find(query)
            return list(ret)
 
    def update(self, data_old, data_new, onlyOne=True):
        if onlyOne:
            self.col.update_one(data_old, {"$set": data_new})
        else:
            self.col.update_many(data_old, {"$set": data_new})
 
    def delete(self, data, onlyOne=True):
        if onlyOne:
            self.col.delete_one(data)
        else:
            self.col.delete_many(data) 

注意该数据库对大小写敏感

MySQL

安装模块pip install pymysql

连接数据库

import pymysql
# 连接mysql
db_config = {
    "host": "127.0.0.1",
    "port": 3306,
    "user": "admin",
    "password": "qwe123",
    "db": "stu",  # 指定操作的数据库
    "charset": "utf8"
}
 
conn = pymysql.connect(**db_config)  # mysql登录 **是字典拆包
print(conn)

执行操作

cur = conn.cursor()  # 返回一个执行数据库命令游标对象，通过游标对象执行SQL命令
cur.execute("INSERT INTO stu (id, name) VALUES (1, 'nihao'),(2, 'ci')")  # 执行SQL命令执行插入命令
conn.commit()  # 事务，提交保存
cur.close()  # 关闭游标对象
conn.close()  # 关闭数据库

查询数据

cur.execute("SELECT * FROM stu")  # 执行SQL命令
# print(list(cur))
# print(cur.fetchone())  # 查询单条
# print(cur.fetchmany(3))  # 查询多条
print(cur.fetchall())  # 查询所有

异常处理

try:
    cur.execute("INSERT INTO stu (id, name) VALUES (1, 'nihao'), (2, 'ci')")
except Exception as e:
    print(e)
    conn.rollback()  # 事务回滚
else:
    conn.commit()  # 事务提交
finally:
    cur.close()  # 关闭游标对象
    conn.close()  # 关闭数据库

Redis

安装模块pip install redis

连接数据库

import redis
 
# 登录数据库
# host ip地址
# decode_responses get获得键值时 True返回字符串数据，默认是False二进制数据
# db 指定数据库，默认为1
red = redis.StrictRedis(host="127.0.0.1", decode_responses=True, db=2)

执行操作

# 字符串
red.set("num", 1)
print(red.get("num"))
print(red.type("num"))
red.delete('num')
# 综上，调用Redis数据库的方法是red.[输入redis数据库操作命令]()

免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：mmqy2019@163.com进行举报，并提供相关证据，查实之后，将立刻删除涉嫌侵权内容。

猜你喜欢

• Python中time时间模块的功能及用法是什么

  time和datetime是Python中常用的两个时间模块，本文将通过示例详细为大家讲讲二者的使用方法，感兴趣的小伙伴可以跟随小编一起学习学习

• Python用CSV文件格式是什么原因，有什么好处

  CSV(以逗号分隔的值)是用于存储表格数据的纯文本文件格式(如电子表格或数据库)。其主要存储的表格数据包括数字和纯文本。多数联机服务允许用户以CSV文件格式导出网站中的数据。通常在Excel中打开CSV文件，并且几乎所有数据库都有不同的特定工具来允许同一文件的导入。

• 怎样用python生成对称矩阵？

  怎样用python生成对称矩阵？有时候我们需要根据给定的数组，然后生成相应的对称矩阵，一些新手可能不了解怎样解决这个问题，对此，这篇文章就主要给大家分享python生成对称矩阵实例，感兴趣的朋友可以参考学习。

• 怎样用python写自动清理文件的功能？

  这篇文章给大家分享的是有关用python实现自动清理文件的功能的内容，文件夹中的很多旧文件常常容易被忽视，我们通过自动清理文件的功能就能不费事的清理这些文件，释放空间。小编觉得挺实用的，因此分享给大家做个参考，接下来一起跟随小编看看吧。

• Python字典查找性能是怎样，快不快

  这篇文章主要为大家介绍了Python字典查找性能，具有一定的参考价值，感兴趣的小伙伴们可以参考一下，希望能够给你带来帮助<BR>