Mysql
 sql >> Database >  >> RDS >> Mysql

Costruire dinamicamente codice MySQL per creare un trigger

Non avendo ricevuto alcuna soluzione definitiva per questa domanda, ho proceduto a mettere insieme un'opzione di prova del concetto (poiché MySQL in modo nativo non ti consente di eseguire codice SQL che crea un trigger, usando le istruzioni preparate). Non esitare a fornire qualsiasi input positivo.

DELIMITER //
DROP PROCEDURE IF EXISTS createAuditTable//
CREATE PROCEDURE createAuditTable(tblname CHAR(30), sufftxt CHAR(10), pri CHAR(20), filename CHAR(255) )
BEGIN
    SELECT DATABASE() INTO @dbname;
    SET @srctbl = CONCAT(@dbname, ".", tblname);
    SET @destdb = CONCAT(@dbname, "_", sufftxt);
    SET @desttbl = CONCAT(@destdb, ".", tblname);

    SET @str1 = CONCAT( "CREATE DATABASE IF NOT EXISTS ", @destdb);
    PREPARE stmt1 FROM @str1;
    EXECUTE stmt1;
    DEALLOCATE PREPARE stmt1;

    SET @str2 = "SET FOREIGN_KEY_CHECKS=0";
    PREPARE stmt2 FROM @str2;
    EXECUTE stmt2;
    DEALLOCATE PREPARE stmt2;

    SELECT COUNT(*) FROM information_schema.tables WHERE table_name = tblname AND table_schema = @destdb INTO @tblcount;
    IF (@tblcount = 0) THEN 
        SET @str3 = CONCAT("CREATE TABLE ", @desttbl, " LIKE ", @srctbl);
        PREPARE stmt3 FROM @str3;
        EXECUTE stmt3;
        DEALLOCATE PREPARE stmt3;
    END IF;

    SELECT COUNT(*) FROM information_schema.columns WHERE table_name = tblname AND table_schema = @destdb AND column_key = 'PRI' INTO @keycount;

    IF (@keycount <> 0) THEN 
        SET @str4 = CONCAT("ALTER TABLE ", @desttbl, " DROP PRIMARY KEY, ADD INDEX ", pri, " (", pri, ")" );
        PREPARE stmt4 FROM @str4;
        EXECUTE stmt4;
        DEALLOCATE PREPARE stmt4;
    END IF;

SELECT CONCAT( "DELIMITER $$
DROP TRIGGER IF EXISTS ", tblname, "_history_BU$$
CREATE TRIGGER ", tblname, "_history_BU
BEFORE UPDATE ON ", tblname, "
FOR EACH ROW
BEGIN
    INSERT INTO ", @desttbl, " (",
(SELECT GROUP_CONCAT(column_name) FROM information_schema.columns WHERE table_schema = @dbname AND table_name = tblname), ") ",
    "
    VALUES(", 
(SELECT GROUP_CONCAT('OLD.', column_name) FROM information_schema.columns WHERE table_schema = @dbname AND table_name = tblname),
 ");
END$$
DELIMITER ;"
 ) AS qstr FROM DUAL INTO @triggertxt;

SET @savestr = CONCAT('SELECT ', '"', @triggertxt, '"', " INTO DUMPFILE ", '"', filename, '"');
PREPARE stmt5 FROM @savestr;
EXECUTE stmt5;
DEALLOCATE PREPARE stmt5;


END//
DELIMITER ;  

PER UTILIZZARE, chiamare la Procedura:

CALL createAuditTable('name_of_table', 'history', 'pri_key_fld', 'path/to/file.sql');

Viene creato un nuovo database utilizzando il nome del DB di lavoro corrente, con il suffisso "_history" aggiunto ad esso. La tabella "name_of_table" viene creata in questo nuovo DB, identica alla tabella originale. Il campo "pri_key_fld" (che dovrebbe essere la chiave primaria/unica della tabella "name_of_table") viene convertito in una normale chiave "INDEX". Lo scopo di ciò è prevenire violazioni uniche durante la registrazione di controllo di più righe in futuro.

ALLORA Esegui il file creato dalla procedura:SOURCE 'path/to/file.sql'; (o qualsiasi sintassi alternativa per eseguire SQL da quel file)

Un paio di avvertenze:al momento, puoi fornire un solo campo per "pri_key_fld". Idealmente, vorremmo fornire un "array" contenente tutti i campi univoci in quella tabella. Attualmente, se hai più di un campo univoco, le violazioni univoche ti impediranno di registrare più di una riga. E non è carino!

Anche in questo caso, è ovviamente molto goffo e poco performante eseguire il processo di creazione di un file su disco, solo per leggere SQL dallo stesso file nel comando successivo. Un'alternativa che si può esplorare per migliorare è questa:eseguire CALL createAuditTable parte dalla riga di comando, cattura l'output come testo, quindi esegui lo stesso come SQL proprio lì sulla riga di comando. L'ho provato su Windows PowerShell; ma l'output era pieno di stringhe letterali "\r\n" (che rappresentano interruzioni di riga). Non ho avuto il tempo di lavorare immediatamente per ripulire questo filo, quindi ora è in frigo!

Infine, o voi ninja MySQL, per favore siate gentili. Non sono un professionista, davvero. Questo è solo un tentativo di far crescere la tua spesa per risolvere un problema pratico.

Grazie.