Tag: sqlalchemy

Сделать SQLAlchemy COMMIT вместо ROLLBACK после запроса SELECT

Я разрабатываю приложение вместе с партнером. Я делаю часть базы данных ( PostgreSQL ), мой партнер реализует приложение на веб-сервере с помощью python с помощью SQLAlchemy . Мы активно используем хранимые процедуры. Запрос SELECT на одном из них выглядит так в журнале db: SET TRANSACTION ISOLATION LEVEL READ COMMITTED; SELECT col_a, col_b FROM f_stored_proc(E'myvalue'); ROLLBACK; […]

Многие-ко-многим в sqlalchemy. Предотвращение вставки SQLAlchemy в таблицу, если тег уже существует

У меня есть несколько таблиц с сопоставлением ORM, которые (уменьшены) выглядят следующим образом: class Tag(Base): __tablename__ = 'tags' tag_name = Column(String, primary_key=True) task2tag_assoc = Table('tasktags', Base.metadata, Column('task_id', UUID, ForeignKey('tasks.task_id', ondelete='cascade'), primary_key=True), Column('tag_name', String, ForeignKey('tags.tag_name', ondelete='cascade'), primary_key=True) ) class Task(Base): __tablename__ = 'tasks' task_id = Column(UUID, primary_key=True) _tags = relationship('Tag', secondary=task2tag_assoc, backref='tasks', collection_class=set) tags = association_proxy('_tags', […]

Проверка в SQLAlchemy

Как я могу получить требуемый валидатор в SQLAlchemy? На самом деле я просто хочу быть уверенным, что пользователь заполнил все обязательное поле в форме. Я использую PostgreSQL, но это не имеет смысла, поскольку таблицы, созданные из объектов в моем файле models.py: from sqlalchemy import ( Column, Integer, Text, DateTime, ) from sqlalchemy.ext.declarative import declarative_base from […]

Почему мой scoped_session создает объект AttributeError: «Session» не имеет атрибута «удалить»,

Я пытаюсь настроить систему, которая элегантно отбрасывает операции базы данных в отдельный поток, чтобы избежать блокировки во время обратных вызовов Twisted. Пока, вот мой подход: from contextlib import contextmanager from sqlalchemy import create_engine from sqlalchemy.orm import scoped_session, sessionmaker from twisted.internet.threads import deferToThread _engine = create_engine(initialization_string) Session = scoped_session(sessionmaker(bind=_engine)) @contextmanager def transaction_context(): session = Session() try: […]

Как вы получаете SQLAlchemy для переопределения MySQL "при обновлении CURRENT_TIMESTAMP"

Я унаследовал более старую базу данных, которая была настроена с помощью «on update CURRENT_TIMESTAMP», помещенного в поле, которое должно описывать только создание элемента. С PHP я использую «timestamp = timestamp» в предложениях UPDATE, но в SQLAlchemy я не могу заставить систему использовать установленную метку времени. У меня нет выбора и вам нужно обновить таблицу MySQL […]

Как использовать зефир для сериализации пользовательского поля sqlalchemy?

Я просто запускаю простой проект под названием flask_wiki в эти дни, и я использую некоторые расширения фляг, как показано ниже: Колба-SQLAlchemy Колба-Restful Зефир Ну, я только что обнаружил, что проект MarshMallow предоставляет класс под названием «ModelSchema», который читает все поля из моей модели SQLAlchemy и предоставляет полностью автоматизированный сериализатор (de). В моем случае я создал […]

Как я могу создать свойства column_properties, которые используют группу?

У меня есть этот sql-запрос: select rooms.*, COUNT(DISTINCT(o.resident_id)) as resident_count, COUNT(reviews.id) as review_count, COUNT(photos.id) as photo_count, AVG(reviews.rating) as mean_review from t_rooms rooms JOIN t_room_listings listings on listings.room_id = rooms.id JOIN t_occupancies o on o.listing_id = listings.id LEFT JOIN t_reviews reviews on reviews.occupancy_id = o.id LEFT JOIN t_photos photos on photos.occupancy_id = o.id GROUP BY rooms.id […]

Как я могу «переопределить» глубину в Python?

Я бы хотел переопределить __deepcopy__ для данного класса, сопоставленного с SQLAlchemy, таким образом, чтобы он игнорировал любые атрибуты SQLA, но глубоко копировал все остальное, что является частью класса. Я не особенно знаком с тем, что я могу переопределить любые встроенные объекты Python, но у меня есть представление о том, чего я хочу. Давайте просто сделаем […]

Msgstr "устаревший ассоциативный прокси, родительский объект вышел из сферы действия" с помощью Flask-SQLAlchemy

Я никогда не сталкивался с этой ошибкой: sqlalchemy.exc.InvalidRequestError: stale association proxy, parent object has gone out of scope После некоторых исследований это выглядит так, потому что родительский объект собирает мусор, пока работает прокси-сервер ассоциации. Фантастика. Однако я не уверен, где это происходит. Соответствующий код: # models.py class Artist(db.Model): # … tags = association_proxy('_tags', 'tag', creator=lambda […]

SqlAlchemy: самореализованное значение по умолчанию в качестве запроса

Допустим, у меня есть следующая структура (с использованием Flask-SqlAlchemy): class User(db.Model): id = db.Column(db.Integer, primary_key=True) name = db.Column(db.String, nullable=False, index=True) # The following line throws an error at runtime. variant = db.Column(db.Integer, nullable=False, index=True, default=select(func.count(User.id)).where(User.name == self.name)) def __init__(self, name): super(User, self).__init__() self.name = name @property def clause(self): return '/'.join([str(self.variant), self.name]) Проблема в том, что […]