问题[sqlalchemy]

在最后一个问题中，我实现了对数据库的查询。

all_rows = db.session.query(
                    TABLE_1.field1,
                    TABLE_1.field2,
                    TABLE_2.field3
                ).join(
                    TABLE_2, TABLE_1.id == TABLE_2.table1_id
                ).filter(
                    TABLE_1.field1== obj_el.value1,
                    TABLE_1.field2== obj_el.value2,
                    TABLE_2.field3 == obj_el.value3
                ).all()

现在问题来了，如何在这里添加别名？例如这种：

all_rows = db.session.query(
                    ......
                    TABLE_2.field4 * 10 as 'nameAlias'
                ).join(....

我开始使用 FastAPI 框架并将 SQLAlchemy 连接到它，总的来说，它不是很高兴，因为我不喜欢将不必要的抽象连接到我的代码中，而是基于互联网上的意见和创建者的事实框架在我决定使用它的示例中推荐这个 ORM。

错误如下：

asyncpg.exceptions.DataError: invalid input for query argument $1: 'lalala@gmail.com' (a bytes-like object is required, not 'str')

存储包db.py文件：

from databases import Database
import sqlalchemy

address = ""

storage = Database(address)

metadata = sqlalchemy.MetaData()

consumers = sqlalchemy.Table(
    "consumers",
    metadata,
    sqlalchemy.Column("id", sqlalchemy.Integer, primary_key=True),
    sqlalchemy.Column("first_name", sqlalchemy.String),
    sqlalchemy.Column("last_name", sqlalchemy.String),
    sqlalchemy.Column("email", sqlalchemy.String, unique=True),
    sqlalchemy.Column("password", sqlalchemy.String)
)

engine = sqlalchemy.create_engine(address)

metadata.create_all(engine)

我的检索代码，放在utils.py文件中的存储包中：

from .db import consumers, storage

async def get_user_by_email(email: str):
    return await storage.fetch_one(
        consumers.select().where(consumers.c.email == email)
    )

身份验证包中的models.py文件：

from pydantic import BaseModel, EmailStr


class CreateConsumer(BaseModel):
    email:            EmailStr
    first_name:       str
    last_name:        str
    password:         str
    confirm_password: str

身份验证包中的routes.py文件：

from fastapi import APIRouter
from .models import CreateConsumer
from storage.utils import get_user_by_email

authentication = APIRouter()


@authentication.post('/sign-up')
async def sign_up(user: CreateConsumer):
    if await get_user_by_email(user.email):
        pass

在解析/修改别人代码的过程中，同步脚本时同步依赖实体（Person-Child）时出现错误。显然，出现了这样一种情况，它session.add(person)试图将先前被同步器删除的 orm-Child 对象添加到数据库中：

  session.add(person)
  File "/home/web/portal/env/local/lib/python2.7/site-packages/sqlalchemy/orm/session.py", line 1559, in add
    self._save_or_update_state(state)
  File "/home/web/portal/env/local/lib/python2.7/site-packages/sqlalchemy/orm/session.py", line 1578, in _save_or_update_state
    self._save_or_update_impl(st_)
  File "/home/web/portal/env/local/lib/python2.7/site-packages/sqlalchemy/orm/session.py", line 1828, in _save_or_update_impl
    self._update_impl(state)
  File "/home/web/portal/env/local/lib/python2.7/site-packages/sqlalchemy/orm/session.py", line 1814, in _update_impl
    state_str(state)
InvalidRequestError: Instance '<Child at 0xec10afec>' has been deleted.  Use the make_transient() function to send this object back to the transient state.

1. 标记一个对象是什么意思make_transient()——在这样的上下文中应该如何以及为什么要使用它？

2. 在代码过程中，还使用了另一种单次请求删除对象的策略：through .delete()。问题是在此类请求中提供什么以及何时使用标志synchronize_session？

session.query(Child).filter(Child.id==child.id).delete(synchronize_session=False)