SELECT * в SQLAlchemy?

Question

Можно ли сделать SELECT * в SQLAlchemy?

В частности, SELECT * WHERE foo=1?

Answer 1

Сегодня никто не чувствует любовь ORM к SQLALchemy? Представленные ответы правильно описывают интерфейс нижнего уровня, который предоставляет SQLAlchemy. Просто для полноты, это наиболее вероятная (для меня) реальная ситуация, когда у вас есть экземпляр сеанса и класс пользователя, который отображается в таблице пользователей.

for user in session.query(User).filter_by(name='jack'):
     print user
     # ...

И это делает явный выбор для всех столбцов.

Answer 2

Следующий выбор работает для меня на основном языке выражений (возвращая RowProxy объект ):

foo_col = sqlalchemy.sql.column('foo')
s = sqlalchemy.sql.select(['*']).where(foo_col == 1)

Answer 3

Где Бар - это класс, сопоставленный с вашей таблицей, а сеанс - ваш сеанс sa:

bars = session.query(Bar).filter(Bar.foo == 1)

Answer 4

Если вы не перечислите какие-либо столбцы, вы получите все из них.

query = users.select()
query = query.where(users.c.name=='jack')
result = conn.execute(query)
for row in result:
    print row

Должно работать.

Answer 5

Для объединений, если столбцы не определены вручную, возвращаются только столбцы целевой таблицы. Чтобы получить все столбцы для объединений (таблица пользователей объединена с таблицей групп:

sql = User.select(from_obj(Group, User.c.group_id == Group.c.id))
# Add all coumns of Group table to select
sql = sql.column(Group)
session.connection().execute(sql)

Answer 6

Вы всегда можете также использовать сырой SQL:

str_sql = sql.text("YOUR STRING SQL")
#if you have some args:
args = {
    'myarg1': yourarg1
    'myarg2': yourarg2}
#then call the execute method from your connection
results = conn.execute(str_sql,args).fetchall()

Answer 7

Оказывается, вы можете сделать:

sa.select('*', ...)

Answer 8

Если вы используете ORM, вы можете построить запрос, используя обычные конструкции ORM, а затем выполнить его напрямую, чтобы получить необработанные значения столбца:

query = session.query(User).filter_by(name='jack')
for cols in session.connection().execute(query):
    print cols