带有条件过滤器和结果的 SQLAlchemy 查询

Question

我正在构建一个 fastAPI 应用程序，我有一个复杂的查询，我试图避免在我连接结果的地方进行多个单独的查询。我有以下 tables，它们都有外键：

CHANGE_LOG: change_id | original (FK ROSTER.shift_id) | new (FK ROSTER.shift_id) | change_type (FK CONFIG_CHANGE_TYPES)

花名册：shift_id | shift_type (FK CONFIG_SHIFT_TYPES) | shift_start | shift_end | user_id (FK USERS)

CONFIG_CHANGE_TYPES: change_type_id | change_type_name

CONFIG_SHIFT_TYPES: shift_type_id | shift_type_name

用户：user_id | user_name

FK=外键

我需要return以下信息： user_name、change_type_name 和 shift_start shift_end 和 shift_type_name 对于 shift_id 与 CHANGE_LOG 行中的原始或新匹配的那些.

问题是 CHANGE_LOG table 可能既有原创又有新，只有原创没有新，或者只有新没有原创。但是由于用户可以 select 在提交请求之前从下拉框中选择几个选项，我还需要能够包含一个筛选器来挑选出来：

仅一个用户，或所有用户
任意change_type，或一组change_type

问题是我无法找到一种方法来保证每行的 user_name 而不事后检查它，因为我不知道新的或原始的是否存在或设置为 null.

在 SQLalchemy 中有没有办法在查询中有一个可选的过滤器，我可以说如果原始存在使用它来获取 user_id，但如果不存在则使用新的来获取 user_id。此外，如果我有一个查询肯定会找到那些具有原始和新班次的人，它永远不会找到只有其中一个的人，因为条件永远不会匹配。

我也读过 this 和类似的，虽然他们会解决有条件地设置一些过滤器的问题，但它并没有解决部分空值的问题 return什么都没有，而不是一半的数据。 This 似乎解决了那个问题，但我不知道如何实现它。

我知道这很复杂，所以如果我没有很好地解释这个问题，请告诉我。

Answer 1

已排序。解决方案是使用 outerjoin 选项。如果我在定义每个 class 时适当地添加关系，我确信语法会比我的解决方案更优雅，但我最终得到的是明确的，我认为它更容易阅读......在至少对我来说。

由于我在同一个查询中多次使用几个表来获取不同的信息，因此对这些表进行别名很重要，否则我最终会发生冲突（'user_id' 你想要哪个 - 它是不清楚）。对于那些在家玩的人，这是我的一般解决方案：

new=aliased(ROSTER)
original=aliased(ROSTER)
o_name=aliased(CONFIG_SHIFT_TYPES)
n_name=aliased(CONFIG_SHIFT_TYPES)

pd.read_sql(
  db.query(
    CHANGE_LOG.change_id,
    CHANGE_LOG.created,
    CONFIG_CHANGE_TYPES.change_name,
    o_name.shift_name.label('original_type'),
    n_name.shift_name.label('new_type'),
    OPERATORS.operator_name
  )
  .outerjoin(original, original.shift_id==CHANGE_LOG.original_shift)
  .outerjoin(new, new.shift_id==CHANGE_LOG.new_shift)
  .outerjoin (CONFIG_CHANGE_TYPES,CONFIG_CHANGE_TYPES.change_id==CHANGE_LOG.change_type)
  .outerjoin(CONFIG_SHIFT_TYPES, CONFIG_SHIFT_TYPES.shift_id==new.roster_shift_id)
  .outerjoin(o_name, o_name.shift_id==original.roster_shift_id)
  .outerjoin(n_name, n_name.shift_id==new.roster_shift_id)
  .outerjoin(USERS, or_(USERS.operator_id==original.user_id, USERS.user_id==new.user_id)
  ).statement, engine)

带有条件过滤器和结果的 SQLAlchemy 查询

SQLAlchemy query with conditional filters and results

python-3.x

sqlalchemy

fastapi