python – SQLAlchemy渴望加载递归模型

你怎么能写出它渴望以递归方式加载父母和某个角色的孩子的模型.所以不仅是你现在扮演的角色的孩子,而且还是孩子.

您是否冒险以无限循环结束或SQLAlchemy是否具有检测这些的逻辑？

SQLAlchemy模型如下：

from sqlalchemy.ext.declarative import declarative_base


roles_parents = Table(
'roles_parents', Base.metadata,
Column('role_id', Integer, ForeignKey('roles.id')),
Column('parent_id', Integer, ForeignKey('roles.id'))
)


Base = declarative_base()
class Role(Base):

    __tablename__ = 'roles'

id = Column(Integer, primary_key=True)
name = Column(String(20))
parents = relationship(
    'Role',
    secondary=roles_parents,
    primaryjoin=(id == roles_parents.c.role_id),
    secondaryjoin=(id == roles_parents.c.parent_id),
    backref=backref('children', lazy='joined'),
    lazy='joined'
)

def get_children(self):
    logger.log_dbg("get_children(self) with name: "  + self.name)
    for child in self.children:
        yield child
        for grandchild in child.get_children():
            yield grandchild

@staticmethod
def get_by_name(name):
    logger.log_dbg("get_by_name( " + name + " )")
    with DBManager().session_scope() as session:
        role = session.query(Role).options(joinedload(
            Role.children).joinedload(Role.parents)).filter_by(
            name=name).first()
        # role = session.query(Role).filter_by(name=name).first()
        session.expunge_all()
        return role

您可以看到我尝试通过关系中的属性以及我获取角色的查询中的选项启用对父项关系的预先加载.

需要这种急切加载(和session.expunge_all())的原因是,当尝试通过get_children()获取子进程时会话丢失.

由于负载急剧,get_children在访问此角色的子角色时不再失败.但是,在尝试获取孙子时它仍然失败.因此,急切的加载似乎适用于子角色,但并不急于加载其子角色.

解决方法:

我很好奇你为什么要急切地加载孙子孙女：用例是什么？

我问这个的原因是,我假设您可以通过访问当前子节点上的.children属性来在需要时访问孙子.这应该减少内存负载(通过不递归地加载所有子节点),并且还使处理当前节点(角色)更容易推理.

标签：python,sqlalchemy,many-to-many,eager-loading
来源： https://codeday.me/bug/20190710/1424482.html