Tag: sqlalchemy

Установите SQLAlchemy для использования PostgreSQL SERIAL для создания идентичности

Задний план: Приложение, которое я сейчас разрабатываю, переходит от SQLite3 к PostgreSQL. Все данные были успешно перенесены с использованием .dump из текущей базы данных, изменив все таблицы типа CREATE TABLE foo ( id INTEGER NOT NULL, bar INTEGER, … PRIMARY KEY (id), FOREIGN KEY(bar) REFERENCES foobar (id), … ); в CREATE TABLE foo ( id […]

sqlite удалить символы un utf-8

У меня есть sqlite db, в котором есть некоторые сумасшедшие персонажи ascii, и я бы хотел их удалить, но я понятия не имею, как это сделать. Я искал некоторые вещи и обнаружил, что некоторые люди говорят использовать REGEXP с mysql, но это заставило ошибку сказать, что REGEXP не был распознан. Вот ошибка, которую я получаю: […]

В SQLAlchemy я могу создать Engine из существующего ODBC-соединения?

Я работаю в среде, где мне предоставляется ODBC-соединение, которое было создано с использованием учетных данных, к которым у меня нет доступа (по соображениям безопасности). Однако я хотел бы получить доступ к базовой базе данных с помощью SQLAlchemy – так что я могу передать это соединение ODBC на что-то вроде create_engine или, наоборот, обернуть его таким […]

Операция Redshift COPY не работает в SQLAlchemy

Я пытаюсь выполнить КОПИРОВАНИЕ Redshift в SQLAlchemy. Следующий SQL правильно копирует объекты из моего ведра S3 в мою таблицу Redshift, когда я выполняю его в psql: COPY posts FROM 's3://mybucket/the/key/prefix' WITH CREDENTIALS 'aws_access_key_id=myaccesskey;aws_secret_access_key=mysecretaccesskey' JSON AS 'auto'; У меня есть несколько файлов с именем s3://mybucket/the/key/prefix.001.json s3://mybucket/the/key/prefix.002.json etc. Я могу проверить, что новые строки были добавлены в […]

Сельдерей и SQLAlchemy – этот объект результата не возвращает строки. Он был автоматически закрыт

У меня есть проект сельдерея, связанный с базами данных MySQL. Одна из таблиц определяется следующим образом: class MyQueues(Base): __tablename__ = 'accepted_queues' id = sa.Column(sa.Integer, primary_key=True) customer = sa.Column(sa.String(length=50), nullable=False) accepted = sa.Column(sa.Boolean, default=True, nullable=False) denied = sa.Column(sa.Boolean, default=True, nullable=False) Кроме того, в настройках у меня есть THREADS = 4 И я застрял в функции в […]

Создавайте много ко многим на одном столе

Flask-SQLAlchemy дает пример того, как создавать отношения многих-многих. Это делается между двумя разными таблицами. Возможно ли создать много-много отношений в одной таблице? Например, у сестры может быть много сестер, у которых также будет много сестер. Я пытался: girl_sister_map = db.Table('girl_sister_map', db.Column('girl_id', db.Integer, db.ForeignKey('girl.id')), db.Column('sister_id', db.Integer, db.ForeignKey('girl.id'))) class Girl(db.Model): id = db.Column(db.Integer, primary_key=True) name = db.Column(db.String) […]

Как сделать соединение mysql, требующее CA-CERT с sqlalchemy или SQLObject

Я хотел бы подключиться к базе данных MySQL, для которой требуется ca-cert. Я могу сделать это с MySQLdb, как показано ниже: MySQLdb.connect(host = self.host, port = self.port, unix_socket = self.unix_socket, user = self.user, passwd = self.passwd, db = self.db, ssl = { 'cert': self.sslcert, 'key': self.sslkey, 'ca': self.sslca } Как мне сделать то же самое […]

sqlalchemy Целочисленный размер столбца

Я где-то видел, что вы можете определить размер столбца для столбцов Integer (например, Integer (20), Integer (10) и т. Д.), Но по какой-то причине кажется, что sqlalchemy игнорирует эти размеры в запросе таблицы create, который он создает через create_all ( ): class Job(Base): __tablename__ = "t_job" id = Column(Integer(20), Sequence('%s_id_seq' % __tablename__), primary_key=True, nullable=False) name […]

Python 'startswith' эквивалент для SqlAlchemy

У меня есть строка, для которой мне нужно найти все записи с соответствующими префиксами: path = '/abc/123/456' session.query(Site).filter(path.startswith(Site.path_prefix)) Следующие записи будут соответствовать, когда path_prefix равно: /abc /ab /abc/123 Но нет: /asd /abc/123/456/789 /kjk Возможно ли это с помощью SqlAlchemy, без перехода на python?

Как правильно отключить кеширование в сеансе ORM Sqlalchemy?

У меня есть поток в демонах, который выполняет цикл и выполняет следующий запрос: try: newsletter = self.session.query(models.Newsletter).\ filter(models.Newsletter.status == 'PROCESSING').\ limit(1).one() except sa.orm.exc.NoResultFound: self.logger.debug('No PROCESSING newsletters found. Sleeping…') self.sleep() return # (…) more code to do with found newsletter Если метод sleep просто останавливает выполнение этого потока для настроенного времени, а оператор возврата возвращается в […]

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