此文档为个人笔记,完整的请查看官方文档。
摘自SQLAlchemy ORM
当前使用的sqlalchemy
版本为1.1.15
添加和更新对象
>>> ed_user = User(name='ed', fullname='Ed Jones', password='edspassword')
>>> session.add(ed_user)
此时,我们说实例正在等待 ; 尚未发布SQL并且该对象尚未由数据库中的行表示。该 Session
会发出SQL持久化,只要需要使用被称为一个冲洗的过程。如果我们查询数据库,所有待处理的信息将首先被刷新,并且查询立即发出。Ed Jones``Ed Jones
例如,下面我们创建一个Query
加载实例的新对象User
。我们“过滤”的name
属性 ed
,并表明我们只想要完整列表中的第一个结果。User
返回的实例与我们添加的实例相同:
>>> our_user = session.query(User).filter_by(name='ed').first()
>>> our_user
<User(name='ed', fullname='Ed Jones', password='edspassword')>
事实上,Session
已经确定返回的行与已经在其内部对象映射中表示的行相同,因此我们实际上取回了与刚才添加的相同的实例:
>>> ed_user is our_user
True
在这里工作的ORM概念被称为身份映射, 并确保在一个特定的行上的所有操作对 Session
同一组数据进行操作。一旦一个具有特定主键的对象出现在该对象中 Session
,那么所有的SQL查询 Session
将总是为该特定主键返回相同的Python对象; 如果尝试在会话中放置第二个已保存的具有相同主键的对象,也会引发错误。
我们可以User
一次添加更多的对象,使用 add_all()
:
>>> session.add_all([
... User(name='wendy', fullname='Wendy Williams', password='foobar'),
... User(name='mary', fullname='Mary Contrary', password='xxg527'),
... User(name='fred', fullname='Fred Flinstone', password='blah')])
另外,我们已经决定Ed的密码不太安全,所以让我们改变它:
创建一个模式
User
通过Declarative系统构造我们的类,我们定义了关于表的信息,称为表元数据。SQLAlchemy用于表示特定表的这些信息的Table
对象称为对象,这里的Declarative已经为我们制作了一个对象。我们可以通过检查__table__
属性来看到这个对象:
>>> User.__table__
Table('users', MetaData(bind=None),
Column('id', Integer(), table=<users>, primary_key=True, nullable=False),
Column('name', String(), table=<users>),
Column('fullname', String(), table=<users>),
Column('password', String(), table=<users>), schema=None)
当我们宣布我们的类时,Declarative使用Python元类来完成类声明完成后的额外活动; 在这个阶段中,Table
根据我们的规范创建一个对象,并通过构造一个Mapper
对象将它与类关联起来。这个对象是我们通常不需要直接处理的幕后对象(虽然它可以在我们需要时提供关于我们映射的大量信息)。
该Table
对象是已知为较大集合的成员MetaData
。当使用Declarative时,这个对象可以使用.metadata
我们的声明基类的属性。
这MetaData
是一个注册表,它包括向数据库发送一组有限的模式生成命令的功能。由于我们的SQLite数据库实际上并没有users
表格,因此我们可以使用MetaData
CREATE TABLE语句向数据库发布所有尚不存在的表格。下面,我们称之为MetaData.create_all()
方法,传入我们Engine
作为数据库连接的来源。我们将看到首先发出特殊命令来检查users
表的存在,然后再看看实际的语句:CREATE TABLE
>>> Base.metadata.create_all(engine)
SELECT ...
PRAGMA table_info("users")
()
CREATE TABLE users (
id INTEGER NOT NULL, name VARCHAR,
fullname VARCHAR,
password VARCHAR,
PRIMARY KEY (id)
)
()
COMMIT
连接
懒惰连接:当create_engine()第一次被返回的时候,并不会建立到数据库的连接,数据库的连接只发生在第一次要对数据库进行操作的时候。
会话
使用会话构造器来创建会话类
再使用会话类去实例化会话。
>>> from sqlalchemy import create_engine
>>> engine = create_engine('sqlite:///:memory:', echo=True)
>>> from sqlalchemy.orm import sessionmaker
>>> Session = sessionmaker(bind=engine)
>>> Session = sessionmaker()
>>> Session.configure(bind=engine) # once engine is available
>>> session = Session()
以上Session
与我们启用SQLite的相关Engine
,但它尚未打开任何连接。当它第一次使用时,它会从由Engine
它维护的连接池中检索一个连接 ,并保留它,直到我们提交所有更改和/或关闭会话对象。