灵魂三问大法：
乔巴.png
一、是个啥？
SQLAlchemy是Python中最著名的ORM框架，该框架建立在数据库API之上，使用关系对象映射进行数据库操作，简单点：将对象转换成SQL，然后使用数据API执行SQL语句来操作数据库。
二、有啥用？
能够让我们将对数据库的操作（主要指SQL语句）转换为对对象属性的操作。也就是我们将数据表抽象成一个ORM对象，然后通过一系列简单的操作就可以完成数据库操作。多数web框架都可以使用sqlalchemy
三、咋用？
ORM
1 class-obj
创建一个Class
from sqlalchemy.ext.declarative_base import declarative_base from sqlalchemy import Column,Integer,INT,INTEGER,VARCHAR,String,NVARCHAR Base = declarative_base() # 这个Base就是ORM模型的基类 class User(Base): __tablename__ = 'user' # 数据库表名 id = Cloumn(Integer,primary_key=True,autoincrenment=True) # 这是一个字段Integer类型 等效于INT 等效于INTEGER，you happy is good；主键，自增。 name = Cloumn(String(32),index=True) # String 等效于VARCHAR,you happy is good, 索引。
2 创建数据库引擎
创建数据引擎
from sqlalchemy import create_engine engine = create_engine("mysql+pymysql://root:@127.0.0.1:3306/sqlalchemy_s?charset=utf8")
3 将所有的class序列化成数据表
将所有继承Base的Class序列化成数据表
Base.metadata.create_all(engine) # mysql模块要确认是否已安装
4 ORM操作-CRUD
1 增加数据
回顾一下我们使用原生SQL对数据库的操作步骤（以navcat可视化操作为例方便理解记忆）：
- 选中数据库（表）
- 创建查询窗口
- 创建SQL语句
- 点击运行
ORM操作步骤是一样的一一对应的：
创建数据库引擎，导入数据库引擎
from create_table import engine创建查询窗口，必须是选中的数据库的查询窗口
from sqlalchemy.orm import sessionmaker Session_window = sessionmaker(engine) db_session = Session_window() # 打开查询窗口增加数据
# INSERT INTO table(name) VALUES('Gavin'); from create_table import User User(name="Gavin") # 创建一个SQL语句 db_session.add(user_obj) # 将SQL语句粘贴到查询窗口中 sb_session.commit() # 执行全部的sql语句 相当于点击运行按钮 db_session.close() # 关闭窗口增加多条数据
from create_table import User user_obj_list = [User(name="Carrie"),User(name="Gavin")] db_session.add_all(user_obj_list) db_session.commit() db_session.close()
2 查询数据
# SELECT # FROM 数据源 # 1 创建查询窗口 from create_table import engine,user from sqlalchemy.orm import sessionmaker Session = sessionmaker(engine) db_session = Session() # 2 使用查询窗口进行查询 user_obj = db_session.query(User).first() # 查询单个数据对象 print(user.id, user.name) user_obj_list = db_session.query(User).all() # 查询全部数据对象 print(user_obj_list) for row in user_obj_list: print(row.id ,row.name) user_obj_list = db_session.query(User).filter(User.id <=2， User.name=='Gavin').all() # 查询符合filter表达式的全部数据对象 print(user_obj_list) for row in user_obj_list: print(row.id ,row.name) user_obj_list = db_session.query(User).filter_by(id=2， name=='Gavin').all() # filter_by是通过传参的方式进行查询，效果等同于filte，大于用gt，小于用lt等等
3 UPDATE
# UPDATE table SET name="Gavin" WHERE id=1； # 1 创建查询窗口 from sqlalchemy.orm import sessionmaker from create_table import engine,User Session = sessionmaker(engine) db_session = Session() # 2 修改一条数据 user_obj = db_session.query(User).filter(id==1).update({"name":"Carrie"}) print(user_obj) # 这里返回的是受影响的行数 db_session.commit() # 执行 # 3 修改多条数据 user_obj = db_session.query(User).filter(id>=1).update({"name":"Gavin"}) print(user_obj) # 这里打印的是受影响的行数 db_session.commit() # 执行
4 删除
# DELETE FROM table --删除表数据保留表 # 1 创建查询窗口 from sqlalchemy.orm import sessionmaker from create_table import engine,User Session = sessionmaker(engine) db_session = Session() # 2 删除单条数据 res = db_session.query(User).filter(User.id==1).delete() print(res) # 这里打印的是受影响的行数 db_session.commit() # 执行 # 3 删除多条数据 res = db_session.query(User).filter(User.id>=1).delete() print(res) # 这里打印的是受影响的行数 db_session.commit() # 执行
好，以上就是SQLALchemy的ORM操作，就是这么简单，OVER！！！
好吧，其实没那么简单，这里只是完成了单表的操作，未完待续。。。
