Вторичная таблица SQLAlchemy ManyToMany с дополнительными полями

У меня есть 3 таблицы: User, Community, community_members (для отношений many2many пользователей и сообщества).

Я создаю эти таблицы с помощью Flask-SQLAlchemy:

community_members = db.Table('community_members',
                db.Column('user_id', db.Integer, db.ForeignKey('user.id')),
                db.Column('community_id', db.Integer, db.ForeignKey('community.id')),
                )


class Community(db.Model):
    __tablename__ = 'community'

    id = db.Column(db.Integer, primary_key=True)
    name = db.Column(db.String(100), nullable=False, unique=True)
    members = db.relationship(User, secondary=community_members,
                            backref=db.backref('community_members', lazy='dynamic'))

Теперь я хочу добавить дополнительное поле в community_members следующим образом:

community_members = db.Table('community_members',
                db.Column('id', db.Integer, primary_key=True),
                db.Column('user_id', db.Integer, db.ForeignKey('user.id')),
                db.Column('community_id', db.Integer, db.ForeignKey('community.id')),
                db.Column('time_create', db.DateTime, nullable=False, default=func.now()),
                )

И теперь в оболочке Python я могу сделать это:

создать сообщество:

> c = Community()
> c.name = 'c1'
> db.session.add(c)
> db.session.commit()

добавить участников в сообщество:

> u1 = User.query.get(1)
> u2 = User.query.get(2)
> c.members.append(u1)
> c.members.append(u2)
> db.session.commit()

> c.members
[<User 1>, <User 2>]

Хорошо, это работает.

Но как мне теперь получить time_create таблицы community_members?


python sqlalchemy orm flask-sqlalchemy many-to-many
person lestat    schedule 14.09.2011    source источник

Ответы (2)


arrow_upward
64
arrow_downward

Вам придется переключиться с использования простого отношения «многие ко многим» на использование «объекта ассоциации», который в основном просто берет таблицу ассоциации и дает ей правильное сопоставление классов. Затем вы определите отношения «один ко многим» для User и Community:

class Membership(db.Model):
    __tablename__ = 'community_members'

    id = db.Column('id', db.Integer, primary_key=True)
    user_id = db.Column(db.Integer, db.ForeignKey('user.id'))
    community_id = db.Column(db.Integer, db.ForeignKey('community.id'))
    time_create = db.Column(db.DateTime, nullable=False, default=func.now())

    community = db.relationship(Community, backref="memberships")
    user = db.relationship(User, backref="memberships")


class Community(db.Model):
    __tablename__ = 'community'

    id = db.Column(db.Integer, primary_key=True)
    name = db.Column(db.String(100), nullable=False, unique=True)

Но время создания может вас интересовать лишь изредка; Вы хотите вернуть старые отношения! ну, вы же не хотите настраивать relationship дважды; потому что sqlalchemy подумает, что вам нужны две ассоциации; что должно означать что-то другое! Это можно сделать, добавив прокси-ассоциацию.

from sqlalchemy.ext.associationproxy import association_proxy

Community.members = association_proxy("memberships", "user")
User.communities = association_proxy("memberships", "community")
person SingleNegationElimination    schedule 23.09.2011
comment
Я использовал ваше решение, и оно сработало, но у меня все еще есть проблема. Возможно ли, что Community.members (добавленный с прокси-сервером ассоциации) возвращает AppenderBaseQuery, что я могу добавить больше фильтров, например. Community.members.filter_by(...)? Я привык делать это с помощью простого отношения «многие ко многим», используя lazy=dynamic в объявлении отношения, но после указания сопоставления классов в таблице ассоциаций кажется, что я больше не могу этого делать. - person stefanobaldo; 30.01.2015
comment
Вы когда-нибудь находили решение @stefanobaldo - было бы очень полезно, если бы вы это сделали! - person pip; 18.04.2016

arrow_upward
0
arrow_downward

Если вам нужны только таблицы запросов community_members и community по известному user_id (например, user_id = 2), в SQLAlchemy вы можете выполнить:

session.query(community_members.c.time_create, Community.name).filter(community_members.c.user_id==2)

чтобы получить результат.

person carton.swing    schedule 13.06.2017