Создать общий триггер в MySQL

Question

В Postgresql триггер можно создать, используя процедуру триггера .Это удобный способ создания триггера.Используя одну и ту же процедуру триггера, можно создать несколько триггеров и применить их даже для нескольких разных таблиц.Мне интересно, есть ли какой-либо аналог MySQL для него.Я вдохновлен этим блогом post , который создает общий триггер для аудита базы данных.Мой план заключается в реализации аналогичного подхода с использованием MySQL.Но возможно ли создать такой общий триггер с помощью MySQL?

Answer 1

Проведя некоторые исследования, я понял, что в MySQL нет прямого способа создать общий триггер.Даже динамический SQL, такой как оператор prepare, оператор execute, не разрешен внутри триггера в MySQL.

Я нашел обходной путь для динамического создания триггера.Предположим, у нас есть таблица клиентов:

CREATE TABLE customer (
  id bigint(20) NOT NULL AUTO_INCREMENT,
  created_on datetime DEFAULT NULL,
  first_name varchar(100) NOT NULL,
  last_name varchar(100) NOT NULL,
  PRIMARY KEY (id)
) 

Таблица информации о редакции:

CREATE TABLE REVINFO (
  REV int(11) NOT NULL AUTO_INCREMENT,
  REVTSTMP bigint(20) DEFAULT NULL,
  PRIMARY KEY (REV)
) 

Таблица аудита:

CREATE TABLE customer_AUD (
  id bigint(20) NOT NULL,
  REV int(11) NOT NULL,
  REVTYPE tinyint(4) DEFAULT NULL,
  created_on datetime DEFAULT NULL,
  first_name varchar(100) DEFAULT NULL,
  last_name varchar(100) DEFAULT NULL,
  PRIMARY KEY (id, REV),
  KEY FK_REV (REV)
) 

Теперь мы напишем процедуру, котораяпримет имя таблицы и сгенерирует SQL для создания триггера, связанного с аудитом для таблицы.

DROP PROCEDURE IF EXISTS `proc_trigger_generator`;

DELIMITER $$

CREATE PROCEDURE `proc_trigger_generator` (IN tableName VARCHAR(255))
BEGIN
    DECLARE triggerSQL TEXT DEFAULT "";
    DECLARE cols TEXT DEFAULT "";
    DECLARE col_values TEXT DEFAULT "";
    DECLARE insert_query TEXT DEFAULT "";
    DECLARE colName TEXT DEFAULT "";
    DECLARE done INT DEFAULT FALSE;

    DECLARE cursorDS CURSOR FOR SELECT column_name FROM information_schema.columns cols 
        WHERE cols.table_name = CONCAT(tableName, '_AUD')
            and (column_name != 'REV' && column_name != 'REVTYPE');
    DECLARE CONTINUE HANDLER FOR NOT FOUND SET done = TRUE; 

    SET triggerSQL = 'DELIMITER ;; \n\n';
    SET triggerSQL = CONCAT(triggerSQL, 'drop trigger if exists tr_', tableName, '_update_audit;; \n\n');
    SET triggerSQL = CONCAT(triggerSQL, 'create trigger tr_', tableName, '_update_audit \n');
    SET triggerSQL = CONCAT(triggerSQL, 'after update \n');
    SET triggerSQL = CONCAT(triggerSQL, '\t on ', tableName, '\n');
    SET triggerSQL = CONCAT(triggerSQL, 'for each row \n');
    SET triggerSQL = CONCAT(triggerSQL, 'begin  \n');
    SET triggerSQL = CONCAT(triggerSQL, '\t DECLARE tmpInt INT; \n');   
    SET triggerSQL = CONCAT(triggerSQL, '\t SELECT COALESCE(MAX(REV), 0) FROM REVINFO into tmpInt; \n\n');  
    SET triggerSQL = CONCAT(triggerSQL, '\t INSERT INTO REVINFO (REV, REVTSTMP) VALUES (tmpInt+1, CURRENT_TIMESTAMP()); \n\n'); 

    SET insert_query = CONCAT(insert_query, 'INSERT INTO ', CONCAT(tableName, '_AUD'), ' (');
    OPEN cursorDS;  
    ds_loop: LOOP
        FETCH cursorDS INTO colName;
        IF done THEN
            LEAVE ds_loop;
        END IF;     
        SET cols = CONCAT(cols, colName, ', ');
        SET col_values = CONCAT(col_values, 'new.', colName, ', ');
    END LOOP;

    SET insert_query = CONCAT(insert_query, cols, 'REV, REVTYPE) VALUES \n');
    SET insert_query = CONCAT(insert_query, '\t\t(', col_values, 'tmpInt+1, 1', ');');
    CLOSE cursorDS;

    SET triggerSQL = CONCAT(triggerSQL, '\t ',insert_query, ' \n\n');
    SET triggerSQL = CONCAT(triggerSQL, 'end;; \n\n');
    SET triggerSQL = CONCAT(triggerSQL, 'DELIMITER ; \n\n');

    SELECT triggerSQL;

END $$
DELIMITER ;

call proc_trigger_generator('customer');

При вызове процедуры с использованием имени таблицы клиента генерируется SQL для требуемого триггера:

DELIMITER ;; 

drop trigger if exists tr_customer_update_audit;; 

create trigger tr_customer_update_audit 
after update 
        on customer
for each row 
begin  
     DECLARE tmpInt INT; 
     SELECT COALESCE(MAX(REV), 0) FROM REVINFO into tmpInt; 

     INSERT INTO REVINFO (REV, REVTSTMP) VALUES (tmpInt+1, CURRENT_TIMESTAMP()); 

     INSERT INTO customer_AUD (id, created_on, first_name, last_name, REV, REVTYPE) VALUES 
        (new.id, new.created_on, new.first_name, new.last_name, tmpInt+1, 1); 

end;; 

DELIMITER ; 

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