Функции сервиса блокировок, описанные в Разделе 5.5.6.1.1, «Интерфейс сервиса блокировок на C», не нуждаются в установке, так как они встроенные в сервер. То же самое не относится к загружаемым функциям, которые отображаются на вызовах функций сервиса: эти функции необходимо установить перед использованием. В этом разделе описывается, как это сделать. Для общей информации об установке загружаемых функций см. Раздел 5.6.1, «Установка и удаление загружаемых функций».

Функции сервиса блокировок реализованы в файле библиотеки плагинов, расположенном в каталоге, указанном переменной системы plugin_dir. Имя файла — locking_service. Суффикс имени файла отличается в зависимости от платформы (например, .so для Unix-систем, .dll для Windows).

Для установки функций сервиса блокировок используйте оператор CREATE FUNCTION, скорректировав суффикс .so для вашей платформы по мере необходимости:

CREATE FUNCTION service_get_read_locks RETURNS INT
  SONAME 'locking_service.so';
CREATE FUNCTION service_get_write_locks RETURNS INT
  SONAME 'locking_service.so';
CREATE FUNCTION service_release_locks RETURNS INT
  SONAME 'locking_service.so';

Если функции используются на сервере источника репликации, установите их и на всех серверах репликации, чтобы избежать проблем с репликацией.

После установки функции остаются установленными до их удаления. Для их удаления используйте оператор DROP FUNCTION:

DROP FUNCTION service_get_read_locks;
DROP FUNCTION service_get_write_locks;
DROP FUNCTION service_release_locks;

Перед использованием функций сервиса блокировок установите их в соответствии с инструкциями в разделе Установка или удаление интерфейса функции сервиса блокировок.

Для получения одной или нескольких блокировок чтения вызовите эту функцию:

mysql> SELECT service_get_read_locks('mynamespace', 'rlock1', 'rlock2', 10);
+---------------------------------------------------------------+
| service_get_read_locks('mynamespace', 'rlock1', 'rlock2', 10) |
+---------------------------------------------------------------+
|                                                             1 |
+---------------------------------------------------------------+

Первый аргумент — пространство имен блокировки. Последний аргумент — целочисленная временная метка, указывающая, сколько секунд ожидать получения блокировок перед отказом. Аргументы между ними — имена блокировок.

В приведенном примере функция получает блокировки с идентификаторами блокировок (mynamespace, rlock1) и (mynamespace, rlock2).

Для получения записей блокировок вместо блокировок чтения вызовите эту функцию:

mysql> SELECT service_get_write_locks('mynamespace', 'wlock1', 'wlock2', 10);
+----------------------------------------------------------------+
| service_get_write_locks('mynamespace', 'wlock1', 'wlock2', 10) |
+----------------------------------------------------------------+
|                                                              1 |
+----------------------------------------------------------------+

В этом случае идентификаторы блокировок — (mynamespace, wlock1) и (mynamespace, wlock2).

Для освобождения всех блокировок для пространства имен используйте эту функцию:

mysql> SELECT service_release_locks('mynamespace');
+--------------------------------------+
| service_release_locks('mynamespace') |
+--------------------------------------+
|                                    1 |
+--------------------------------------+

Каждая функция блокировки возвращает ненулевое значение при успехе. Если функция завершается ошибкой, происходит ошибка. Например, возникает следующая ошибка, потому что имена блокировок не могут быть пустыми:

mysql> SELECT service_get_read_locks('mynamespace', '', 10);
ERROR 3131 (42000): Incorrect locking service lock name ''.

Сессия может получить несколько блокировок для одного и того же идентификатора блокировки. Пока другая сессия не имеет записи блокировки для идентификатора, сессия может получить любое количество блокировок чтения или записи. Каждый запрос на блокировку для идентификатора получает новую блокировку. Следующие операторы получают три записи блокировок с одинаковым идентификатором, а затем три блокировки чтения для того же идентификатора:

SELECT service_get_write_locks('ns', 'lock1', 'lock1', 'lock1', 0);
SELECT service_get_read_locks('ns', 'lock1', 'lock1', 'lock1', 0);

