当前位置: 首页 > Python编程 > Python编程实战技能 > Python编程基础入门 > Python之ORM框架SQLAlchemy

Python之ORM框架SQLAlchemy

发布时间:2020年09月27日 09:53:19 来源: 点击量:452

【摘要】一、SQLAlchemy简介SQLAlchemy是Python SQL工具包和对象关系映射器,是python中最著名的ORM(Object Relationship Mapping)框架,它简化

一、SQLAlchemy简介

SQLAlchemy是Python SQL工具包和对象关系映射器,是python中最著名的ORM(Object Relationship Mapping)框架,它简化了应用程序开发人员在原生SQL上的操作,使开发人员将主要精力都放在程序逻辑上,从而提高开发效率。它提供了一整套著名的企业级持久性模式,设计用于高效和高性能的数据库访问。

使用ORM操作数据库:

优势 :代码易读,隐藏底层原生SQL语句,提高了开发效率。

劣势 :执行效率低 ,将方法转换为原生SQL后 原生SQL不一定是最优的。

环境:

Windows 7  x64   python 3.7.1  SQLAlchemy 1.3.5   pymysql 0.9.3    mysqld  5.6.43

关于如何安装上述环境,这里不做演示,相信大家能搜到这篇文章,想必这种小问题不在话下。

二、简单的操作

1、准备数据库sql_demo

mysql> create database sql_demo;

2、在sql_demo中创建表

from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import Column, Integer, String
from sqlalchemy import create_engine
Base = declarative_base()  # 导出官方基础类
class SQLDemo(Base):
    __tablename__ = 'SqlDemo'  # 表名
    # 创建字段
    id = Column(Integer,primary_key=True,autoincrement=True)
    name = Column(String(32))
# 创建数据库引擎
engine = create_engine('mysql+pymysql://数据库用户:数据库密码@127.0.0.1:3306/数据库名?charset=utf8')
# 创建表
Base.metadata.create_all(engine)

运行上面的代码后会在数据库sql_demo中创建一个名为sqldemo的表。

3、向表中添加数据。

from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import Column, Integer, String
from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker
Base = declarative_base()  # 导出官方基础类
class SQLDemo(Base):
    __tablename__ = 'SqlDemo'  # 表名
    # 创建字段
    id = Column(Integer,primary_key=True,autoincrement=True)
    name = Column(String(32))
# 创建数据库引擎
engine = create_engine('mysql+pymysql://root:123@127.0.0.1:3306/sql_demo?charset=utf8')
# 创建表
# Base.metadata.create_all(engine)
# 向表中添加数据
obj = SQLDemo(name='小明')
# 创建会话
obj_session = sessionmaker(engine)
# 打开会话
db_session = obj_session()
# 向表中添加数据,此时数据保存在内存中
db_session.add(obj)
# 提交数据,将数据保存到数据库中
db_session.commit()
# 关闭会话
db_session.close()

相关推荐:《Python视频教程》

3.1向表中添加多条数据。

 向表中添加多条数据

 添加后的数据如下:

4、查询表中数据

from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import Column, Integer, String
from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker
Base = declarative_base()  # 导出官方基础类
class SQLDemo(Base):
    __tablename__ = 'SqlDemo'  # 表名
    # 创建字段
    id = Column(Integer,primary_key=True,autoincrement=True)
    name = Column(String(32))
# # 创建数据库引擎
engine = create_engine('mysql+pymysql://root:123@127.0.0.1:3306/sql_demo?charset=utf8')
# 创建会话
obj_session = sessionmaker(engine)
# 打开会话
db_session = obj_session()
# 查询表中所有数据
all_list = db_session.query(SQLDemo).all()
for obj in all_list:
    print(obj.id,obj.name)
# 提交数据,将数据保存到数据库中
db_session.commit()
# 关闭会话
db_session.close()

 最终打印结果如下:

4.1使用filter过滤查询条件

from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import Column, Integer, String
from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker
Base = declarative_base()  # 导出官方基础类
class SQLDemo(Base):
    __tablename__ = 'SqlDemo'  # 表名
    # 创建字段
    id = Column(Integer,primary_key=True,autoincrement=True)
    name = Column(String(32))
# # 创建数据库引擎
engine = create_engine('mysql+pymysql://root:123@127.0.0.1:3306/sql_demo?charset=utf8')
# 创建会话
obj_session = sessionmaker(engine)
# 打开会话
db_session = obj_session()
# 使用filter过滤查询条件
all_list = db_session.query(SQLDemo).filter(SQLDemo.name=='小明')
for obj in all_list:
    print(obj.id,obj.name)
# 提交数据,将数据保存到数据库中
db_session.commit()
# 关闭会话

5、修改数据

from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import Column, Integer, String
from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker
Base = declarative_base()  # 导出官方基础类
class SQLDemo(Base):
    __tablename__ = 'SqlDemo'  # 表名
    # 创建字段
    id = Column(Integer,primary_key=True,autoincrement=True)
    name = Column(String(32))
# 创建数据库引擎
engine = create_engine('mysql+pymysql://root:123@127.0.0.1:3306/sql_demo?charset=utf8')
# 创建会话
obj_session = sessionmaker(engine)
# 打开会话
db_session = obj_session()
# 更改id是2的name为娃哈哈
all_list = db_session.query(SQLDemo).filter(SQLDemo.id==2).update({'name':'娃哈哈'})
# 提交数据,将数据保存到数据库中
db_session.commit()
# 关闭会话
db_session.close()

6、删除数据

from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import Column, Integer, String
from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker
Base = declarative_base()  # 导出官方基础类
class SQLDemo(Base):
    __tablename__ = 'SqlDemo'  # 表名
    # 创建字段
    id = Column(Integer,primary_key=True,autoincrement=True)
    name = Column(String(32))
# # 创建数据库引擎
engine = create_engine('mysql+pymysql://root:123@127.0.0.1:3306/sql_demo?charset=utf8')
# 创建会话
obj_session = sessionmaker(engine)
# 打开会话
db_session = obj_session()
# 删除id是2的行
all_list = db_session.query(SQLDemo).filter(SQLDemo.id==2).delete()
# 提交数据,将数据保存到数据库中
db_session.commit()
# 关闭会话
db_session.close()

分享到: 编辑:wangmin

就业培训申请领取
您的姓名
您的电话
意向课程
点击领取

环球青藤

官方QQ

扫描上方二维码或点击一键加群,免费领取大礼包,加群暗号:青藤。 一键加群

绑定手机号

应《中华人民共和国网络安全法》加强实名认证机制要求,同时为更加全面的体验产品服务,烦请您绑定手机号.

预约成功

本直播为付费学员的直播课节

请您购买课程后再预约

环球青藤移动课堂APP 直播、听课。职达未来!

安卓版

下载

iPhone版

下载
环球青藤官方微信服务平台

刷题看课 APP下载

免费直播 一键购课

代报名等人工服务

课程咨询 学员服务 公众号

扫描关注微信公众号

APP

扫描下载APP

返回顶部