Добрый день, хаброжители!
Представляю вашему вниманию расширение для PostgreSQL, позволяющее отправлять поисковые запросы на Sphinx из PostgreSQL и получать результаты этих запросов.
Подробности реализации и ссылка на репозиторий под катом.
Предисловие
В одном крупном web проекте потребовалось использование полнотекстового движка Sphinx. И все бы хорошо, если бы не потребовалось результаты запросов от Sphinx дополнительно сортировать по хитро заданным правилам внутри базы.
И тут встал очевидный вопрос: как? Тут напрашиваются как минимум два варианта:
- Делать полнотекстовый запрос в Sphinx, результаты сортировать в приложении;
- Воспользоваться мощью SQL в PostgreSQL для получения данных поисковых запросов из Sphinx в табличной форме с возможностью дополнительной обработки в базе.
Взвесив все плюсы и минусы указанных вариантов, было реализовано расширение sphinxlink. Идея реализации была честно подсмотрена с расширения dblink.
Функции расширения и детали реализации
Как и в dblink, управление всем осуществляется с помощью SQL функций, написанных на C.
Клиентский протокол взаимодействия с Sphinx соответствует протоколу взаимодействия mysql, а это значит, что мы можем использовать самую обыкновенную библиотеку mysql-client для подключения к Sphinx.
Для подключения к серверу Sphinx используется функция sphinx_connect():
SELECT * FROM sphinx_connect('myconn');
sphinx_connect
----------------
OK
(1 строка)
Подключения создаются в статической области памяти бэкенда в виде структуры HTAB, поэтому при закрытии закрытии сессии все созданные соединения к Sphinx будут закрыты.
Для просмотра списка открытых соединений с Sphinx и параметров подключения используется функция sphinx_connections():
SELECT * FROM sphinx_connections();
conname | host | port
---------+-----------+------
myconn | 127.0.0.1 | 9306
(1 строка)
А теперь, как отправлять поисковые запросы и получать результаты.
Получение результатов поискового запроса в табличной форме реализовано в функции sphinx_query(). Важно при этом указать название столбцов и их типов данных для корректного формирования результата.
Например, создадим индекс в Sphinx со следующей структурой:
DESC myindex;
+---------+--------+
| Field | Type |
+---------+--------+
| id | bigint |
| content | field |
| title | string |
+---------+--------+
В поле content будут лежать тексты документов (например, рассказы А.П. Чехова), в поле title — название рассказа, поле id — идентификатор текста (служебное поле в Sphinx).
SELECT * FROM sphinx_query('myconn', 'SELECT weight(), * FROM myindex WHERE MATCH(''красота'')') AS (weight integer, docid integer, title text);
weight | docid | title
--------+-------+-------
1680 | 3 | Дома
(1 строка)
Для запроса метаинформации по последнему запросу используется функция sphinx_meta():
SELECT * FROM sphinx_meta('myconn');
varname | value
-------------+--------
total | 1
total_found | 1
time | 0.000
keyword[0] | красот
docs[0] | 1
hits[0] | 1
(6 строк)
Данная функция сделана для удобства. Аналогичного эффекта можно добиться, послав запрос SHOW META с помощью функции sphinx_query().
Для закрытия ненужного соединения используется функция sphinx_disconnect():
SELECT * FROM sphinx_disconnect('myconn');
sphinx_disconnect
-------------------
OK
(1 строка)
Планы реализации
У текущей реализации модуля есть ряд недостатков:
- Параметры подключений не сохраняются при завершении сессии PostgreSQL — хотелось бы иметь режим работы, при котором параметры соединения сохранялись в реальную таблицу с целью их получения;
- Все описанное справедливо для запросов на чтение индексов Sphinx, но нет функции управления RT индексами;
- Ваши предложения?
Традиционно для подобных постов, оставляю ссылку на github: sphinxlink.
Комментарии и предложения горячо приветствуются. Спасибо за внимание!
