写点什么

数据持久化技术(Python)的使用

  • 2022 年 9 月 14 日
    北京
  • 本文字数:1278 字

    阅读完需:约 4 分钟

传统数据库连接方式:mysql(PyMySQL)ORM 模型:SQLAlchemy MyBatis、 HibernatePyMySQL 安装:


pip install 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'),)


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


安装 pip3 install SQLAlchemy


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


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, Stringfrom 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)


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


1 student1


点击下方链接免费领取:性能测试+接口测试+自动化测试+测试开发+测试用例+简历模板+测试文档

http://qrcode.testing-studio.com/f?from=infoQ&url=https://ceshiren.com/t/topic/22265

用户头像

社区:ceshiren.com 微信:ceshiren2021 2019.10.23 加入

微信公众号:霍格沃兹测试开发 提供性能测试、自动化测试、测试开发等资料,实时更新一线互联网大厂测试岗位内推需求,共享测试行业动态及资讯,更可零距离接触众多业内大佬。

评论

发布
暂无评论
数据持久化技术(Python)的使用_霍格沃兹测试开发学社_InfoQ写作社区