sql >> Databáze >  >> RDS >> Mysql

Dynamicky konstruující MySQL kód pro vytvoření spouštěče

Jelikož jsem neobdržel žádné definitivní řešení pro tuto otázku, přistoupil jsem k vytvoření možnosti důkazu konceptu (protože MySQL by vám nativně nedovolilo spouštět kód SQL, který vytváří spouštěč, pomocí připravených příkazů). Neváhejte a uveďte jakýkoli pozitivní příspěvek.

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 ;  

PRO POUŽITÍ volejte Postup:

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

Vytvoří se nová databáze s použitím názvu vaší aktuální pracovní databáze s příponou „_history“. V této nové DB je vytvořena tabulka "name_of_table" identická s původní tabulkou. Pole "pri_key_fld" (což by měl být primární/unikátní klíč tabulky "name_of_table") je převedeno na běžný "INDEX" klíč. Účelem toho je v budoucnu odvrátit jedinečná porušení během protokolování auditu více řádků.

PAK Spusťte soubor vytvořený postupem:SOURCE 'path/to/file.sql'; (nebo jakákoli alternativní syntaxe pro spuštění SQL z tohoto souboru)

Několik upozornění:Právě teď můžete zadat pouze jedno pole pro "pri_key_fld". V ideálním případě bychom chtěli dodat „pole“ obsahující všechna jedinečná pole v této tabulce. V současné době platí, že pokud máte více než jedno jedinečné pole, jedinečná porušení vám zabrání v protokolování více než jednoho řádku. A to není hezké!

Opět je zjevně velmi nemotorné a nevýkonné projít procesem vytvoření souboru na disku, aby v dalším příkazu načetl SQL ze stejného souboru. Jedna alternativa, kterou lze prozkoumat ke zlepšení, je tato:Spusťte CALL createAuditTable část z příkazového řádku, zachyťte výstup jako text a poté spusťte to samé jako SQL přímo tam na příkazovém řádku. Zkusil jsem to na Windows PowerShell; ale výstup byl prošpikovaný doslovnými "\r\n" řetězci (představujícími zalomení řádků). Neměl jsem čas okamžitě pracovat na vyčištění tohoto provázku, takže je teď v lednici!

Nakonec, ó vy ninjové MySQL, buďte prosím milí. Nejsem profík, fakt. Toto je jen pokus pěstovat si vlastní potraviny při řešení praktického problému.

Děkuji.



  1. Optimalizace Microsoft Access pomocí SQL Server IndyPass – 5/21/19

  2. Více COUNT() pro více podmínek v jednom dotazu (MySQL)

  3. co je oracle EBS R12

  4. Jak vytvořit databázi ze skriptu v MySQL