У меня есть довольно большие панды DataFrames, и я бы хотел использовать новые массовые сопоставления SQL для загрузки их на Microsoft SQL Server через SQL Alchemy. Метод pandas.to_sql, в то время как хороший, медленный. У меня возникли проблемы с написанием кода … Я хотел бы иметь возможность передать эту функцию pandas DataFrame, которую я называю […]
Я использую Python с SQLAlchemy для некоторых реляционных таблиц. Для хранения некоторых более крупных структур данных я использую Cassandra. Я предпочел бы использовать только одну технологию (cassandra) вместо двух (cassandra и PostgreSQL). Можно ли хранить реляционные данные в кассандре?
У меня есть база данных, в которой у меня нет метаданных или классов orm (база данных уже существует). Мне удалось получить материал для выбора: from sqlalchemy.sql.expression import ColumnClause from sqlalchemy.sql import table, column, select, update, insert from sqlalchemy.ext.declarative import * from sqlalchemy.orm import sessionmaker from sqlalchemy import create_engine import pyodbc db = create_engine('mssql+pyodbc://pytest') Session = […]
в попытке узнать sqlalchemy (и python), я пытаюсь дублировать уже существующий проект, но мне трудно понять sqlalchemy и наследование с postgres. вот пример того, что делает наша база данных postgres (очевидно, это упрощено): CREATE TABLE system (system_id SERIAL PRIMARY KEY, system_name VARCHAR(24) NOT NULL); CREATE TABLE file_entry(file_entry_id SERIAL, file_entry_msg VARCHAR(256) NOT NULL, file_entry_system_name VARCHAR(24) REFERENCES […]
Например, у нас есть таблица, в которой хранятся объекты LONGBLOB : class MyEntity(_base): id = Column('ID', Integer, primary_key=True) metadata = Column('META', String(512), nullable=False) bigData = deferred(Column('BIG_DATA', LONGBLOB, nullable=False)) Столбец с LONGBLOB помечен как отложенный, т.е. он загружается только при доступе к этому атрибуту конкретного объекта. Мне нужно запросить список объектов из базы данных и выполнить […]
Как решить эту утечку памяти? Какие меры следует предпринять для очистки старых объектов сеанса? Достаточно ли session.close() ? или Это как-то связано с пирамидой? Sqlalchmey setup: ———————————————————————————- def get_db(request): maker = request.registry.dbmaker session = maker() @profile def cleanup(request): _session = request.db if request.exception is not None: _session.rollback() else: _session.commit() _session.close() # del _session # No […]
Я получаю эту ошибку: TypeError: 'BaseQuery' object is not callable Вот мой код: companies = Company.query.all() return Company.query(func.count(Company.id)) Мне нужно узнать количество строк в модели компании. Пожалуйста помоги!
Как я могу заключить отношения без наличия внешнего ключа? @declared_attr def custom_stuff(cls): joinstr = 'foreign(Custom.name) == "{name}"'.format(name=cls.__name__) return db.relationship('Custom', primaryjoin=joinstr) Это вызывает ошибку: ArgumentError: Could not locate any simple equality expressions involving locally mapped foreign key columns for primary join condition Это работает, но я думаю, что это довольно уродливый хак. @declared_attr def custom_stuff(cls): joinstr […]
Я использую много объектов werkzeug.local.LocalProxy в моем приложении Flask. Они должны быть идеальными для объектов, но на самом деле это не так, поскольку они не отвечают на type () или instanceof () правильно. SQLAlchemy им совсем не нравится. Если я создаю LocalProxy для записи SQLAlchemy, SQLAlchemy считает это None. Если передать его LocalProxy на более […]
Отвечая на другой вопрос, я ударил стену, пытаясь создать гибридное свойство , которое вернет выражение функции, обертывающее скалярный подзапрос, который коррелирует все его объекты FROM из прилагаемого запроса, но он все равно будет предоставлять объект FROM, если никакое другое выражение в заключенный запрос предоставляет таблицу для корреляции. Учитывая определение модели игрушек class Foo(Base): __tablename__ = […]