在SQLAlchemy中动态构造过滤器

Question

我正在寻找一种使用SQLAlchemy动态构造过滤器的方法。也就是说，给定该列，运算符名称和比较值，即可构造相应的过滤器。

我将尝试使用一个示例进行说明（这将用于构建API）。假设我们有以下模型：

class Cat(Model):

  id = Column(Integer, primary_key=True)
  name = Column(String)
  age = Column(Integer)

我想将查询映射到过滤器。例如，

• /cats?filter=age;eq;3 应该产生 Cat.query.filter(Cat.age == 3)

• /cats?filter=age;in;5,6,7&filter=id;ge;10 应该产生 Cat.query.filter(Cat.age.in_([5, 6, 7])).filter(Cat.id >= 10)

我环顾四周，看看它是如何完成的，但是找不到一种不涉及手动将每个运算符名称映射到比较器或类似名称的方法。例如，Flask-
Restless
保留所有支持的操作的字典，并存储相应的lambda函数（此处的代码）。

我在SQLAlchemy文档中进行了搜索，发现了两个潜在的线索，但似乎都不令人满意：

• 使用Column.like，Column.in_…：这些运营商都可以直接在列这将使其简单的使用getattr，但一些人仍下落不明（==，>，等）。

• 使用Column.op：例如，Cat.name.op('=')('Hobbes')但这似乎不适用于所有运算符（in即）。

有没有lambda功能的干净方法吗？

Answer 1

如果这对某人有用，这就是我最终要做的事情：

from flask import request

class Parser(object):

  sep = ';'

  # ...

  def filter_query(self, query):
    model_class = self._get_model_class(query) # returns the query's Model
    raw_filters = request.args.getlist('filter')
    for raw in raw_filters:
      try:
        key, op, value = raw.split(self.sep, 3)
      except ValueError:
        raise APIError(400, 'Invalid filter: %s' % raw)
      column = getattr(model_class, key, None)
      if not column:
        raise APIError(400, 'Invalid filter column: %s' % key)
      if op == 'in':
        filt = column.in_(value.split(','))
      else:
        try:
          attr = filter(
            lambda e: hasattr(column, e % op),
            ['%s', '%s_', '__%s__']
          )[0] % op
        except IndexError:
          raise APIError(400, 'Invalid filter operator: %s' % op)
        if value == 'null':
          value = None
        filt = getattr(column, attr)(value)
      query = query.filter(filt)
    return query

这涵盖了所有SQLAlchemy列比较器：

• eq 对于 ==
• lt 对于 <
• ge 对于 >=
• in 对于 in_
• like 对于 like
• 等等

详尽列表及其相应名称可在此处找到。