根据Django中的项目分组进行分页

Mic*_*ael 5 python mysql sql django django-models

对于在Django/Python中实现的网站,我们有以下要求:

在视图页面上,每个Web分页显示15条消息.如果来自同一来源的更多两条或更多条消息在视图上相互跟随,则应将它们组合在一起.

也许不清楚,但以下例子可能是:

一个例子是(这次在页面上有5条消息):

  Message1 Source1
  Message2 Source2
  Message3 Source2
  Message4 Source1
  Message5 Source3
  ...
Run Code Online (Sandbox Code Playgroud)

这应显示为:

Message1 Source1
Message2 Source2 (click here to 1 more message from Source2)
Message4 Source1
Message5 Source3
Message6 Source2
Run Code Online (Sandbox Code Playgroud)

因此,在每个页面上,页面上会显示固定数量的项目,其中一些项目已重新分组.

我们想知道如何创建Django或MySQL查询以便以最佳和简单的方式查询这些数据.请注意,使用分页并且消息按时间排序.

PS:由于SQL的性质,我认为没有一个简单的解决方案,但有时复杂的问题很容易解决

Dav*_*ger 3

我看不出有什么好方法可以直接完成您想要做的事情。如果您愿意接受一点非规范化,我建议使用预保存信号将消息标记为位于头部。

#In your model
head = models.BooleanField(default=True)

#As a signal plugin:
def check_head(sender, **kwargs):
    message = kwargs['instance']
    if hasattr(message,'no_check_head') and message.no_check_head:
        return
    previous_message = Message.objects.filter(time__lt=message.time).order_by('-time')[0]
    if message.source == previous_message.source:
        message.head = False
    next_message = Message.objects.filter(time__gt=message.time).order_by('time')[0]
    if message.source == next_message.source:
        next_message.head = False
        next_message.no_check_head
        next_message.save()
Run Code Online (Sandbox Code Playgroud)

然后你的查询变得非常简单:

messages = Message.objects.filter(head=True).order_by('time')[0:15]
Run Code Online (Sandbox Code Playgroud)

老实说......信号监听器必须比我写的要复杂一点。我的方法中存在许多固有的丢失同步/丢失更新问题,解决方案将根据您的服务器而有所不同(如果它是单处理、多线程,那么 python 对象应该可以帮助您解决Lock,但如果它是多进程的,那么你真的需要基于文件或数据库对象实现锁定)。另外,您当然还必须编写相应的删除信号侦听器。

显然,此解决方案涉及添加一些数据库命中,但它们是在编辑而不是在查看中,这对您来说可能是值得的。否则,也许可以考虑一种更粗略的方法:抓取 30 个故事,在视图中循环,剔除您不会显示的故事,如果还剩 15 个故事,则显示它们,否则重复。这绝对是一个可怕的最坏情况,但也许不是可怕的平均情况?

如果您的服务器配置使用多线程的单个进程,则 Lock 或 RLock 应该可以解决问题。这是使用不可重入锁的可能实现:

import thread
lock = thread.allocate_lock()
def check_head(sender, **kwargs):
    # This check must come outside the safe zone
    # Otherwise, your code will screech to a hault
    message = kwargs['instance']
    if hasattr(message,'no_check_head') and message.no_check_head:
        return
    # define safe zone
    lock.acquire()
    # see code above
    ....
    lock.release()
Run Code Online (Sandbox Code Playgroud)

同样,相应的删除信号也很重要。

编辑:许多或大多数服务器配置(例如 Apache)将预分叉,这意味着有多个进程正在进行。在这种情况下,上面的代码将毫无用处。有关如何开始与分叉进程同步的想法,请参阅此页面。