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

MySQL načte datový soubor, když jsou splněny podmínky

Jednou z možností je použít UDF , například:lib_mysqludf_sys .

Po instalaci UDF můžete udělat něco jako:

Shell skript (/server/loadpath/load.sh):

mysql -u [user] -p[pass] -e "LOAD DATA INFILE '$1' INTO TABLE $2;"

Uložená procedura:

DELIMITER $$

DROP PROCEDURE IF EXISTS load_data$$

CREATE PROCEDURE load_data(pfile VARCHAR(100), pdbtable VARCHAR(100))
BEGIN
    DECLARE exec_str VARCHAR(500);
    DECLARE ret_val INT;
    IF (check_10m_file() = 'file ok') THEN
        SET exec_str := CONCAT('sh /server/loadpath/load.sh ', pfile, ' ', pdbtable);
        SET ret_val := sys_exec(exec_str);
        IF ret_val = 0 THEN
            SELECT 'OK' Result;
        ELSE
            SELECT 'ERROR' Result;
        END IF;
    END IF;
END$$

DELIMITER ;

CALL load_data('/server/filepath/file.csv', 'mydb.mytable');

DŮLEŽITÉ: Ověřte vstupní data, abyste zabránili vložení kódu.




  1. získání chybového argumentu '0' je mimo rozsah

  2. Nebyl použit index kvůli konverzi typu?

  3. Správa rolí a stavů v systému

  4. MySQL INSERT funguje správně, jak je zdokumentováno