6
Пример от автора pycon2013 zzzeek
Создаете две таблицы User и Address.
class User(Base):
__tablename__ = 'user'
id = Column(Integer, primary_key=True)
name = Column(String)
fullname = Column(String)
def __repr__(self):
return "<User(%r, %r)>" % (
self.name, self.fullname
)
class Address(Base):...
6
Flask -- это микро- веб-фреймворк, поэтому она имеет отношение к поиску только в той степени, что она позволяет использовать различные ORM (нет жёсткой привязки к какому-то одному решению).
Если вопрос: как реализовать поиск с помощью Flask-SQLAlchemy, то чтобы отобразить книгу, указанную по автору и названию в ссылке, можно написать:
@app.route('/book/<...
6
А есть ли смысл разделять категории и подкатегории? Сделайте одну таблицу категорий, у которых есть ссылка на родительскую категорию (на себя же). Это позволит произвольную вложенность подкатегорий и уберет лишнюю сущность. Получится что-то вроде такого:
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import Column, Integer, String
...
ответ дан 13 июл '15 в 4:15
Vadim Shender
2,49511 золотой знак1212 серебряных знаков2727 бронзовых знаков
6
Я когда-то делал подобным образом. Как по мне - нормальная реализация методов моделей.
Неплохим решением будет создать базовый класс, от которого можно наследовать другие модели, а в самих методах добавлять нужную логику.
Для своих нужд, работая с фреймворком Flask, написал такую такую штуковину:
from ._base import db
from sqlalchemy.exc import ...
5
Можно начать с отличий:
Функция make_db_session возвращает объект типа ScopedSession (scoped_session - это класс такой, который зачем-то назвали как функцию). scoped_session - обычная такая сессия, но помимо бла-бла-бла про потоки, основное ее отличие, видимое пользователям, в следующем:
# Обычные сессии
Session = sessionmaker(__config_here__)
session_1 =...
4
Не потоков, соединений с базой. Да, у каждого процесса пул свой. Это обычный callable, возвращающийся соединение из управляемой им коллекции. То есть в предельно простом случае это может быть просто функция, возвращающая новое соединение. Реальные пулы - это классы, хранящие внутри себя коллекции свободных и выданных подключений, ведущие статистику по ...
ответ дан 21 авг '17 в 6:25
Sergey Gornostaev
63.7k66 золотых знаков3737 серебряных знаков9292 бронзовых знака
3
Ошибка происходит из-за того, что предыдущая транзакция не была откачена. Для того чтобы ее откатить достаточно сделать session.rollback().
Обычно комитят изменения в алхимии следующим образом:
try:
session.commit()
except DatabaseError, e:
session.rollback()
logger.error('...')
Обновление
session.flush() записывает изменения в базу, но не ...
3
Вы в комментраиях верно подметили, поможет having.
Сджойнить ноты с произведениями и выборкой нужных инструментов, вывести призведения с группировкой и фильтрацией having "кол-во инструментов в выборке"
Запрос на вашей базе без изменений скорее всего не отработает, но даст понимание что к чему.
with t as (
select id from instrument where insrument in ('...
3
groups = Group.query.all()
for group in groups:
users = group.users
3
Стоит начать с того, как делать не нужно. Например, не нужно перебирать объекты в базе по-одному:
for question in all_questions:
most_viewed_question = MostViewedQuestion.query.filter_by(question_id=question.question_id).first()
этот цикл - совсем нет-нет-нет. Такого поведения нужно избегать любой ценой - НАМНОГО лучше запросить сразу миллион строк, ...
3
Можно использовать automap, тогда алхимия автоматически сгенерирует схему по существующей БД (http://docs.sqlalchemy.org/en/latest/orm/extensions/automap.html )
3
Есть пару моментов, но?
for subscribe in Subscribe.query.yield_per(1000):
aws.send(subscribe.email)
ответ дан 19 дек '18 в 13:26
Andrio Skur
2,67433 золотых знака1212 серебряных знаков2626 бронзовых знаков
3
Дошло. Дело было в том, что word_id - это число, которое превращается в строку при записи в бд. И когда я добавляю туда еще один элемент с таким же id, то в словаре один из элементов с ключом-числом, а другой с ключом-строкой. При записи в бд они оба становятся строкой.
3
Как импортировать денормализованые данные из CSV в PostgreSQL c сохранением отношений один ко многим
Можно прочитать из CSV нужный набор полей, удалить дубликаты и записать в БД:
def process_data(filename, engine, tab, **kwargs):
df = pd.read_csv(filename, **kwargs).drop_duplicates()
df.to_sql(tab, engine, if_exists='append', index=False)
process_data(filename, engine, 'reporter', sep=';', names=headers, usecols=[0,1,2,3])
process_data(filename, ...
3
Вместо функции or_ из sqlalchemy можете использовать оператор |:
User.query.filter((User.email == email) | (User.login == login)).all()
Пример:
# app.py
from flask import Flask
from flask_sqlalchemy import SQLAlchemy
app = Flask(__name__)
app.config['SQLALCHEMY_DATABASE_URI'] = 'url_or_path/to/database'
db = SQLAlchemy(app)
class User(db.Model):
...
2
Если, как показано в примере, initials - представляет производное значение из полей модели - не вижу смысла делать для его получения отдельный класс.
Как выше указали - если вам требуется создать свойство, которое будет менять свое "поведение" в зависимости от контекста использования (экземпляр объекта или класс модельки) - то нужно использовать @...
2
Это конечно не прямой ответ на вопрос, но что мешает представить полученную дату в нужном формате самому?
myDate.strftime("%Y-%m-%d %H:%M:%S")
2
Используйте полиморфные отношения. Как раз ваш пример в документации http://docs.sqlalchemy.org/en/rel_1_0/orm/inheritance.html
class ModelWithPhone(Base):
__tablename__ = 'phones'
phone = Column(String(13), primary_key=True)
type = Column(String(50))
__mapper_args__ = {
'polymorphic_identity': 'phone',
'polymorphic_on':type
...
2
db.ForeignKey(User.id) - без кавычек это питоновский класс
db.ForeignKey("user.id") - в кавычках указывается имя таблицы
db.ForeignKey(user.id) - здесь указан объект user, который нигде не определен в вашем контексте программы, поэтому питон кидает ошибку (определен класс User)
db.ForeignKey("User.id") - таблицы с именем "User" нет (есть "user")
UPD: У меня ...
2
Что получилось в результате:
def update_most_viewed():
reader_session = db_session()
question_count = reader_session.query(func.count(QuestionViewHistory.id)).filter_by(counted=False).scalar()
query = reader_session.query(QuestionViewHistory.id, QuestionViewHistory.question_id, QuestionViewHistory.view_count).filter_by(counted=False)
...
ответ дан 24 фев '17 в 6:15
2
Ничего разделять в данном случае не нужно. У вас есть абстракция (модель), у этой абстракции есть состояние (поля), которое она может хранить (но не обязана). Так же есть методы, через которые можно менять состояние. Еще можно выделить так называемые свойства - по сути те же поля, только вычисляются динамически.
Какой смысл отделять методы и свойства от ...
2
Модель, или точнее класс, который представляет собой запись в БД, это объектное представление используемой бд. То есть структура в которой данные и их поведение были объеденены в единое целое, в отличие от той БД, которой вы пользуетесь, для удобства вашей работы с этими данными.
То есть вы можете писать в привычном вам, ну или требуемым кем-то, объектно-...
ответ дан 30 мар '17 в 15:10
Мистер Фикс
2,23011 золотой знак88 серебряных знаков2323 бронзовых знака
2
Команда session.query(Child).delete() не только удалит соответствующие объектам Child записи из базы данных, но и обновит состояние этих объектов в сессии. Естественно, эти дополнительные действия требуют времени и соответственно замедлят процесс удаления. Если вы точно знаете, что дальше по коду вы не будете больше обращаться к этим объектам, то вам незачем ...
ответ дан 30 мар '17 в 6:02
Sergey Gornostaev
63.7k66 золотых знаков3737 серебряных знаков9292 бронзовых знака
2
Помогли на enSO
При использовании запроса на подобии этого:
q = db.session.query(Transaction). \
filter(Transaction.transaction_id != ReconciledTransaction.safe_withdraw_id)
Получаем такой SQL:
SELECT Transaction.* FROM Transaction, ReconciledTransaction
WHERE Transaction.transaction_id != ReconciledTransaction.safe_withdraw_id
Соответственно мы в любом ...
ответ дан 28 сен '17 в 6:23
Klimenko Kirill
2,09511 золотой знак88 серебряных знаков3232 бронзовых знака
2
Не только можете, но и должны. Создавать пул соединений для каждого запроса - это плохое решение. Но стоит учесть, что SQLAlchemy по умолчанию синхронная, а значит, что без дополнительных ухищрений весь ваш сервер становится синхронным. Вот как этот вопрос решает сам автор aiohttp.
ответ дан 19 дек '17 в 6:26
Sergey Gornostaev
63.7k66 золотых знаков3737 серебряных знаков9292 бронзовых знака
2
Pandas позволяет удобно выгрузить данные из SQL в Excel:
pd.read_sql('select * from tab where ...', engine) \
.to_excel(r'/path/to/excel_file.xlsx', index=False)
2
Спасибо всем, кто хоть сколько потратил время на мой вопрос, но ответ уже нашёл. Не вдаваясь в подробности, ответ - использовать column-property
В моём случае проблема решается так:
sources_tasks = db.Table('sources_tasks',
db.Column('source_id', db.Integer, db.ForeignKey('sources.id', ondelete='CASCADE'), nullable=False),
db.Column('task_id', db....
2
Если на чистом SQL (минуя ORM), то например вот так:
db = SQLAlchemy()
# конфигурация подключения к БД пропущена
rows = db.engine.execute('тут sql').fetchall()
2
Вы можете легко настроить задачу Celery так, что в случае сбоя отправки письма, задача будет повторяться нужное количество раз с увеличением временного интервала между попытками. Cron вам такого удобства не предоставит, придётся либо смириться с негарантированной доставкой, либо велосипедить собственный алгоритм обработки сбоев. Но нужен ли вам этот ...
ответ дан 18 дек '18 в 7:29
Sergey Gornostaev
63.7k66 золотых знаков3737 серебряных знаков9292 бронзовых знака
2
Чтобы из таблицы Subscribe получить все записи, нужно вызвать all, например:
for theuser in Subscribe.query.all():
...
Чтобы из таблицы получить все email, то:
for theuser in Subscribe.query.all():
print(theuser.email)
или в одну строку как список:
emails = [theuser.email for theuser in Subscribe.query.all()]
ответ дан 9 янв '19 в 10:39
gil9red
55.9k55 золотых знаков4040 серебряных знаков8989 бронзовых знаков
Допускаются только превышающие минимальную длину ответы с наивысшим рейтингом, не являющиеся общими
Связанные метки
sqlalchemy × 211python × 161
flask × 63
python-3.x × 53
flask-sqlalchemy × 42
sql × 33
postgresql × 26
orm × 20
база-данных × 18
sqlite × 13
mysql × 11
sql-server × 5
pandas × 5
json × 4
django × 3
веб-программирование × 3
pyqt5 × 2
dataframe × 2
консоль × 2
наследование × 2
сессия × 2
join × 2
asyncio × 2
aiohttp × 2
foreign-key × 2