Как правильно составить join-запрос в приложении на Flask?

Question

[German Jet]

Модели:

class User(db.Model):
    __tablename__ = 'users'
    id = db.Column(db.Integer, primary_key=True)
    name = db.Column(db.String(100))
    username = db.Column(db.String(120), unique=True)
    password = db.Column(db.String(120))

    def __init__(self, name, username, password):
        self.name = name
        self.username = username
        self.password = password

class Weather(db.Model):
    __tablename__ = 'weather'
    id = db.Column(db.Integer, primary_key=True)
    ray_id = db.Column(db.Integer, db.ForeignKey('users.id'))
    ray = db.relationship('User', backref=db.backref('weather_current', uselist=False))   
    putdate = db.Column(db.DateTime)
    sost = db.Column(db.String(250))
    temp = db.Column(db.String(150))

    def __init__(self, ray_id, putdate, sost, temp):
        self.ray_id = ray_id
        self.putdate = putdate
        self.sost = sost
        self.temp = temp

Вьюшка:

@mod.route('/', methods = ['GET', 'POST'])
def weather():
    rows = Weather.query.outerjoin(User, Weather.ray_id==User.id).order_by(User.name.asc())
    return render_template("weather/weather.html",
        rows = rows)

Шаблон:

{% for row in rows %}
	<tr>
	<td align=left>{{ row.name }}</td>
	<td>{{ row.putdate }}</td>
	<td>{{ row.sost }}</td>
	<td>{{ row.temp }}</td>
	</tr>
 {% endfor %}

Выводятся данные только по модели Weather, как вывести данные пользователя, например, {{ row.username }}

Запрос во views соответствует sql-запросу

SELECT * FROM weather LEFT JOIN users ON weather.id_ray = users.id ORDER BY users.name asc"

На PHP все прекрасно работает.

Answer 1

[Алексей Исмаилов]

{{ row.ray.username }}
И вместо

rows = Weather.query.outerjoin(User, Weather.ray_id==User.id).order_by(User.name.asc())

Можно просто написать

rows = Weather.query.outerjoin(User).order_by(User.name.asc())

Полный пример:

from flask import Flask, render_template
from flask.ext.sqlalchemy import SQLAlchemy
app = Flask(__name__)
app.config['SQLALCHEMY_DATABASE_URI'] = 'sqlite:///tst.db'
db = SQLAlchemy(app)

import datetime

class User(db.Model):
    __tablename__ = 'users'
    id = db.Column(db.Integer, primary_key=True)
    name = db.Column(db.String(100))
    username = db.Column(db.String(120), unique=True)
    password = db.Column(db.String(120))

    def __init__(self, name, username, password):
        self.name = name
        self.username = username
        self.password = password

class Weather(db.Model):
    __tablename__ = 'weather'
    id = db.Column(db.Integer, primary_key=True)
    ray_id = db.Column(db.Integer, db.ForeignKey('users.id'))
    ray = db.relationship('User', backref=db.backref('weather_current', uselist=False))   
    putdate = db.Column(db.DateTime)
    sost = db.Column(db.String(250))
    temp = db.Column(db.String(150))

    def __init__(self, ray_id, putdate, sost, temp):
        self.ray_id = ray_id
        self.putdate = putdate
        self.sost = sost
        self.temp = temp
db.drop_all()
db.create_all()

u = User("usertest2", 'testuser2', '123')

db.session.add(u)
db.session.commit()
db.session.add(Weather(u.id, datetime.datetime.now(), 'test', '123'))
db.session.add(Weather(None, datetime.datetime.now(), 'test', '123'))
db.session.commit()
        
@app.route('/', methods = ['GET', 'POST'])
def weather():
    rows = Weather.query.outerjoin(User).order_by(User.name.asc())
    return render_template("weather.html",
        rows = rows)
if __name__ == "__main__":
    app.run(debug=True)

Шаблон:

<table>
{% for row in rows %}
  <tr>
  <td align=left>{{ row.ray.name }}</td>
  <td>{{ row.putdate }}</td>
  <td>{{ row.sost }}</td>
  <td>{{ row.temp }}</td>
  <td>{{ row.ray.username }}</td>
  </tr>
 {% endfor %}
</table>

Comments

[German Jet]

{{ row.ray.username }} - не работает(((

[Алексей Исмаилов]

А если запустить мой пример? Работает?
И вообще, какую ошибку выдает?
Если добавить к контроллеру
for i in rows:
print i
if i.ray:
print i.ray.name

[German Jet]

Очень странно. На локальной машине работает, и мой, и ваш код, но на сервере нет

[Алексей Исмаилов]

А выдает какие-то ошибки? На сервере так же запускается, как и на локальной машине? Не через tornado+nginx там, или как-то еще? Установлены ли все библиотеки? Версии библиотек, компонент и интерпретатор совпадают?

[German Jet]

На сервере выдает страницу 500, в логах ничего нет. Запускается одинаково, все совпадает. Разрабатывал прямо на сервере, на локальную машину проект целиком оттуда скопировал сейчас. Все библиотеки установлены.

[Алексей Исмаилов]

На сервер ssh? Это linux? Можно обернуть запрос в try, except Exception. e и сделать return e.message

Answer 2

[Archet]

Я бы предложил обратить внимание на add_entity, но я не уверен в том, насколько это решение правильное, ибо сам во фласке только разбираюсь.

Comments

[German Jet]

Пример запроса можете написать?

[Archet]

German Jet:
rows = Weather.query.outerjoin(User, Weather.ray_id==User.id).add_entity(User).order_by(User.name.asc())

после этого каждая строка результата запроса будет tuple'ом из 2 элементов - [0] - Weather И [1] - User, разумеется, с учетом join

[German Jet]

Результат тот же... Что-то мне кажется, запрос я делаю правильно, только в шаблоне неправильно вывожу

[Archet]

German Jet:
шаблон в итоге должен иметь вид
{{ row[1].name }}
{{ row[0].putdate }}
{{ row[0].sost }}
{{ row[1].username}}


Если в этом раскладе не сработает, то я присоединяюсь к ожиданию правильного ответа.

[German Jet]

Archet: Не сработал. Пока решил проблему прямым sql-запросом:

rows = db.session.execute("SELECT * FROM weather_current  LEFT JOIN users ON weather_current.ray_id = users.id ORDER BY users.name asc")

[Алексей Исмаилов]

Archet: add_entity нужен тогда, когда между таблицами нет реляции, т.е. отсутствует foreign key например. Конструкция rows = Weather.query.outerjoin(User, Weather.ray_id==User.id).add_entity(User).order_by(User.name.asc()) вернет BaseQuery, нужно еще сказать ему взять данные, то есть сделать так: rows = Weather.query.outerjoin(User, Weather.ray_id==User.id).add_entity(User).order_by(User.name.asc()).all(). И тогда действительно вернется набор кортежей (Weather, User). Только еще проверять придется, с outerjoin, не является ли row[1] == None, хотя я не помню, как jinja это обрабатывает, может и не надо =)

[Алексей Исмаилов]

Гоняю я что-то, не проснулся видать. BaseQuery нормально позволяет себя итерировать, .all() там не нужен. Мой пример работает, нужно получить информацию об ошибках и трейсы.

[Алексей Исмаилов]

Но вообще, add_entity тут не нужен в принципе, т.к. указаны ассоциации