1. 程式人生 > >MySQL儲存過程:批量為使用者授權

MySQL儲存過程:批量為使用者授權

編寫出這些指令碼的需求是把慢查日誌寫入資料庫中,方便檢視。

1. 由於預設的mysql.slow_log表使用的是csv資料引擎,不支援對資料進行索引,所以需要將其修改為MyISAM引擎,並對query_time欄位進行索引以優化查尋效率。

2. 需要對所有的使用者進行授權,讓大家要可通過呼叫 pub_getSlowQuery( limit ) 儲存過程獲取一天的慢查記錄資料。

3. 儲存過程命名約定:priv_ 起頭的為私有儲存過程,不需要對使用者授權,以pub_起頭的儲存過程對所有的會員進行授權,只允許執行,不可修改和刪除。

-- 修改慢查日誌表結構,新增索引優化查尋速度
DROP PROCEDURE IF EXISTS `mysql`.`priv_setSlowLogEngine`;
DELIMITER $$
CREATE PROCEDURE `mysql`.`priv_setSlowLogEngine`() COMMENT '修改慢查設定'
BEGIN
    /** 關閉慢查記錄 */
    SET GLOBAL slow_query_log=0;
    /** 修改儲存方式 */
    SET GLOBAL log_output='TABLE';
    /** 記錄日誌的執行時間 */
    SET GLOBAL long_query_time=3;
    /** 修改表引擎 */
    ALTER TABLE `mysql`.`slow_log` ENGINE=MYISAM;
    /** 新增索引 */
    ALTER TABLE `mysql`.`slow_log` ADD INDEX `query_time`(`query_time`);
    /** 開啟慢查記錄 */
    SET GLOBAL slow_query_log=1;
END$$
DELIMITER ;




-- 獲取慢查尋句子列表
DROP PROCEDURE IF EXISTS `mysql`.`pub_getSlowQuery`;
DELIMITER $$
CREATE PROCEDURE `mysql`.`pub_getSlowQuery`(IN top INT) COMMENT '獲取慢查記錄'
BEGIN
    /**
     * 昨天凌晨一點的時間
     * 業務需求是每天凌晨時間執行,所以是取昨天凌晨到當前時間的所有慢查日誌 */
    DECLARE yesterday DATETIME;
    SELECT CONCAT_WS(' ', DATE_SUB(CURDATE(),INTERVAL 1 DAY), '00:00:00') INTO yesterday;
    SET @sql=CONCAT("SELECT * FROM `mysql`.`slow_log` WHERE `query_time`>0 ORDER BY `query_time` DESC LIMIT 0",top);
    /** 使用預處理執行SQL句子 */
    PREPARE m FROM @sql;
    EXECUTE m;
    DEALLOCATE PREPARE m;
END$$
DELIMITER ;




-- 授權操作
DROP PROCEDURE IF EXISTS `mysql`.`priv_grantToProcedure`;
DELIMITER $$
CREATE PROCEDURE `mysql`.`priv_grantToProcedure`( IN procedureName VARCHAR(30) ) COMMENT '對儲存過程授權'
BEGIN
    DECLARE not_found_data INT DEFAULT 0;
    DECLARE userName VARCHAR(20) DEFAULT '';
    DECLARE hostName VARCHAR(20) DEFAULT '';
    
    /**
     * 將使用者列表讀入遊標 */
    DECLARE users CURSOR FOR SELECT `user`,`host` FROM mysql.user WHERE `user`!='csc86';
    DECLARE CONTINUE HANDLER FOR NOT FOUND SET not_found_data=1;
    
    OPEN users;
    WHILE not_found_data=0 DO
        FETCH users INTO userName,hostName;
        SET @sql=CONCAT('GRANT Execute ON PROCEDURE `mysql`.`',procedureName,'` TO `',userName,'`@`',hostName,'`');
        
        /** 使用預處理執行SQL句子 */
        PREPARE m FROM @sql;
        EXECUTE m;
        DEALLOCATE PREPARE m;
    END WHILE;
    CLOSE users;
END$$
DELIMITER ;



-- 將mysql庫中以pub_開頭的儲存過程對所有使用者授權
DROP PROCEDURE IF EXISTS `mysql`.`priv_setPrivileges`;
DELIMITER $$
CREATE PROCEDURE `mysql`.`priv_setPrivileges`() COMMENT '設定呼叫儲存過程許可權'
BEGIN
    /**
     * 遊標 */
    DECLARE not_found_data INT DEFAULT 0;
    
    /**
     * 儲存過程名稱 */
    DECLARE proc_name VARCHAR(30) DEFAULT '';
    
    /**
     * 讀取所有公開的儲存過程 */
    DECLARE procedures CURSOR FOR SELECT `name` FROM `mysql`.`proc` WHERE `db`='mysql' AND `type`='PROCEDURE' AND `name` REGEXP '^pub_';
    
    /**
     * 到達遊標尾部時,設定not_found_data為1 */
    DECLARE CONTINUE HANDLER FOR NOT FOUND SET not_found_data = 1;
    
    /**
     * 開啟遊標進入迴圈 */
     -- priv_grantToProcedure
    OPEN procedures;
    TRUNCATE TABLE mysql.`procs_priv`;
    WHILE not_found_data=0 DO
        FETCH procedures INTO proc_name;
        CALL priv_grantToProcedure( proc_name );
    END WHILE;
    /** 關閉遊標 */
    CLOSE procedures;
    
    /** 重新整理許可權 */
    FLUSH PRIVILEGES;
END$$
DELIMITER ;