Flask-SQLAlchemy Модель отношений и запросов - PullRequest
Новая
       9

Flask-SQLAlchemy Модель отношений и запросов

0 голосов
/ 06 ноября 2019

В моем приложении Flask есть следующие модели SQLAlchemy: 

class User(UserMixin, db.Model):
    __tablename__ = "users"

    # relationships
    instruments = db.relationship(
        Instrument, backref="instruments", passive_deletes=True, lazy="dynamic"
    )
    transactions = db.relationship(
        Transaction, backref="transactions", passive_deletes=True, lazy="dynamic"
    )
    round_trips = db.relationship(
        RoundTrip, backref="round_trips", passive_deletes=True, lazy="dynamic"
    )

    # columns
    id = db.Column(db.Integer, primary_key=True)
    username = db.Column(db.String(24), unique=True, index=True)

class Instrument(db.Model):
    __tablename__ = "instruments"

    # relationships
    user = db.relationship("User")
    transaction = db.relationship(
        Transaction, uselist=False, backref="transaction", passive_deletes=True
    )

    # columns
    id = db.Column(db.Integer, primary_key=True)
    user_id = db.Column(
        db.Integer,
        db.ForeignKey("users.id", onupdate="CASCADE", ondelete="CASCADE"),
        index=True,
        nullable=False,
    )
    symbol = db.Column(db.String(100), index=True)

class Transaction(db.Model):
    __tablename__ = "transactions"

    # relationships
    user = db.relationship("User")
    instrument = db.relationship("Instrument")
    transaction_round_trip_mapping = db.relationship(
        "RoundTripTransactionMapping",
        backref="round_trip_mappings",
        passive_deletes=True,
        lazy="dynamic",
    )

    # columns
    id = db.Column(db.Integer, primary_key=True)
    user_id = db.Column(
        db.Integer,
        db.ForeignKey("users.id", onupdate="CASCADE", ondelete="CASCADE"),
        index=True,
        nullable=False,
    )
    instrument_id = db.Column(
        db.Integer,
        db.ForeignKey("instruments.id", onupdate="CASCADE", ondelete="CASCADE"),
        index=True,
        nullable=False,
    )
    amount = db.Column(db.Float, nullable=False)

class RoundTrip(ResourceMixin, db.Model):
    __tablename__ = "round_trips"

    # relationships
    user = db.relationship("User")
    transaction_round_trip_mapping = db.relationship(
        "RoundTripTransactionMapping", backref="transaction_mappings", passive_deletes=True, lazy="dynamic"
    )

    # columns
    id = db.Column(db.Integer, primary_key=True)
    user_id = db.Column(
        db.Integer,
        db.ForeignKey("users.id", onupdate="CASCADE", ondelete="CASCADE"),
        index=True,
        nullable=False,
    )

class RoundTripTransactionMapping(db.Model):
    __tablename__ = "round_trip_transaction_mappings"

    # relationships
    round_trip = db.relationship("RoundTrip")
    transaction = db.relationship("Transaction")

    # columns
    id = db.Column(db.Integer, primary_key=True)
    round_trip_id = db.Column(
        db.Integer,
        db.ForeignKey("round_trips.id", onupdate="CASCADE", ondelete="CASCADE"),
        index=True,
        nullable=False,
    )
    transaction_id = db.Column(
        db.Integer,
        db.ForeignKey("transactions.id", onupdate="CASCADE", ondelete="CASCADE"),
        index=True,
        nullable=False,
    )
    closing_transaction = db.Column(db.Boolean, nullable=False)

A User может иметь одну или несколько Transaction с. A User может иметь один или несколько Instrument s. A Transaction может иметь один Instrument. RoundTrip может иметь один или несколько Transaction с.

Модель RoundTripTransactionMapping представляет собой просто таблицу сопоставления, чтобы связать RoundTrip с одним или несколькими Transactions.

Я хочу запросить для всех RoundTrip с Instrument.symbol == "GOOG".

Как я могу сделать это с помощью ORM в SQLAlchemy?

(Я даже правильно определил эти отношения? Я получаюнемного потерял с этим.)

1 Ответ

0 голосов
/ 06 ноября 2019

Сортировал, довольно просто на самом деле. Документы SQLAlchemy на join спасли день. 

result = (
    db.session.query(RoundTrip)
    .join(RoundTripTransactionMapping)
    .join(Transaction)
    .join(Instrument)
    .filter(Instrument.symbol == "GOOG")
    .all()
)
...