Tag: sqlalchemy

Операция SQL Pivot в SQLAlchemy

Я пытаюсь использовать SQLAlchemy для выполнения операции pivot SQL в базе данных, но я не могу понять, как это сделать. Я не хочу извлекать эти данные из базы данных из-за размера, поэтому я не думаю, что использование numpy / pandas может помочь мне здесь. SQL, который я пытаюсь передать в RDBMS (текущий запрос находится на […]

Как использовать collection_class в SQLAlchemy?

Я пытаюсь моделировать иерархические и исторические отношения между институциональными субъектами в SQLAlchemy (т.е. Учреждение может иметь родителей / детей и предшественников / преемников). То, что я до сих пор в значительной степени следует примеру ориентированного графа в документах SQLAlchemy. Теперь я хотел бы иметь доступ к левым / правым соседям к узлам в словаре с […]

SQLAlchemy – Как вставить вставленную таблицу. Унаследованный экземпляр класса, когда родительский объект уже сохранен.

Я объявлял две классы, используя SQLAlchemy, входящие в таблицу Inheritance . Кроме того, я использую Flask-SQLAlchemy и Flask. class Parent(db.Model): id = db.Column(db.Integer, primary_key=True) name = db.Column(db.String(255)) type = db.Column(db.String(50)) __mapper_args__ = { 'polymorphic_identity': 'parent', 'polymorphic_on': type } class Child(Parent): id = db.Column(db.Integer, db.ForeignKey('parent.id'), primary_key=True) brand_id = db.Column(db.Integer, nullable=False) __mapper_args__ = { 'polymorphic_identity': 'child', } […]

sqlalchemy, создающий VIEW с ORM

Я создал следующий ORM: from sqlalchemy import Column, Integer, String, UniqueConstraint from sqlalchemy.dialects.postgresql import JSONB from sqlalchemy.ext.declarative import declarative_base Base = declarative_base() class TableA(Base): __tablename__ = 'table_a' id = Column(Integer, primary_key=True, nullable=False) identifier = Column(String(320)) internal_id = Column(Integer) type = Column(String(32)) time = Column(DateTime(timezone=True)) success = Column(Boolean()) parameters = Column(JSONB()) class TableB(Base): __tablename__ = 'table_b' […]

Массив Enum в Postgres с SQLAlchemy

Я использовал массив перечислений с postgres и SQLAlchemy успешно за последний год: class MyModel(BaseModel): enum_field = Column(postgresql.ARRAY(EnumField(MyEnum, native_enum=False))) EnumField находится из библиотеки EnumField , небольшой обертки вокруг встроенного перечисления, который использует перечисления Python как представление Python вместо строк. Хотя документы говорят , что массив перечислений не поддерживается, я думаю, это сработало, потому что я выбрал […]

Python3, используя функцию Pandas df.to_sql () с SQLAlchemy для вставки данных в базу данных PostgreSQL

Как указать первичный ключ таблицы? Если вы делаете это со стандартным SQL, я бы использовал: CREATE TABLE table ( uid TEXT PRIMARY KEY NOT NULL,\ age SMALLINT NOT NULL,\ gen TEXT NOT NULL,\ eth TEXT NOT NULL,\ biu BOOLEAN NOT NULL,\ pst TEXT NOT NULL,\ jse TEXT NOT NULL,\ emp TEXT NOT NULL,\ inc INT […]

Как создать столбец идентификатора, не являющийся первичным ключом с SQLAlchemy?

Как создать столбец идентификатора в SQLAlchemy, автоматически увеличивая его и не являясь основным ключом? Я использую Postgres. Благодаря, Yann

запрос Kerberized Hive с SQL Алхимия

Я пытаюсь запросить кластер Kerberized Hive с SQL Alchemy . Я могу отправлять запросы с помощью pyhs2, который подтверждает, что можно подключиться и запросить Hive при аутентификации Kerberos: import pyhs2 with pyhs2.connect(host='hadoop01.woolford.io', port=10500, authMechanism='KERBEROS') as conn: with conn.cursor() as cur: cur.execute('SELECT * FROM default.mytable') records = cur.fetchall() # etc … Я замечаю, что Airflow Airbnb […]

Запрос sql alchemy застрял в зависимости от значения

Я довольно новичок в python и MySql. Я пытаюсь импортировать данные, полученные в файлах excel, в MySql, используя python. Скрипты работают тихо, но у меня есть простая часть выбора, которая работает неправильно. Он пытается получить данные из одной таблицы, хранящей уже импортированные имена файлов, классифицированные по типам файлов. Таким образом, таблица имеет эти две колонки […]

SQLAlchemy – Логический гибридный атрибут

Я хочу иметь возможность запускать следующие запросы SQLAlchemy: q_done = Batch.query.filter(Batch.done) q_running = Batch.query.filter(~Batch.done) Но я не могу обернуть голову, написав expression соответствующее моему гибридному атрибуту. Модели SQLAlchemy: class Action(db.Model): id = db.Column(db.Integer, primary_key=True) action = db.Column(db.String(32)) done = db.Column(db.Boolean, default=False) batch = db.relationship(Batch.__name__, backref='actions') class Batch(db.Model): id = db.Column(db.Integer, primary_key=True) name = db.Column(db.String(255), default='unknown') […]

Python - лучший язык программирования в мире.