MySQL: 遍历数据库并在其中运行存储过程

5
我对MySQL非常陌生,我有一个存储过程需要添加到几个旧数据库中。我正在使用SQLyog,并且想循环遍历连接上的每个数据库,如果它与“application _%”匹配(数据库被称为 application_clientName ,有数十个),则运行存储过程。

我希望有一个可保存并通过SQLyog运行的脚本。

我希望循环遍历所有在SHOW DATABASES中的数据库,并在其名称类似于'application_%'时运行语句。该语句将在该数据库中创建一个通用存储过程。

1个回答

8

好的,看起来在information_scheme数据库中的SCHEMATA表包含了所有数据库的列表。因此,为了获取您想要运行该过程的所有数据库的列表,您可以执行以下操作:

SELECT schema_name FROM information_schema.schemata
WHERE schema_name LIKE 'application_%';

下一步是将其转化为某种过程。不幸的是,如果涉及创建过程,MySQL 在执行动态生成的 SQL 方面表现不佳。因此,我想出的纯 SQL 版本有点混乱。它归结为首先创建“生成器”过程,然后调用它,最后执行生成器的结果:
delimiter //
DROP PROCEDURE IF EXISTS create_procedures//
CREATE PROCEDURE create_procedures()
BEGIN
    DECLARE done INT DEFAULT 0;
    DECLARE db VARCHAR(255);
    DECLARE appDBs CURSOR FOR SELECT schema_name FROM information_schema.schemata WHERE schema_name LIKE 'application_%';
    DECLARE CONTINUE HANDLER FOR NOT FOUND SET done = 1;

    SET @procName = "simpleproc"; -- Change this to your proc name

    SET @output = "delimiter //";

    OPEN appDBs;
    REPEAT
        FETCH appDBs INTO db;
        IF NOT done THEN
            -- Replace this procedure declaration with your procedure.
            -- Make sure to keep the ',db,' syntax there.
            -- You should really only have to change the parameters
            -- and the stuff between the BEGIN and END clauses.
            SET @output = CONCAT(@output,'
    DROP PROCEDURE IF EXISTS ',db,'.',@procName,'//
    CREATE PROCEDURE ',db,'.',@procName,'()
        BEGIN
            SELECT 1;
        END//');

        END IF;
    UNTIL done END REPEAT;

    CLOSE appDBs;

    SET @output = CONCAT(@output,'\ndelimiter ;');

    SELECT @output AS procs;
END//
delimiter ;

生成此过程后,调用该过程:
CALL create_procedures();

这将输出一个包含创建所有application_%表存储过程所需SQL的单个列。选择整个列(它可能很长),并将其作为新的SQL查询执行。

我从未使用过SQLyog,但如果它无法正常工作,则可能需要使用MySQL的命令行界面。首先,生成一个名为input.sql的文件,其中包含:

CALL create_procedures();

然后执行以下命令:

mysql -u <username> -p --database=<dbname> -N -r -B < input.sql > proc.sql
mysql -u <username> -p --database=<dbname> < proc.sql

<username><dbname>更改为适当的值(<dbname>可以是您有权限访问的任何数据库)。如果没有遇到任何错误,则应为每个数据库定义了存储过程。


网页内容由stack overflow 提供, 点击上面的
可以查看英文原文,
原文链接