Anwenden von LIMIT und OFFSET auf alle Abfragen in SQLAlchemy

Question

Ich entwerfe eine API mit SQLAlchemy (Abfrage von MySQL) und ich möchte alle meine Abfragen zwingen, page_size (LIMIT) und page_number (OFFSET) Parameter zu haben.

Gibt es einen sauberen Weg, dies mit SQLAlchemy zu tun? Vielleicht eine Art Factory erstellen, um ein benutzerdefiniertes Query-Objekt zu erstellen? Oder vielleicht gibt es eine gute Möglichkeit, dies mit einer Mixing-Klasse zu tun?

habe ich versucht, die offensichtliche Sache, und es hat nicht funktioniert, weil .limit() und .Offset() aufgerufen werden muss, nachdem alle Filterbedingungen angewandt wurden:

def q(page=0, page_size=None): 
    q = session.query(...) 
    if page_size: q = q.limit(page_size) 
    if page: q = q.offset(page*page_size) 
    return q 

Wenn ich das versuchen Sie es mit, ich Erhalten Sie die Ausnahme:

sqlalchemy.exc.InvalidRequestError: Query.filter() being called on a Query which already has LIMIT or OFFSET applied. To modify the row-limited results of a Query, call from_self() first. Otherwise, call filter() before limit() or offset() are applied. 

Answer 1

Versuchen Sie, ein erstes erforderliches Argument hinzuzufügen, das eine Gruppe von Abfragefiltern sein muss. So

# q({'id': 5}, 2, 50) 
def q(filters, page=0, page_size=None): 
    query = session.query(...).filter_by(**filters) 
    if page_size: 
     query = query.limit(page_size) 
    if page: 
     query = query.offset(page*page_size) 
    return query 

oder

# q(Model.id == 5, 2, 50) 
def q(filter, page=0, page_size=None): 
    query = session.query(...).filter(filter) 
    if page_size: 
     query = query.limit(page_size) 
    if page: 
     query = query.offset(page*page_size) 
    return query