2018-06-05 sqlalchemy

2018-06-05  本文已影响0人  lucasdada

此文档为个人笔记,完整的请查看官方文档。
摘自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它维护的连接池中检索一个连接 ,并保留它,直到我们提交所有更改和/或关闭会话对象。

上一篇下一篇

猜你喜欢

热点阅读