SQLAlchemy 表达式语言 – 恰到好处

使用 SQLAlchemy 表达式语言进行选择

从数据库中选择属于数据库查询语言 （DQL），我们可以选择所有可用的列或从表中选择几个列。

为此，SQLAlchemy 提供了一个可以从模块导入的函数。如果兴趣仅在表列的子集中，则函数要求在函数调用中将这些列显式指定为参数。selectsqlalchemy.sqlselect

为了访问表的列，实例具有 aattribute，它是表中所有列的集合。例如返回所有列的集合 intable 和访问特定的列可以使用。sqlalchemy.Table.cItem.cItemItem.c.column_name

select_statement = select(Item.c.name, Item.c.id, Item.c.category, ...)

要检索所有列，可以显式指定每个列（如上面的代码片段），也可以按原样给出表实例。

select_statement = select(Item)

db/scripts/items_el.py

class DQL:
    """Encapsulates database query language (DML)"""

    @staticmethod
    def retrieve_all_items():
        """Retrieves all data entries and 
        corresponding columns from Item table.
        """
        with create_connection() as conn:
            return conn.execute(select(Item))

炒作
忽略上面代码中的类和函数构造，魔术是一个简单的语句选择（Item）。其他用于结构，而conn.execute（）是我们之前使用过的熟悉。

创建 DQL 类是为了封装所有选择查询表达式和数据库调用。function 返回所有 Item 条目以及所有列。retrieve_all_items

要检索唯一的 Item 条目，只需将 chainingconstructs 升级到现有构造。.where()select

db/scripts/items_el.py

class DQL:
    """Encapsulates database query language (DML)"""

    # codes from existing methods         

    @staticmethod
    def retrieve_item_by_id(id:int):
        """Retrieves a single item by it's id.

        - id <int> A unique identifier of an item.
        """
        statement = (
            select(Item)
            .where(Item.c.id==bindparam('id', type_=Integer))
        )
        with create_connection() as conn:
            result = conn.execute(statement, {'id': id})
            return result

上面代码段中的 SELECT 语句利用了传递表的（主键）列以实现特异性的构造。.where()idItem

小问题很简单，用于指定我们期望从用户那里获得的值和值的类型。在本例中，我们期待 anof 类型。这作为字典传递给第二个参数。bindparamidIntegerconn.execute

bindparam从 导入自sqlalchemy.sql

使用 SQLAlchemy 表达式语言插入

数据库 INSERT 语句用于填充数据库表。INSERT 是 SQL 中的数据操作语言 （DML） 子句。类的实例具有方法，以便于将数据插入到相应的表中。在数据插入时，我们要么指定我们拥有数据的列名，并将这些数据作为值提供给语句，要么为所有可用列提供数据，同时分解可用约束。sqlalchemy.Table.insert()

语句构造点

1. 指定我们为其提供数据的表列或对所有列进行寻址
2. 将数据作为值发送到语句
3. 因子约束

db/scripts/items_el.py

class DML:
    """Encapsulates database manipulation language (DML)"""

    @staticmethod
    def add_item(name:str, category:str):
        """Adds a single item to Item table"""
        statement = Item.insert().values(name=name, category=category)
        with create_connection() as conn:
            conn.execute(statement)
            conn.commit()

Item.insert().values(name=name, category=category)上面的代码满足插入语句构造概述的所有要点。项目表有 3 列 （）.列未在上面的代码片段中指定，因为它是自动递增的主键，默认情况下会自行填充。我们只提供列。我们也可以省略列，因为它是一个可为空的列，如果未提供任何内容，则默认为 None。也可以利用这些值并将其作为字典提供给函数的第二个参数。id, name & categoryidnamecategorycategorybindparamconn.execute

# every other code above

statement = Item.insert().values(
    name=bindparam('name', type_=String),
    category=bindparam('category', type_=String)
)
with create_connection() as conn:
    conn.execute(statement, {'name': name, 'category': category)

# every other code below

使用函数，一次只能插入一条 Item 记录。SQLAlchemy 允许插入多个项目，这些项目将转换为执行许多语句。add_item(...)

db/scripts/items_el.py

class DML:
    """Encapsulates database manipulation language (DML)"""

    # codes from existing methods 

    @staticmethod
    def add_items(payload:List[Dict[str, str]]):
        """Inserts multiple items to Item table

        - payload <list> new data to be added to
                         Item table. Each dict has
                         key mapped to the Item table
                         and it's corresponding value.
        """
        with create_connection() as conn:
            conn.execute(Item.insert(), payload)
            conn.commit()

add_items函数将一系列键值对作为参数。此参数用作函数调用的第二个参数。insert 语句不必指定任何列 withand，因此，序列有效负载中的键值对应具有所有不可为空的字段。在这种情况下，justkey 值对就足够了，因为列可以自行填充并且列可为空。conn.execute().values()nameidcategory

使用 SQLAlchemy 表达式语言删除

使用 DELETE 语句，可以从数据库表中删除单个、多个或所有记录。类实例有一个方法，可用于从表中删除现有记录。为了特异性，调用构造来标识记录。sqlalchemy.Table.delete().where()

db/scripts/items_el.py

class DML:
    """Encapsulates database manipulation language (DML)"""

    # code from existing methods

    @staticmethod
    def delete_item(item_id:int):
        """Deletes an item whose id is passed as a 
        parameter

        - item_id <int> Uniquely identifies an item
                        instance
        """
        with create_connection() as conn:
            statement = Item.delete().where(
                Item.c.id==bindparam('id', type_=Integer)
            )
            conn.execute(statement, {'id': item_id})
            conn.commit()

delete_item函数采用参数来标识要从项目表中删除的记录。转换为语句：从项目表中删除所有记录。链接构造有助于指定要删除的给定记录。在这种情况下，项列用于记录查找。