sql >> データベース >  >> RDS >> Mysql

トリガーを作成するためのMySQLコードを動的に構築する

    この質問に対する明確な解決策を受け取っていないので、概念実証オプションを作成しました(MySQLでは、プリペアドステートメントを使用してトリガーを作成するSQLコードをネイティブに実行できないため)。積極的なご意見をお寄せください。

    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 ;  
    

    使用するには、手順を呼び出します:

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

    現在動作しているDBの名前を使用して新しいデータベースが作成され、それに「_history」というサフィックスが追加されます。テーブル「name_of_table」は、元のテーブルと同じこの新しいDBに作成されます。フィールド「pri_key_fld」(テーブル「name_of_table」のプライマリ/一意キーである必要があります)は、通常の「INDEX」キーに変換されます。これの目的は、将来の複数の行の監査ログ中に固有の違反を回避することです。

    次に、プロシージャによって作成されたファイルを実行します:SOURCE 'path/to/file.sql'; (またはそのファイルからSQLを実行するための代替構文)

    いくつかの警告:現在、「pri_key_fld」には1つのフィールドしか指定できません。理想的には、そのテーブル内のすべての一意のフィールドを含む「配列」を提供する必要があります。現在、複数の一意のフィールドがある場合、一意の違反により、複数の行をログに記録できなくなります。そして、それは良くありません!

    繰り返しになりますが、次のコマンドで同じファイルからSQLを読み取るためだけに、ディスク上にファイルを作成するプロセスを実行することは、明らかに非常に不器用でパフォーマンスが低くなります。改善するために検討できる代替案の1つは、次のとおりです。CALL createAuditTableを実行します。 コマンドラインからの部分で、出力をテキストとしてキャッチし、コマンドラインでSQLと同じように実行します。私はWindowsPowerShellでそれを試みました。しかし、出力はリテラルの「\ r \ n」文字列(改行を表す)でいっぱいでした。すぐにこのひもを掃除する時間がなかったので、今は冷蔵庫にあります!

    最後に、MySQL忍者の皆さん、よろしくお願いします。私はプロではありません。これは、実際的な問題を解決するための、自分で育てる食料品の試みにすぎません。

    ありがとうございます。



    1. Wordpressのドロップダウンまたはテキストフィールドからfunctions.phpのMySQLクエリに値を渡す

    2. 半径に従ってマップデータベースからポイントを選択します

    3. AndroidデバイスからPHPを使用してMySQLデータベースに接続する

    4. SQLチートシート:SQL、SQLコマンド、およびSQLインジェクションとは