sqlalchemy mysql教程_python使用SQLAlchemy操作MySQL
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()
运行程序后,表格中的数据如下:
本次分享到此结束,感谢大家阅读~
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持python博客。
sqlalchemy mysql教程_python使用SQLAlchemy操作MySQL相关推荐
- linux c mysql教程_linux下c操作mysql之增删改查
书接上文,继续进行linux 下c操作mysql. 1.创建表/插入数据 mysql> desc children -> ; +---------+-------------+------ ...
- MySQL Workbench 使用教程 - 如何使用 Workbench 操作 MySQL / MariaDB 数据库中文指南
MySQL Workbench 是一款专门为 MySQL 设计的可视化数据库管理软件,我们可以在自己的计算机上,使用图形化界面远程管理 MySQL 数据库. 有关 MySQL 远程管理软件,你可以选择 ...
- .NET 使用 MySql.Data.dll 动态库操作MySql的帮助类--MySqlHelper
.NET 使用 MySql.Data.dll 动态库操作MySql的帮助类--MySqlHelper 參考演示样例代码,例如以下所看到的: /// <summary>/// MySql 数 ...
- PHP访问mysql的常用函数,PHP操作MySQL数据库常用函数
PHP操作MySQL数据库常用函数 php操作mysql数据库,俗称天龙八步: 第一步:连接数据库 第二步:判断连接错误 第三步:选择数据库 第四步:设置字符集 第五步:准备SQL语句 第六步:执行并 ...
- python加mysql加界面用代码写_python加mysql_python操作mysql
python操作mysql可用的第三方库有MySQLdb,pymysql等. 下面主要讲解MySQLdb: 1.用pip安装mysqlclient库,连接python和mysql pip3 insta ...
- swoole 连接mysql_swoole教程:用swoole4操作mysql连接池之读写分离
为什么要读写分离? 一般的系统都是读多写少,利用读写分离,可以提升mysql的效率 读写分离后,从库可以水平扩展 下面我们开始代码之旅吧 配置先改造: $config = [ 'host'=> ...
- php如何操作mysql数据库代码_php如何操作mysql数据库的类(附代码)
这篇文章主要介绍了php简单操作mysql数据库的类,涉及php操作mysql的连接.查询.插入.删除等基本操作方法,非常具有实用价值,需要的朋友可以参考下.<?php /** * Databa ...
- perl mysql 数据推拉_Perl操作Mysql数据库
1. CGI变量简介 如果你在以前使用过传统的CGI,你应该对"CGI变量"的概念很熟悉. 由这些变量可以取得一些和请求(Request)有关的信息.其中一些来自于 HTTP 请求 ...
- 使用jdbc操作mysql数据库_java使用JDBC操作MYSQL数据库
1.新建数据库 DROP TABLE IF EXISTS `test`.`user`; CREATE TABLE `test`.`user` ( `username` varchar(45) DEFA ...
最新文章
- weblogic oracle连接池配置文件,关于WebLogic 访问Oracle 数据库(建立连接池)问题...
- oracle删除表中数据_工作表中提供的特定数据在数据库中批量删除的方法
- 何为消息队列,为何使用消息队列,有什么消息队列插件
- UEFI下面安装win7+Xubuntu18.10双系统
- composer在windows中安装失败
- java流与文件——流
- 为什么R语言是学习数据分析的第一选择
- 程序员被纳入新生代农民工;“腾讯视频崩了”上热搜;英特尔发布全新独立显卡品牌 Arc|极客头条...
- mysql 5.7 多线程主从复制_Mysql 5.7从节点配置多线程主从复制的方法详解
- [机器学习]关联挖掘算法Apriori和FP-Growth以及基于Spark 实例
- Deepin linux 15.9.1 Ubuntu 16.04 安装zsteg、gem
- vba 定义数组_excel自定义排序的三种方法
- C# 图片验证码简单例子
- Unity-创建一个小地图
- hget和get redis_Redis Hash 的 HSET、HGET、HMSET、HMGET 性能测试
- 失恋33天——我用57天考了一个5A
- 六、Kali Linux 2 远程控制
- ubuntu 7z解压
- meta标签下http-equiv 属性详解
- python爬虫实战-如何批量爬取唯品会商品信息>>>