Python之ORM框架SQLAlchemy

一、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

<pre class="brush:php;toolbar:false">mysql> create database sql_demo;</pre>

2、在sql_demo中创建表

<pre class="brush:php;toolbar:false">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)</pre>

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

3、向表中添加数据。

<pre class="brush:php;toolbar:false">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()</pre>

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

3.1向表中添加多条数据。

 向表中添加多条数据

 添加后的数据如下：

4、查询表中数据

<pre class="brush:php;toolbar:false">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()</pre>

 最终打印结果如下：

4.1使用filter过滤查询条件

<pre class="brush:php;toolbar:false">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() # 关闭会话</pre>

5、修改数据

<pre class="brush:php;toolbar:false">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()</pre>

6、删除数据

<pre class="brush:php;toolbar:false">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()</pre>

您可能感兴趣的文章：
python orm框架有哪些
Flask与Django框架的区别
Python之ORM框架SQLAlchemy
django有什么用
flask框架使用什么数据库
为什么用flask
django是什么
轻量级web框架Flask是什么
盘点Flask常用扩展包
django有多难