Python ORM框架SQLAlchemy学习笔记之数据添加和事务回滚介绍

2019-10-06 14:02:27于海丽

无论是立即(commit、flush)或者通过“首次访问加载(load-on-first-access)”,在Session在数据库插入一条新记录后,所有新生成的标识和数据库生成的默认值对于实例来说才可以被访问到。

当调用了commit()以后,SQLAlchemy将会刷新当前事务的所有数据到数据库里。

2. 事务回滚

本文以及同系列的文章是以自己的想法翻译的,不当之处还请指正,不做权威依据。好了,下面我还是简单介绍一下事务回滚吧,其实这个和数据库的事务回滚一个意思,就是我们做错事后要撤消之前的变更。

因为Session是作为事务(transaction)来工作的,所以我们可以回滚(roll back)先前所做的更改。接下来让我们做两个稍后会被撤销(回滚)的更改,第一个是修改ed_user.name:

>>> ed_user.name = 'Edwardo'
第二个是增加一个“不期望”的用户fake_user:

>>> fake_user = User('fakeuser', 'Invalid', '12345')
>>> session.add(fake_user)
查询当前会话,我们可以看到这两个变更已经被flush到当前事务里了:

>>> session.query(User).filter(User.name.in_(['Edwardo', 'fakeuser'])).all()
UPDATE users SET name=? WHERE users.id = ?
('Edwardo', 1)
INSERT INTO users (name, fullname, password) VALUES (?, ?, ?)
('fakeuser', 'Invalid', '12345')
SELECT users.id AS users_id,
        users.name AS users_name,
        users.fullname AS users_fullname,
        users.password AS users_password
FROM users
WHERE users.name IN (?, ?)
('Edwardo', 'fakeuser')
[<User('Edwardo','Ed Jones', 'f8s7ccs')>, <User('fakeuser','Invalid', '12345')>]
好吧,接下来是见证奇迹的时刻,我们回滚(rolling back)事务:

>>> session.rollback()
ROLLBACK
>>> ed_user.name
BEGIN (implicit)
SELECT users.id AS users_id,
        users.name AS users_name,
        users.fullname AS users_fullname,
        users.password AS users_password
FROM users
WHERE users.id = ?
(1,)
u'ed'
>>> fake_user in session
False


我们可以看到ed_user的名字变回ed,并且我们不期望的用户fake_user被“踢出”会话(Session)了。

最后,我们可以查询一下用户名在['ed', 'fakeuser']范围的用户,确保我们的更改是有效的:

>>> session.query(User).filter(User.name.in_(['ed', 'fakeuser'])).all()
SELECT users.id AS users_id,
        users.name AS users_name,
        users.fullname AS users_fullname,
        users.password AS users_password