Как сделать update в flask sqlalchemy?

Question

[pcdesign]

В чистом виде на sql запрос выглядит так:
update stat set user_id=1 where user_id=2

Гуглил на этот счет, но все решения не подошли.

Запись user_id в таблице stat не уникальна.
Вот для примера:
==========================
MariaDB []> select id , date , user_id from stat where user_id = 2 limit 0,3;
+-------+---------------------+---------+
| id | date | user_id |
+-------+---------------------+---------+
| 63573 | 2011-12-18 17:20:17 | 2 |
| 63653 | 2011-12-18 18:51:33 | 2 |
| 63654 | 2011-12-18 18:51:39 | 2 |
+-------+---------------------+---------+
3 rows in set (0.00 sec)

========================

А все решения, которые гуглятся они расчитаны на update только одного row.

Answer 1

[Алексей Алексеев]

Через filter или filter_by можно получить нужные строки - filter и filter_by. Затем можно уже в цикле обойти все записи и записать нужное значение.

НО! это не самый лучший подход, точнее это плохой подход! В SQLAlchemy есть один хороший метод - update. В итоге можно сделать всё примерно так:

u_id = get_userid()
rows = Stat.query.filter_by(user_id = u_id).update({'user_id': 1})
db.session.commit()

А вообще не нужно ничего гуглить, всё есть в официальной документации.

Comments

[pcdesign]

Спасибо за ответ. Но так не работает.
Код ошибки:

========================
Traceback (most recent call last):
File "/home/dom/env/lib/python3.4/site-packages/flask/app.py", line 1817, in wsgi_app
response = self.full_dispatch_request()
File "/home/dom/env/lib/python3.4/site-packages/flask/app.py", line 1477, in full_dispatch_request
rv = self.handle_user_exception(e)
File "/home/dom/env/lib/python3.4/site-packages/flask/app.py", line 1381, in handle_user_exception
reraise(exc_type, exc_value, tb)
File "/home/dom/env/lib/python3.4/site-packages/flask/_compat.py", line 33, in reraise
raise value
File "/home/dom/env/lib/python3.4/site-packages/flask/app.py", line 1475, in full_dispatch_request
rv = self.dispatch_request()
File "/home/dom/env/lib/python3.4/site-packages/flask/app.py", line 1461, in dispatch_request
return self.view_functions[rule.endpoint](**req.view_args)
File "/home/dom/proj/main.py", line 744, in profile_clearstat
db.session.query().filter(S.user_id == user_id).update({"user_id": 1})
File "/home/dom/env/lib/python3.4/site-packages/sqlalchemy/orm/query.py", line 2796, in update
update_op.exec_()
File "/home/dom/env/lib/python3.4/site-packages/sqlalchemy/orm/persistence.py", line 895, in exec_
self._do_pre()
File "/home/dom/env/lib/python3.4/site-packages/sqlalchemy/orm/persistence.py", line 903, in _do_pre
self.context = context = query._compile_context()
File "/home/dom/env/lib/python3.4/site-packages/sqlalchemy/orm/query.py", line 2836, in _compile_context
"Query contains no columns with which to "
sqlalchemy.exc.InvalidRequestError: Query contains no columns with which to SELECT from.
======================================

И сам код:

user_id = get_userid()
S = Stat
db.session.query().filter(S.user_id == user_id).update({"user_id": 1})
db.session.commit()

[Алексей Алексеев]

Мой коды выше - это просто пример того, по какому принципу работает метод update - сначала условие выборки, затем update для обновления. По этому принципу работают большинство ORM. Но не значит, что надо копировать просто. Ошибка у вас здесь в том, что не заданы поля для выборки. Другими словами выполняйте запрос для конкретной таблицы, к примеру, так: Stat.query.filter(user_id == '2').update({"user_id": 1})

[pcdesign]

greenkaktusx: В этом случае вообще ничего не происходит и не меняется.
И ошибок никаких не выводит.

[Алексей Алексеев]

pcdesign: покажите код, как на примере выше вы делали.

[pcdesign]

greenkaktusx: Да вот код:

user_id = get_userid()
Stat.query.filter(Stat.user_id == user_id).update({"user_id": 1})
db.session.commit()

[Алексей Алексеев]

Попробуйте так:
u_id = get_userid()
rows = Stat.query.filter_by(user_id = u_id).update({'user_id': 1})
db.session.commit()

[pcdesign]

Да, спасибо большое! Заработало.
А на сколько вообще нужен в конце
db.session.commit()?
И что делать с объектом rows, если он мне не нужен?

[Алексей Алексеев]

Коммит нужен обязательно, чтобы выполнить запрос и завершить транзакцию. Rows можете не использовать, это в эту переменную возвращается количество измененных записей. По сути, если эта информация не нужна, то можно использовать без rows, т.е. просто Stat.query.filter_by(user_id = u_id).update({'user_id': 1})

[pcdesign]

Да, row убрал, все отлично работает. Еще раз спасибо!

Answer 2

[kirilldzr]

user = User.query.get(1)
user.email = '[e-mail]'
db.session.add(user)
db.session.commit()

blog.miguelgrinberg.com/post/the-flask-mega-tutori...

Comments

[pcdesign]

Проблема в том, что это не уникальная запись.
Ну то есть в таблице Stat очень много раз встречается
user_id = 2

А здесь речь идет о изменении одиночной записи.

Answer 3

[bromzh]

Можно написать самому миграцию. Если что пойдёт не так - откатишься.
Для фласка есть плагин (который есть обёртка над alembic)