数据持久化技术（Python）的使用

编程入门行业动态更新时间:2024-10-23 11:29:56

数据<a href=https://www.elefans.com/category/jswz/34/1771330.html style= 持久化技术（Python）的使用"/>

数据持久化技术（Python）的使用

传统数据库连接方式：mysql（PyMySQL）
ORM 模型：SQLAlchemy MyBatis、 Hibernate

PyMySQL

安装：

pip install pymysql

简单使用

利用 pymysql.connect 建立数据库连接并执行 SQL 命令（需要提前搭建好数据库）：

import pymysqldb = pymysql.connect(# mysql 地址host='182.92.129.158',# 账号和密码user='tmp',password='ceshiren',# 数据库db='tmp',charset='utf8mb4'
)if __name__ == '__main__':with db.cursor() as cursor:# 查看数据库中有多少表sql = "show tables;"# 执行 sql 语句cursor.execute(sql)# 查看所有数据print(cursor.fetchall())# 查询 name = aaaaaa 的数据sql = "select * from test_case_table where name=%s"cursor.execute(sql, ["aaaaaa"])print(cursor.fetchall())

(('test_case_table',),)
(('aaaaaa', '新的测试用例', 'test_hello.py', 'def test'),)

ORM

对象关系映射（ object-relational mapping）利用语言特性，操作数据库，比如对 Python 对象的操作，操作内容会映射到数据库里。
SQLALchemy 是 Python 编程语言下的一款 ORM 框架，该框架建立在数据库 API 之上，使用关系对象映射进行数据库操作。

安装

pip3 install SQLAlchemy

安装完成后可创建数据库连接：

engine = create_engine("mysql+pymysql://tmp:ceshiren@182.92.129.158/tmp?charset=utf8",echo=True,)

1.echo: 当设置为 True 时会将 ORM 语句转化为 SQL 语句打印，一般 debug 的时候可用。
2.字段解释：
3.mysql+pymysql：连接方式，采用 pymysql 。
4.tmp:ceshiren：用户名:密码。
5.182.92.129.158/tmp：数据库地址和数据库名称。

创建数据库

from sqlalchemy import create_engine, Column, Integer, String
from sqlalchemy.orm import declarative_baseengine = create_engine("mysql+pymysql://tmp:ceshiren@182.92.129.158/tmp?charset=utf8",echo=True,)
# 其子类将 Python 类和数据库表关联映射起来
Base = declarative_base()
# 继承 Base
class Users(Base):__tablename__ = "users"id = Column(Integer, primary_key=True)name = Column(String(64), unique=True)def __init__(self, name):self.name = nameif __name__ == '__main__':# 生成数据库表，如果有此库会忽略Base.metadata.create_all(engine)

declarative_base() 是 SQLALchemy 内部封装的一个方法，可以让其子类将 Python 类和数据库表关联映射起来。

增和查

SQLALchemy 使用 Session 用于创建程序和数据库之间的会话，通过 Session 对象可实现对数据的增删改查。

from sqlalchemy.orm import sessionmaker
# 创建session
Session = sessionmaker(bind=engine)
session = Session()
# 添加新数据
add_user = Users("student1")
# 提交
session.add(add_user)
sessionmit()
# 查询
result = session.query(Users).filter_by(name="student1").first()
print(result.id, result.name)

上述代码新增数据后进行查询，结果如下：