Процедуры сервиса блокировки, описанные в Разделе 7.6.9.1.1, «Интерфейс сервиса блокировки C», устанавливать не нужно, так как они встроены в сервер. Это не относится к загружаемым функциям, которые отображаются на вызовы процедур сервиса: эти функции необходимо установить перед использованием. В этом разделе описывается как это сделать. Общие сведения об установке загружаемых функций см. в Разделе 7.7.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-интерфейс службы блокировки реализует загружаемые функции, описанные в этом разделе. Примеры использования см. в разделе об использовании интерфейса функций службы блокировки.

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

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