Celery 和 SQLAlchemy - 此结果对象不返回行.它已自动关闭
我有一个连接到 MySQL 数据库的 celery 项目.其中一张表的定义如下: class MyQueues(Base):__tablename__ = 'accepted_queues'id = sa.Column(sa.Integer, primary_key=True)客户 = sa.Column(sa.String(length=50), nullable=False)接受 = sa.
..
sqlalchemy相关内容
SQLalchemy AttributeError: 'str' 对象没有属性 '_sa_instance_state'
我正在尝试使用 SQLAlchemy + Python 向我的数据库中添加一个项目，但一直出现错误. 我的database_setup.py: 班级公司(基地):__表名__ = '公司'compID = 列(整数，primary_key = True)名称 = 列(字符串(80)，可为空 = 假)类项目(基础):__表名__ = '物品'itemID = Column(整数，primar
..
使用 json.dumps() 的 MemoryError
我想知道在将大型数组编码为 json 时，json.dump() 或 json.dumps() 中哪一个最有效格式. 你能告诉我一个使用 json.dump() 的例子吗? 实际上，我正在制作一个 Python CGI，它使用 ORM SQlAlchemy 从 MySQL 数据库中获取大量数据，经过一些用户触发处理后，我将最终输出存储在一个数组中，最终将其转换为 Json. 但是
..
SQLAlchemy:如何过滤 PgArray 列类型?
在纯 postgres 中我们可以这样写: SELECT * FROM my_table WHERE 10000 = ANY (array_field); 或 SELECT * FROM my_table WHERE 10000 = ALL (array_field); 如何在没有原始 sql 的情况下借助 sqlalchemy 做同样的事情? 解决方案 a = ANY(b_arr
..
如何获取更改字段的原始值?
我使用 sqlalchemy 作为我的 orm，并使用 declarative 作为 Base. Base = declarative_base()类用户(基础):__表名__ = '用户'id = 列(整数，primary_key=True)名称 = 列(字符串) 我的问题是，我怎么知道一个用户被修改了，以及如何在不查询数据库的情况下再次获取原始值? user = Session.quer
..
SQLAlchemy 将一列的默认值设置为另一列的默认值
我正在尝试为物质编写一个类，它有一个名称(名称，在实验室中常用)和另一列用于长名称(以防名称实际上不完整).如果没有指定长名称，是否可以告诉类只将名称字段的值复制到长名称字段? 我尝试过这样的事情: class Substance(Base):__tablename__ = "物质"id = 列(整数，primary_key=True)代码 = 列(字符串，唯一=真)名称 = 列(字符串，
..
SQLAlchemy:如何对关系字段的查询结果 (order_by) 进行排序?
型号 from sqlalchemy.ext.declarative import declarative_base从 sqlalchemy 导入列，外键从 sqlalchemy 导入整数从 sqlalchemy 导入 Unicode从 sqlalchemy 导入时间戳来自 sqlalchemy.orm 的导入关系BaseModel = declarative_base()类基础(基础模型):_
..
如何使用没有 ORM 的 SQLAlchemy 查询从表中删除行?
我正在编写一个快速而肮脏的维护脚本来删除一些行，并希望避免将我的 ORM 类/映射从主项目中带过来.我有一个类似于以下内容的查询: address_table = Table('address',metadata,autoload=True)地址 = session.query(addresses_table).filter(addresses_table.c.retired == 1) 根据
..
SQLALchemy 动态 filter_by
我知道您可以通过向 filter_by 提供 **kwargs 来为 SQLAlchemy 的查询构建动态过滤器. 例如 过滤器 = {'id': '123456', 'amount': '232'}db.session.query(Transaction).filter_by(**filters) 下面是我的问题: 如果我需要通过“大于"或“小于"子句进行查询怎么办?例如(原始
..
对 JSON 字段的更新不会持续到 DB
我们有一个带有 JSON 字段的模型，其中插入了用户标志.插入确实按预期工作，但是当删除某些标志时，它们会留在字段中并且更改不会持久保存到数据库中. 我们的模型中有以下方法: def del_flag(self, key):如果 self.user_flags 为 None 或不在 self.user_flags 中键入:返回错误别的:del self.user_flags[key]db.
..
单个表上的 SQLAlchemy 多对多关系
我在我的应用程序中设置了一个 SQLAlchemy 模型，它应该模仿 Twitter 上“关注者"的功能，即.用户之间存在多对多关系(包括关注者和关注者).表的结构如下(sa 是 sqlalchemy 模块): t_users = sa.Table("users", meta.metadata,sa.Column("id", sa.types.Integer, primary_key=True)
..
如何?时区 'UTC' 的 CURRENT_TIMESTAMP
我将如何修改我的电话 sqlalchemy.func.current_timestamp() 产生的东西 CURRENT_TIMESTAMP AT TIME ZONE 'UTC' 解决方案 快速解决方法是执行以下操作: func.current_timestamp().op('AT TIME ZONE')('UTC') 更合适的方法是使用编译器扩展并定义的自定义编译CURRENT_T
..
SQLAlchemy:通过至少一个多对多相关表中的成员资格过滤
使用 SQLAlchemy 0.7.1 和 MySQL 5.1 数据库，我建立了如下的多对多关系: user_groups = Table('user_groups', Base.metadata,Column('user_id', String(128), ForeignKey('users.username')),列('group_id'，整数，外键('groups.id')))类 ZKUs
..
可以将 SQLAlchemy 配置为非阻塞吗?
我的印象是通过 SQLAlchemy 调用数据库会阻塞并且不适合在同步代码以外的任何地方使用.我是否正确(我希望我不是！)或者有没有办法将其配置为非阻塞? 解决方案 您可以使用 gevent 以非阻塞方式使用 SQLA.这是使用 psycopg2 的示例，使用 psycopg2 的 协程支持: https://bitbucket.org/zzzeek/green_sqla/ 我
..
Flask-SQLAlchemy 如何删除单个表中的所有行
如何使用 Flask-SQLAlchemy 删除单个表中的所有行? 寻找这样的东西: >>>用户 = models.User.query.all()>>>模型.db.session.delete(用户)# 但它出错了:UnmappedInstanceError: Class '__builtin__.list' is not mapping 解决方案 尝试 delete: mod
..
sqlalchemy 通用外键(如在 django ORM 中)
sqlalchemy 有类似 django 的 GenericForeignKey 的东西吗?以及使用通用的外部字段是否正确. 我的问题是:我有几个模型(例如，发布、项目、空缺，没有什么特别的)，我想为每个模型添加评论.而且我只想使用一种 Comment 模型.值得吗?还是应该使用 PostComment、ProjectComment 等?两种方式的优缺点? 谢谢！ 解决方案
..
SQLAlchemy:选择查询中对象的哪些列
是否可以控制在 SQLAlchemy 的查询方法中查询哪些列，同时仍然返回您正在查询的对象的实例(尽管部分填充)? 或者SQLAlchemy是否需要执行SELECT *来映射到一个对象? (我确实知道可以查询单个列，但它不会将结果映射到对象，只会映射到命名元组的组件). 例如，如果 User 对象具有属性 userid、name、password 和 bio，但您希望查询仅填写它
..
Twisted + SQLAlchemy 和最好的方法
所以我正在编写另一个基于 Twisted 的守护进程.它将像往常一样有一个 xmlrpc 接口，这样我就可以轻松地与它通信，并让其他进程根据需要与其交换数据. 这个守护进程需要访问一个数据库.我们一直在使用 SQL Alchemy 来代替我们最新项目的硬编码 SQL 字符串——这些项目主要是为 Pylons 中的网络应用程序完成的. 我们希望对这个应用程序做同样的事情，并重用利用 SQ
..
通过 SQLAlchemy 获取随机行
如何使用 SQLAlchemy 从表中随机选择一个或多个行? 解决方案 这在很大程度上是一个特定于数据库的问题. 我知道 PostgreSQL、SQLite、MySQL 和 Oracle 具有按随机函数排序的能力，因此您可以在 SQLAlchemy 中使用它: from sqlalchemy.sql.expression import func, selectselect.orde
..
为什么 SQLAlchemy count() 比原始查询慢得多?
我将 SQLAlchemy 与 MySQL 数据库一起使用，我想计算表中的行数(大约 300k).SQLAlchemy count 函数需要大约 50 倍的时间直接在 MySQL 中编写相同的查询来运行.我做错了什么吗? # 这需要 3 秒以上才能返回session.query(Segment).count() 然而: SELECT COUNT(*) FROM segment;+------
..