Процедуры сервиса блокировок, описанные в разделе 7.6.9.1.1 «Интерфейс сервиса блокировок на C», не требуют установки, так как они встроены в сервер. Это не относится к загружаемым функциям, которые отображаются на вызовах процедур службы: эти функции должны быть установлены перед использованием. В этом разделе описано, как это сделать. Общие сведения об установке загружаемых функций см. в разделе 7.7.1 «Установка и удаление загружаемых функций».

Функции сервиса блокировок реализованы в файле библиотеки плагинов, расположенном в каталоге, указанном переменной среды plugin_dir. Имя файла — locking_service. Расширение файла зависит от платформы (например, .so для систем Unix и 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-интерфейс службы блокировки реализует загружаемые функции, описанные в этом разделе. Примеры использования см. в разделе об использовании интерфейса функций службы блокировки.

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

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