我正在阅读 SQLAlchemy对象关系教程,我对 query() 函数有点困惑。
from sqlalchemy import create_engine
engine = create_engine('sqlite:///users.db', echo=True)
from sqlalchemy.ext.declarative import declarative_base
Base = declarative_base()
from sqlalchemy import Column, Integer, String
from sqlalchemy import Sequence
class User(Base):
__tablename__ = 'users'
id = Column(Integer, Sequence('user_id_seq'), primary_key=True)
name = Column(String(50))
fullname = Column(String(50))
password = Column(String(12))
def __init__(self, name, fullname, password):
self.name = name
self.fullname = fullname
self.password = password
def __repr__(self):
return "<User('%s','%s', '%s')>" % (self.name, self.fullname, self.password)
Base.metadata.create_all(engine)
from sqlalchemy.orm import sessionmaker
Session = sessionmaker(bind=engine)
session = Session()enter code here
ed_user = User('ed', 'Ed Jones', 'edspassword')
session.add(ed_user)
our_user = session.query(User).filter_by(name='ed').first()
session.add_all([User('wendy', 'Wendy Williams', 'foobar'),User('mary', 'Mary Contrary', 'xxg527'),User('fred', 'Fred Flinstone', 'blah')])
session.commit()
医生说
会话将在需要时立即发出 SQL 以持久化 Ed Jones,使用称为刷新的过程。如果我们查询 Ed Jones 的数据库,所有待处理的信息将首先被刷新,然后立即发出查询。
如果我跑
our_user = session.query(User).filter_by(name='ed').first()
它实际上发布了
BEGIN (implicit)
INSERT INTO users (name, fullname, password) VALUES (?, ?, ?)
('ed', 'Ed Jones', 'edspassword')
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 = ?
LIMIT ? OFFSET ?
('ed', 1, 0)
但是,数据库在 session.commit() 执行之前没有得到更新(它是空的)。
我的问题是: 1. 为什么挂起的数据被刷新,甚至显示 INSERT INTO 用户,数据库仍然是空的?2. 数据库不包含刷新的数据,但是如果通过运行ed_user.id它返回了正确的主键?
谢谢