在flaskSQLAlchemy中保存和恢复查询

Question

我基于用户的搜索构建查询，但只提取切片。在接下来的10分钟内，用户可能会请求下一个slice\page，因此我希望存储查询并在用户需要下一个slice时恢复它。理想情况下，我不希望从头开始构造查询，而是将其恢复到原来的状态，然后获取下一个片段。在

我遇到了-->；http://docs.sqlalchemy.org/en/rel_0_8/core/serializer.html，它似乎是针对这个用例的，但是当我试图在我的查询中运行它时，我遇到了问题。在

lib/python2.7/copy_reg.py", line 70, in _reduce_ex raise TypeError, "can't pickle %s objects" % base.name TypeError: can't pickle function objects

我怀疑这是由于FlaskSQLAlchemy在查询对象中使用函数造成的，但是我不确定问题到底出在哪里。在

你对如何推进这项工作有什么建议或建议吗？或者是另一种方法。在

这是破坏它的代码。在

from flask.ext.sqlalchemy import SQLAlchemy
from sqlalchemy.orm import relationship
from sqlalchemy.ext.serializer import loads, dumps
from sqlalchemy import Table, Column, Integer, ForeignKey

db = SQLAlchemy(app)


class Blink(db.Model):
    id = db.Column(db.Integer, primary_key=True)
    uploaded_sd = db.Column(db.Boolean, default=False, index=True)
    blink_metadata = relationship("BlinkMetadata", remote_side='BlinkMetadata.blink_id',
                                  primaryjoin='blink.c.id==blink_metadata.c.blink_id')


class BlinkMetadata(db.Model):
    id = db.Column(db.Integer, primary_key=True)
    blink_id = db.Column(db.Integer, ForeignKey('blink.id'), index=True)
    metadata_id = db.Column(db.Integer, index=True)
    metadata_type_id = db.Column(db.Integer)
    created_date = db.Column(db.DateTime)
    last_updated = db.Column(db.DateTime)
    blink = relationship("Blink", remote_side='Blink.id',
                         primaryjoin=('blink_metadata.c.blink_id==blink.c.id'))

def make_sample_query():
    q = db.session.query(Blink).filter(Blink.uploaded_sd == 1)

    activity_filter = (
        (BlinkMetadata.metadata_id == 1) &
        (BlinkMetadata.metadata_type_id == 1)
    )

    q = q.join(Blink.blink_metadata, aliased=True).filter(activity_filter)

    serialised_query = dumps(q)

Answer 1

为了处理这件事，我采取了不同的策略。相反，我将查询构建为字符串（作为ORM字符串，而不是SQL字符串）。然后我存储查询，并根据需要使用eval（）恢复并执行它。在

我将查询字符串传递给page\u query（），然后根据需要使用next\u page（）调用页面。在

def page_query(query_string):

  transaction_id = create_query_transaction(0, BLINKS_PAGE_SIZE, query_string)
  return transaction_id


def next_page(transaction_id):

    transaction = BlinkQueryTransaction.query.get(transaction_id)

    query = eval(transaction.sql)
    query = query.slice(transaction.latest_offset, transaction.page_size)

    transaction.latest_offset = transaction.latest_offset + transaction.page_size
    db.session.commit()

    return query


def create_query_transaction(latest_offset, page_size, query):

    bqt = BlinkQueryTransaction(latest_offset=latest_offset, page_size=page_size, sql=query)
    bqt = save_to_db(bqt)

    return bqt.id