主要内容:
1 sqlalchemy: 一个python的ORM框架
2 使用sqlalchemy 的流程:
创建一个类
创建数据库引擎
将所有的类序列化成数据表
进行增删改查操作
# 1.创建一个 Classfrom sqlalchemy.ext.declarative import declarative_baseBase = declarative_base()# Base 是 ORM模型 基类# ORM模型 - Obj里面的属性 == table中创建的字段# - Obj定义table的操作方式和属性from sqlalchemy import Column,Integer,INT,INTEGER,VARCHAR,Stringclass User(Base): __tablename__ = "user" id = Column(Integer,primary_key=True,autoincrement=True) name = Column(String(32),index=True)# 2.创建数据引擎from sqlalchemy import create_engineengine = create_engine("mysql+pymysql://root:@127.0.0.1:3306/sqlalchemy_s14?charset=utf8")# 3.将所有的继承Base的Class序列化成数据表Base.metadata.create_all(engine)
增删改操作
#1.选中数据库 - 创建数据库引擎 导入数据库引擎from model import engine#2.创建查询窗口,必须是选中数据库的查询窗口from sqlalchemy.orm import sessionmakerSession_window = sessionmaker(engine)# 打开查询窗口db_session = Session_window()3 增加数据# user_obj = User(name='yuyu',age=12)# db_session.add(user_obj)# db_session.commit() #执行全部sql语句# add_list = [User(name='yu2yu',age=12), User(name='yu1yu',age=12)]# db_session.add_all(add_list)# db_session.commit()# db_session.close() 删除数据# res = db_session.query(User).filter(User.id>=8).all()# for one in res:# db_session.delete(one)# db_session.commit()修改数据# 修改数据user_obj = db_session.query(User).filter(User.id==5).update({"name":"yu"})res1 = db_session.query(User).all()for one_info in res1: print(one_info.id, one_info.name)