1

我使用 SQLAlchemy 访问一个 postgres 表。我想要一个具有急切加载的查询。

from sqlalchemy.orm import sessionmaker, scoped_session, eagerload
from settings import DATABASE_USER, DATABASE_PASSWORD, DATABASE_HOST, DATABASE_PORT, DATABASE_NAME
from sqlalchemy import create_engine
from sqlalchemy import Table, Column, Integer, String, Boolean, MetaData, ForeignKey
from sqlalchemy.orm import mapper
from sqlalchemy.ext.declarative import declarative_base

def create_session():
  engine = create_engine('postgres://%s:%s@%s:%s/%s' % (DATABASE_USER, DATABASE_PASSWORD, DATABASE_HOST, DATABASE_PORT, DATABASE_NAME), echo=True)
  Session = scoped_session(sessionmaker(bind=engine))
  return Session()

Base = declarative_base()
class Zipcode(Base):
  __tablename__ = 'zipcode'
  zipcode = Column(String(6), primary_key = True, nullable=False)
  city = Column(String(30), nullable=False)
  state = Column(String(30), nullable=False)

session = create_session()
query = session.query(Zipcode).options(eagerload('zipcode')).filter(Zipcode.state.in_(['NH', 'ME']))
#query = session.query(Zipcode.zipcode).filter(Zipcode.state.in_(['NH', 'ME']))
print query.count()

AttributeError 失败：“ColumnProperty”对象没有属性“mapper”

一个没有预先加载的正确返回记录。

我是 SQLAlchemy 的新手。我不确定问题是什么。任何指针？

4

1 回答 1

2

您只能预先加载关系属性。不在桌子上。急切加载意味着在获取特定对象的同时从其他表中加载对象。为查询加载所有对象的方式是简单地添加 all()。

query = session.query(Zipcode).options(eagerload('zipcode')).filter(Zipcode.state.in_(['NH', 'ME'])).all()

查询现在将是表中所有对象（行）的列表，并且 len(query) 将为您提供计数。

于 2009-08-14T20:19:18.083 回答