python使用SQLAlchemy操作MySQL
作者:jclian91 发布时间:2024-01-16 19:11:11
SQLAlchemy是Python编程语言下的一款开源软件,提供了SQL工具包及对象关系映射(ORM)工具,使用MIT许可证发行。SQLAlchemy首次发行于2006年2月,并迅速地在Python社区中最广泛使用的ORM工具之一,不亚于Django的ORM框架。
本文将介绍如何使用SQLAlchemy操作MySQL,完成基础的表创建,表格数据的新增、查询、修改、删除(CRUD)等操作。
首先我们需要确认当前的Python环境下已经安装sqlalchemy和pymysql模块。
新建表格
我们使用本地的MySQL数据库,数据库为orm_test。新建一张users表,字段为id,name,age,place。完整的Python代码(create_table.py
)如下:
# -*- coding: utf-8 -*-
# author: Jclian91
# place: Sanya, Hainan
# time: 12:46
from sqlalchemy.dialects.mysql import INTEGER, VARCHAR
from sqlalchemy import Column
from sqlalchemy import create_engine
from sqlalchemy.ext.declarative import declarative_base
Base = declarative_base()
# users表结构
class Users(Base):
__tablename__ = 'users'
id = Column(INTEGER, primary_key=True)
name = Column(VARCHAR(256), nullable=False)
age = Column(INTEGER)
place = Column(VARCHAR(256), nullable=False)
def __init__(self, id, name, age, place):
self.id = id
self.name = name
self.age = age
self.place = place
def init_db():
engine = create_engine(
"mysql+pymysql://root:@localhost:3306/orm_test",
encoding= "utf-8",
echo=True
)
Base.metadata.create_all(engine)
print('Create table successfully!')
if __name__ == '__main__':
init_db()
运行后,生成的users表结构如下:
数据插入
接着我们插入几条测试数据,完整的代码(db_insert.py
)如下:
# -*- coding: utf-8 -*-
# author: Jclian91
# place: Sanya, Hainan
# time: 12:52
from create_table import Users
from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker
def insert_data():
# 初始化数据库连接
engine = create_engine("mysql+pymysql://root:@localhost:3306/orm_test", encoding="utf-8")
# 创建DBSession类型
DBSession = sessionmaker(bind=engine)
# 创建session对象
session = DBSession()
# 插入单条数据
# 创建新User对象
new_user = Users(id=1, name='Jack', age=25, place='USA')
# 添加到session
session.add(new_user)
# 提交即保存到数据库
session.commit()
# 插入多条数据
user_list= [Users(id=2, name='Green', age=26, place='UK'),
Users(id=3, name='Alex', age=31, place='GER'),
Users(id=4, name='Chen', age=52, place='CHN'),
Users(id=5, name='Zhang', age=42, place='CHN')
]
session.add_all(user_list)
session.commit()
# 关闭session
session.close()
print('insert into db successfully!')
if __name__ == '__main__':
insert_data()
运行程序后,表格中的数据如下:
数据查询
接下来演示如何进行简单的查询。我们需要查询place为CHN的人名,完整的Python代码(db_query)如下:
# -*- coding: utf-8 -*-
# author: Jclian91
# place: Sanya, Hainan
# time: 12:52
from create_table import Users
from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker
def query_data():
# 初始化数据库连接
engine = create_engine("mysql+pymysql://root:@localhost:3306/orm_test", encoding="utf-8")
# 创建DBSession类型
DBSession = sessionmaker(bind=engine)
# 创建session对象
session = DBSession()
# 查询所有place是CHN的人名
# 创建Query查询,filter是where条件
# 调用one()返回唯一行,如果调用all()则返回所有行:
users = session.query(Users).filter(Users.place == 'CHN').all()
print([use.name for use in users])
# 输出:['Chen', 'Zhang']
# 或者用如下查询
users = session.query(Users.name).filter(Users.place == 'CHN').all()
print(users)
# 输出:[('Chen',), ('Zhang',)]
session.close()
if __name__ == '__main__':
query_data()
输出结果如下:
['Chen', 'Zhang']
[('Chen',), ('Zhang',)]
数据更新
接下来我们演示数据更新。我们需要将Jack的place修改为CHN,完整的Python代码(db_update)如下:
# -*- coding: utf-8 -*-
# author: Jclian91
# place: Sanya, Hainan
# time: 12:52
from create_table import Users
from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker
def update_data():
# 初始化数据库连接
engine = create_engine("mysql+pymysql://root:@localhost:3306/orm_test", encoding="utf-8")
# 创建DBSession类型
DBSession = sessionmaker(bind=engine)
# 创建session对象
session = DBSession()
# 数据更新,将Jack的place修改为CHN
update_obj = session.query(Users).filter(Users.name=='Jack').update({"place":"CHN"})
session.commit()
session.close()
print("Update data successfully!")
if __name__ == '__main__':
update_data()
更新后的表格数据如下:
数据删除
接着我们演示数据删除。我们需要将Jack的记录删除,完整的Python代码(db_delete.py)如下:
# -*- coding: utf-8 -*-
# author: Jclian91
# place: Sanya, Hainan
# time: 12:52
from create_table import Users
from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker
def delete_data():
# 初始化数据库连接
engine = create_engine("mysql+pymysql://root:@localhost:3306/orm_test", encoding="utf-8")
# 创建DBSession类型
DBSession = sessionmaker(bind=engine)
# 创建session对象
session = DBSession()
# 数据更新,将Jack的记录删除
update_obj = session.query(Users).filter(Users.name=='Jack').delete()
session.commit()
session.close()
print("Delete data successfully!")
if __name__ == '__main__':
delete_data()
运行程序后,表格中的数据如下:
本次分享到此结束,感谢大家阅读~
本文的示例代码已经上传至Github,网址为:https://github.com/percent4/ORM_test。
来源:https://segmentfault.com/a/1190000021446268
猜你喜欢
- ASP编写完整的一个IP所在地搜索类的修正文稿修正了查询方法,查询的方法和追捕的一致;只是追捕会自动更正IP。还有个函数的书写错误,也已经修
- python数据分析工具pandas中DataFrame和Series作为主要的数据结构.本文主要是介绍如何对DataFrame数据进行操作
- 其实网上有很多关于python2.6.6 升级到python2.7的文章,但是我对比这些类似的文章升级之后,发现其中有错误的地方,于是决定还
- 1、下载python3.6的安装包: wget https://www.python.org/ftp/p
- 前言大家好最近python爬虫有点火啊,啥python爬取马保国视频……我也来凑个热闹,今天我们来试着做个翻译软件……不是不是,说错了,今天
- 本意是为了和手写jdbc对照,不过不要和原来的手写连接重名。打开cmd,直接输入notepad就打开了记事本。jdk1.5之后不必配置cla
- return 语句用于退出函数,向调用方返回一个表达式。执行到 return 语句时,会退出函数,return 之后的语句不再执行。如:de
- 尽管Python提供了多个消息框已经能够满足大部分正常人的需求,但并不够灵活,所以有的时候不得不自定义消息框。新建窗口消息框的本质是一个窗口
- 索引的目的在于提高查询效率,可以类比字典,如果要查“mysql”这个单词,我们肯定需要定位到m字母,然后从下往下找到y字母,再找到剩下的sq
- 本文实例讲述了python获取Linux下文件版本信息、公司名和产品名的方法,分享给大家供大家参考。具体如下:区别于前文所述。本例是在lin
- 在我遇到 SimPy 包的其中一位创始人 Klaus Miller 时,从他那里知道了这个包。Miller 博士阅读过几篇提出使用 Pyth
- 目录友情提示:性能优化指标数据库查询优化利用Queryset的惰性和缓存,避免重复查询一次查询所有需要的关联模型数据仅查询需要用到的数据使用
- 最近经常需要出一些临时性的报表,于是就用python 的smtplib 和email 两模块写了个小程序,当数据处理完后通过邮箱把报表文件从
- 介绍 append()语法list.append( element )参数element:任何类型的元素列表「末尾」添加元素nam
- 简述和GNU一样,YAML是一个递归着说“不”的名字。不同的是,GNU对UNIX说不,YAML说不的对象是XML。YAML不是XML。为什么
- queue模块简介queue模块是Python内置的标准模块,模块实现了三种类型的队列,它们的区别仅仅是条目取回的顺序,分别由3个类进行表示
- 声明:请事先到官网下载echarts,另外本文引用了adminlte模板构建前台页面views:<!-- /.row --> &
- 当我们拿到一个对象的引用时,如何知道这个对象是什么类型、有哪些方法呢?使用type()首先,我们来判断对象类型,使用type()函数:基本类
- (一)连接连接通常来自Web服务器,下面列出了一些与连接有关的参数,以及该如何设置它们。1、max_connections这是Web服务器允
- 1. settings.py文件做开发离不开必定离不开日志, 以下是我在工作中写Django项目常用的logging配置.# 日志配置BAS