数据持久化技术
数据持久化是指数据存储,目前后端多利用数据库存储数据,数据库主要分为两大类:
ORM 模型是利用语言特性,操作数据库,比如 Python 对象的操作,操作内容会映射到数据库里
PyMySQL
安装:
简单使用
利用 pymysql.connect 建立数据库连接并执行 SQL 命令(需要提前搭建好数据库):
import pymysql
db = pymysql.connect(
# mysql 地址
host='182.92.129.158',
# 账号和密码
user='tmp',
password='ceshiren.com',
# 数据库
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'),)
复制代码
OPM
对象关系映射( object-relational mapping) 利用语言特性,操作数据库,比如对 Python 对象的操作, 操作内容会映射到数据库里。
SQLALchemy 是 Python 编程语言下的一款 ORM 框架,该框架建立在数据库 API 之上,使用关系对象 映射进行数据库操作。
SQLAchemy 本身无法操作数据库,要依赖 pymysql 三方库
安装
安装完成后可创建数据库连接:
engine = create_engine("mysql+pymysql://tmp:ceshiren.com@182.92.129.158/tmp?
charset=utf8",echo=True,)
复制代码
1.echo:当设置为 True 时会将 ORM 语句转化为 SQL 语句打印,一般 debug 的时候可用。
2.字段解释:
3.mysql+pymysql:连接方式,采用 pymysql.
4.tmp:ceshiren.com:用户名:密码。
5.182.92.129.158/tmp:数据库地址喝数据库名称。
创建数据库
from sqlalchemy import create_engine, Column, Integer, String
from sqlalchemy.orm import declarative_base
engine = create_engine("mysql+pymysql://tmp:ceshiren.com@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 = name
if __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)
session.commit()
# 查询
result = session.query(Users).filter_by(name="student1").first()
print(result.id, result.name)
复制代码
上述代码新增数据后进行查询,结果如下:
搜索微信公众号:TestingStudio 霍格沃兹的干货都很硬核
评论