Если вы изучите таблицу Performance Schema metadata_locks в этот момент, вы обнаружите, что сессия содержит шесть различных блокировок с одинаковым (ns, lock1) идентификатором. (Для получения подробностей см. Мониторинг сервиса блокировок.)

Поскольку сессия содержит по крайней мере одну запись блокировки для (ns, lock1), ни одна другая сессия не может получить блокировку для нее, ни чтение, ни запись. Если сессия содержала только блокировки чтения для идентификатора, другие сессии могли получить блокировки чтения, но не записи.

Блокировки для одного вызова приобретения блокировки получают атомарно, но атомарность не сохраняется между вызовами. Таким образом, для оператора, такого как следующий, где service_get_write_locks() вызывается один раз на строку набора результатов, атомарность сохраняется для каждого отдельного вызова, но не для всего оператора:

SELECT service_get_write_locks('ns', 'lock1', 'lock2', 0) FROM t1 WHERE ... ;

INSERT INTO ... SELECT service_get_write_locks('ns', t1.col_name, 0) FROM t1;

Сервис блокировок реализован с использованием механизма блокировок метаданных MySQL Server, поэтому вы можете отслеживать полученные или ожидаемые блокировки сервиса блокировок, просматривая таблицу Performance Schema metadata_locks.

Сначала включите инструмент для блокировки метаданных:

mysql> UPDATE performance_schema.setup_instruments SET ENABLED = 'YES'
    -> WHERE NAME = 'wait/lock/metadata/sql/mdl';

Затем получите некоторые блокировки и проверьте содержимое таблицы metadata_locks:

mysql> SELECT service_get_write_locks('mynamespace', 'lock1', 0);
+----------------------------------------------------+
| service_get_write_locks('mynamespace', 'lock1', 0) |
+----------------------------------------------------+
|                                                  1 |
+----------------------------------------------------+
mysql> SELECT service_get_read_locks('mynamespace', 'lock2', 0);
+---------------------------------------------------+
| service_get_read_locks('mynamespace', 'lock2', 0) |
+---------------------------------------------------+
|                                                 1 |
+---------------------------------------------------+
mysql> SELECT OBJECT_TYPE, OBJECT_SCHEMA, OBJECT_NAME, LOCK_TYPE, LOCK_STATUS
    -> FROM performance_schema.metadata_locks
    -> WHERE OBJECT_TYPE = 'LOCKING SERVICE'\G
*************************** 1. row ***************************
  OBJECT_TYPE: LOCKING SERVICE
OBJECT_SCHEMA: mynamespace
  OBJECT_NAME: lock1
    LOCK_TYPE: EXCLUSIVE
  LOCK_STATUS: GRANTED
*************************** 2. row ***************************
  OBJECT_TYPE: LOCKING SERVICE
OBJECT_SCHEMA: mynamespace
  OBJECT_NAME: lock2
    LOCK_TYPE: SHARED
  LOCK_STATUS: GRANTED

У блокировок сервиса блокировок есть значение OBJECT_TYPE равное LOCKING SERVICE. Это отличается, например, от блокировок, полученных с помощью функции GET_LOCK(), у которых значение OBJECT_TYPE равно USER LEVEL LOCK.

Пространство имен блокировки, имя и режим отображаются в столбцах OBJECT_SCHEMA, OBJECT_NAME и LOCK_TYPE. Блокировки чтения и записи имеют значения LOCK_TYPE, равные SHARED и EXCLUSIVE соответственно.

Значение LOCK_STATUS равно GRANTED для полученной блокировки, PENDING для блокировки, за которой ведется ожидание. Вы увидите PENDING, если одна сессия имеет запись блокировки, а другая сессия пытается получить блокировку с тем же идентификатором.

SQL-интерфейс службы блокировки реализует загружаемые функции, описанные в этом разделе. Примеры использования см. в разделе об использовании интерфейса функций службы блокировки.

Функции обладают следующими характеристиками:

Доступны следующие функции службы блокировки: