在sqlalchemy python中构建动态过滤器

Question

我需要使用动态列及其值来动态生成/构建sqlalchemy查询。

示例 - 我在SQL中有一个名为“Convo”的表，它有像UserID，ConvoID，ContactID这样的列。

我需要根据以下标准获取行。

criteria = (('UserID', 2), ('ConvoID', 1) ,('ContactID', 353)) 

我已经对此使用了“烘焙查询”逻辑。但有些我如何不能成功运行此查询。

以下是我的代码。

criteria = (('UserID', 2), ('ConvoID', 1) ,('ContactID', 353)) 
baked_query = bakery(lambda session: session.query(tablename)) 
for key1 in condition: 
    baked_query += lambda q: q.filter(tablename.key1 == condition[key1]) 
    result = baked_query(self.session).all() 

我得到错误的 -

AttributeError: type object 'Convo' has no attribute 'key1' 

请帮我这个

Answer 1

criteria = (('UserID', 2), ('ConvoID', 1) ,('ContactID', 353)) 

query = session.query(tablename) 
for _filter, value in criteria: 
    query = query.filter(getattr(tablename, _filter) == value) 
result = query.all() 

Answer 2

如果您在使用动态密钥和 “简单” 平等检查时，filter_by方法可能会更方便，因为它使用与您的属性名称匹配的关键字参数并将其组装到where子句中。

所以，你的迭代查询构造可能看起来像：

baked_query = bakery(lambda session: session.query(tablename)) 
for key, value in condition.items(): 
    baked_query += lambda q: q.filter_by(key=value) 

此外，由于filter_by需要多张关键字参数，你也许可以简化您的查询建设一个filter_by调用：

baked_query = bakery(lambda session: session.query(tablename)) 
baked_query += lambda q: q.filter_by(**condition) 

上述所有显然都假设您的condition变量引用了字典。