Doe mee aan een CTE in SQLAlchemy

Het tweede argument voor Query.join() moet in dit geval de volledige ON . zijn clausule, maar in plaats daarvan geef je 3 argumenten door aan join() . Gebruik and_() om de predikaten te combineren, zoals wordt gedaan in de onbewerkte SQL:

already_in_db_query = db.session.query(MyModel)\
    .join(cte,
          and_(cte.c.field1 == MyModel.field1,
               cte.c.field2 == MyModel.field2),
    ).all()