a54546 发表于 2025-2-7 00:02:34

python SQLAlchemy ORM——从零开始学习 02简单的增删查改

02 简单的增删查改

前情提要:承接了01中的engine以及User类
2-1 了解会话机制


[*]个人理解
在SQLAlchemy 增删查改中是依赖会话(Session)这个机制进行操作的,我个人的理解是用“会话“进行连接数据库周期的一系列管理操作(以下是ai生成对此会话的理解)
[*]ai理解
在 SQLAlchemy 中,sessionmaker 是用于创建 会话(Session) 对象的工厂类,负责与数据库的交互。会话(Session)是 SQLAlchemy ORM 的核心部分,它管理与数据库的连接,并在一次操作中追踪对象的状态变化(如添加、修改、删除),同时处理事务的提交和回滚。
会话(Session)的作用

[*]管理事务:会话负责开始、提交和回滚事务。通过会话,SQLAlchemy 可以在多个数据库操作间提供原子性(即要么全部成功,要么全部失败)。
[*]对象的持久化:会话在内存中追踪对象的状态变化,确保对象在数据库中得到正确的插入、更新或删除。
[*]查询管理:会话管理 SQL 查询的生命周期,包括从数据库获取数据,执行查询语句等。

2-2 创建会话


[*]流程:

[*]导入对应包,依赖其中的 sessionmaker
[*]使用sessionmaker 生成新的会话对象 Session ,生成时绑定之前创建过的引擎
[*]通过Session对象我们来构造对应的实例【可能有点绕,但一开始2调用的只是我们绑定好的类,我们还需要对这个对象创造实例来进行会话管理操作】

[*]官方的用例参考,他用的数据库类型不一样,但是思路是一样的:
eg1:
from sqlalchemy import create_enginefrom sqlalchemy.orm import sessionmaker# an Engine, which the Session will use for connection# resourcesengine = create_engine("postgresql+psycopg2://scott:tiger@localhost/")Session = sessionmaker(engine)with Session() as session:    session.add(some_object)    session.add(some_other_object)    session.commit()eg2:这个就是后文使用的创建实例进行操作了
session = Session()try:    session.add(some_object)    session.add(some_other_object)    session.commit()finally:    session.close()eg3:
Session = sessionmaker(engine)with Session.begin() as session:    session.add(some_object)    session.add(some_other_object)# commits transaction, closes session
[*]看完官方的实例,来写我们自己的会话管理了:

[*]简化版:
from test_package_sql import engine, User #这个只是导入01文件提及的engine和User类,名字自己改一下from sqlalchemy.orm import sessionmakerSession = sessionmaker(bind=engine)#先通过时间创造器绑定引擎->创建这个会话类session = Session()#根据我们自己的Session类创建属于我们自己的实例对象用于后续操作
[*]详细版:
from sqlalchemy import create_engine, Column, Integer, Float, Stringfrom sqlalchemy.orm import declarative_basefrom sqlalchemy.orm import sessionmakerlocal_url = "sqlite:///02_test.db"engine = create_engine(url=local_url)local_base = declarative_base()class User(local_base):    __tablename__ = "User"    id = Column(Integer, primary_key=True)    name = Column(String)    age = Column(Integer)local_base.metadata.create_all(engine)

2-3 增


[*]事前bb【觉得烦的可以略过】
在进行增删查改前,必须再强调一下这个会话机制的流程:创建会话->进行管理操作(包括但不不限于增删查改)->提交会话管理【注意,提交时的更改的只是当前会话状态,言下之意,你提交了一次再修改,没提交那还是之前提交的状态】
[*]流程介绍【增加单个User对象】

[*]创建需要增添的实例——必须与User类相匹配,就是说是User类对象
[*]使用对话机制的 session.add接口进行添加
[*]添加若干个后,结束则使用 session.commit() 进行修改后的提交
主函数直接调用就好,我这样子写好封装,看得也清楚,很简单对吧
def add_one():    User1 = User(name="arthur",age=18)    User2 = User(name="lihua",age=21)    session.add(User1)    session.add(User2)    session.commit()

