sqlalchemy动态过滤

from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker
from sqlalchemy import Column, Integer, String
from sqlalchemy.ext.declarative import declarative_base

# 创建数据库连接
engine = create_engine('mysql://username:password@localhost/mydatabase')
Session = sessionmaker(bind=engine)
session = Session()

Base = declarative_base()

# 定义模型
class User(Base):
    __tablename__ = 'users'
    id = Column(Integer, primary_key=True)
    name = Column(String)
    age = Column(Integer)

# 动态过滤
name_filter = input("请输入要查询的用户名：")
age_filter = int(input("请输入要查询的年龄："))

query = session.query(User)
if name_filter:
    query = query.filter(User.name == name_filter)
if age_filter:
    query = query.filter(User.age == age_filter)

result = query.all()

for user in result:
    print(user.name, user.age)