X-Git-Url: https://git.openstreetmap.org./osqa.git/blobdiff_plain/410bfa05ee36ed1d99356c443a5f3f6aa3ee9578..886fb5136dfb9ff258b8948c981a68bbf3550208:/forum_modules/pgfulltext/handlers.py diff --git a/forum_modules/pgfulltext/handlers.py b/forum_modules/pgfulltext/handlers.py index 835c2f5..780bfa9 100644 --- a/forum_modules/pgfulltext/handlers.py +++ b/forum_modules/pgfulltext/handlers.py @@ -1,15 +1,38 @@ -from forum.models import Question -from forum.modules.decorators import decorate -from forum.views.readers import do_question_search - -@decorate(do_question_search, needs_origin=False) -def question_search(keywords): - return Question.objects.all().extra( - select={ - 'ranking': 'node_ranking("forum_node"."id", %s)', - }, - where=['node_ranking("forum_node"."id", %s) > 0'], - params=[keywords], - select_params=[keywords], - order_by=['-ranking'] - ) \ No newline at end of file +import re +from django.db import connection, transaction +from django.db.models import Q +from forum.models.question import Question, QuestionManager +from forum.models.node import Node +from forum.modules import decorate + +word_re = re.compile(r'\w+', re.UNICODE) + +@decorate(QuestionManager.search, needs_origin=False) +def question_search(self, keywords): + tsquery = " | ".join(word_re.findall(keywords)) + ilike = keywords + u"%%" + + return True, self.extra( + tables = ['forum_rootnode_doc'], + select={ + 'ranking': """ + rank_exact_matches(ts_rank_cd('{0.1, 0.2, 0.8, 1.0}'::float4[], "forum_rootnode_doc"."document", to_tsquery('english', %s), 32)) + """, + }, + where=[""" + "forum_rootnode_doc"."node_id" = "forum_node"."id" AND ("forum_rootnode_doc"."document" @@ to_tsquery('english', %s) OR + "forum_node"."title" ILIKE %s) + """], + params=[tsquery, ilike], + select_params=[tsquery], + ) + + +@decorate(Node.delete) +def delete(origin, self, *args, **kwargs): + cursor = connection.cursor() + cursor.execute("DELETE FROM forum_rootnode_doc WHERE node_id = %s" % (self.id)) + transaction.commit_unless_managed() + return origin(self, *args, **kwargs) + +