[*]增添效果如下【db为空时】:

下一集我再对如何显示数据库做一个解释吧,毕竟是从零开始(bushi)

[*]增添多个对象【或者是User_list】
只需要修改接口以及传入参数就好了,使用 session.add_all()接口
def add_Users():    User1 = User(name="arthur", age=18)    User2 = User(name="lihua", age=21)    Users =     session.add_all(Users)    session.commit()

[*]explain:Users就是User 类(项目)的可迭代对象(列表),让我们看看官方对于这个接口的解释:
method sqlalchemy.orm.Session.add_all(instances: Iterable) → None
Add the given collection of instances to this Session.
添加实例到Seesion会话中。这句话可能不太好理解,看看他的传参解释其实就很直观,其实就是传入可迭代对象XD


[*]output:

就结束了,其实增删改查不难,接口已经抽象出来了,记住逻辑就好

2-4 查

还是得先说查啊,不然没法删啊0v0

[*]接口介绍
q = session.query(SomeMappedClass)

[*]参数介绍:
SomeMappedClass:所映射的类
q:返回的类型是Query,即任何满足要求的数据
[*]常用后缀

[*].all():以列表的形式传回搜索的结果
session.query(User).all()#用来返回User表的所有数据
[*]sqlalchemy.orm.Query.filter_by(* *kwargs)¶ 这个是常用的简化版的搜索接口。!注意他可以同时接收多个变量,且只使用等值过滤条件
results = session.query(User).filter_by(ag,e=21)results = session.query(User).filter_by(age=21,name="lihua")
[*]session.query(Model).filter(condition)
运行使用多个复杂的表达式,支持更多条件类型,支持手动连接多个条件:如果需要多个条件,可以使用 AND 或 OR 手动连接条件。但就说注意对比时需要User.xxx--你自己定义的类表
results = session.query(User).filter(User.name == 'arthur')#不止支持== ,还支持其他比较运算符
[*].one_or_none()
用于查找是否只有一个或者none个,找到多个则会报错


[*]编码
其实把上面的看懂了就已经学会了如何搜索了

[*]简单搜索法:
def search():    results = session.query(User).filter_by(age=21)    for result_one in results:      print(result_one)
[*]使用传统接口更多扩展的的搜索:
def other_way_search():    results = session.query(User).filter(User.name == 'arthur')    for result_one in results:      print(result_one)


2-5 删


[*]删除主要运用到 session.delete(object)接口,主要有以下两种用法:

[*]删除单个对象:
session.delete(object)#object是单个对象session.commit()
[*]删除多个满足条件的对象
session.query(Model).filter(condition).delete()session.commit()流程大概是:找到想要删除的对象->删除->提交


[*]code:
def remove_one():#单个    results = session.query(User).filter_by(age=21).first()#找到第一个    session.delete(results)    session.commit()原数据库:

删除后:

def remove_all():#多个    results = session.query(User).filter_by(name='arthur').delete()    session.commit()删除后:

[*]删除尾声:
删除就结束了,最后各位可以尝试把lihua也删除,然后根据上面的教程添加再添加4个User信息,其中要有两个age、name不一样
参考code:
def add_4new_user():    User1 = User(name='arthur', age=18)    User2 = User(name='Abigail Williams',age=14)    User3 = User(name='caster', age=21)    User4 = User(name='Lilith', age=22)    users =     session.add_all(users)    session.commit()结果:

2-6 改

改其实最简单,找到对应的object然后修改,提交即可,非常朴实无华
def update_f():    caster = session.query(User).filter_by(name="caster").one_or_none()#找到一个caster的信息    caster.age = 18                        #修改就好啦    session.commit()                #记得提交
part2结束,感谢观看,读者可以自行实践一下增删查改,最好融合起来一起实践
页: [1]
查看完整版本: python SQLAlchemy ORM——从零开始学习 02简单的增删查改