X-Git-Url: https://git.openstreetmap.org./osqa.git/blobdiff_plain/eb5d07faf2fe743f482ba8b3168e083e4df29434..390a606c867e39c828628322621419d9d2bce453:/forum_modules/pgfulltext/handlers.py diff --git a/forum_modules/pgfulltext/handlers.py b/forum_modules/pgfulltext/handlers.py index 6e2165b..780bfa9 100644 --- a/forum_modules/pgfulltext/handlers.py +++ b/forum_modules/pgfulltext/handlers.py @@ -1,22 +1,38 @@ +import re +from django.db import connection, transaction from django.db.models import Q from forum.models.question import Question, QuestionManager -from forum.modules.decorators import decorate +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): - return 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", plainto_tsquery('english', %s), 32)) + 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" @@ plainto_tsquery('english', %s) OR - "forum_node"."title" ILIKE '""" + keywords + """%%') + }, + 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=[keywords], - select_params=[keywords], - order_by=['-ranking'] - ) + 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) +