在存储过程中替换变量和游标的问题

Question

所以我知道为了在 select 语句中替换游标，我们需要在 prepare 语句之前定义它。我可以在那里替换变量，但我对游标有相同的问题。

例如，下面的语句应该正确地替换 table 的变量值并且应该创建一个 table 作为 trial_data.

SET @user := 'trial';
SET @group := 'data';
SET @table := CONCAT(@user, '_', @group);
SET @stat = CONCAT('CREATE TABLE ',@table,' as SELECT @user, @group;');
PREPARE stmt from @stat;
EXECUTE stmt;
DEALLOCATE PREPARE stmt;

但是，当我尝试在带有游标的存储过程中应用相同的逻辑时，我运行出现如下错误 -

01:13:52    call cursor_ROWPERROW() Error Code: 1064. You have an error in your SQL syntax; check the manual that corresponds to your MySQL server version for the right syntax to use near 'NULL' at line 1    0.000 sec

在这种情况下，我尝试通过替换变量和游标的值来动态创建 table。在这里，我尝试根据我从信息架构中识别的另一个 table 的相同列动态创建 PD_yyyyy_xxxxx table。

DROP PROCEDURE IF EXISTS cursor_ROWPERROW;
DELIMITER $$
CREATE PROCEDURE cursor_ROWPERROW()
BEGIN
    DECLARE cursor_COL VARCHAR(50);
    DECLARE cursor_TAB VARCHAR(50);
    DECLARE tab VARCHAR(100);
    DECLARE col1 VARCHAR(50);
    DECLARE col2 VARCHAR(50);
    DECLARE done INT DEFAULT 0;
    DECLARE cursor_i CURSOR FOR SELECT COLUMN_NAME, TABLE_NAME FROM INFORMATION_SCHEMA.COLUMNS WHERE TABLE_SCHEMA='xxxxx' AND TABLE_NAME='yyyyy' AND COLUMN_NAME = 'zzzzz';
    DECLARE CONTINUE HANDLER FOR NOT FOUND SET done = 1;
    OPEN cursor_i;
    read_loop: LOOP
        FETCH cursor_i INTO cursor_COL, cursor_TAB;
        SET tab := CONCAT('PD', '_', @cursor_TAB, '_' , @cursor_COL);
        SET col1 := CONCAT(@cursor_COL);
        SET col2 := CONCAT(@cursor_COL, '_', 'value');
        IF done THEN
            LEAVE read_loop;
        END IF;
        SET @dyn_sql := CONCAT('CREATE TABLE ',@tab,' AS SELECT Codevalue as ',@col1,', valueLabel as ',@col2,' from valuesets14 where varName = cursor_COL and TableName = cursor_TAB;');
        PREPARE stmt_dyn_view FROM @dyn_sql;
        EXECUTE stmt_dyn_view;
        DEALLOCATE PREPARE stmt_dyn_view;
    END LOOP;
    CLOSE cursor_i;
END;
$$

DELIMITER ;

虽然，我用下面的 select 语句替换了整个 SET @dyn_sql 块，但它运行没问题，并为我提供了我想要创建多个 tables 的。请注意，我引用的 table 中的 none 个值是 NULL，因此我似乎遗漏了游标替换的内容。

SELECT Codevalue as ',@col1,', valueLabel as ',@col2,' from valuesets14 where varName = cursor_COL and TableName = cursor_TAB;

谁能帮我解决这个问题？

Answer 1

问题是您混淆了引用变量的各种方式。声明它们时应省略 @ 符号...

read_loop: LOOP
    FETCH cursor_i INTO cursor_COL, cursor_TAB;
    SET tab := CONCAT('PD', '_', cursor_TAB, '_' , cursor_COL);
    SET col1 := CONCAT(cursor_COL);
    SET col2 := CONCAT(cursor_COL, '_', 'value');
    IF done THEN
        LEAVE read_loop;
    END IF;
    SET @dyn_sql := CONCAT('CREATE TABLE ',tab,' AS SELECT Codevalue as ',col1,', valueLabel as ',col2,' from valuesets14 where varName = cursor_COL and TableName = cursor_TAB;');
    PREPARE stmt_dyn_view FROM @dyn_sql;
    EXECUTE stmt_dyn_view;
    DEALLOCATE PREPARE stmt_dyn_view;
END LOOP;

Answer 2

感谢 Nigel 的想法，但是，我仍然运行遇到另一个问题，它抱怨游标变量替换

call cursor_ROWPERROW(): Error Code: 1054. Unknown column 'zzzzz' in 'where clause'

所以基本上，它无法替换游标值，所以我采用了您提到的相同方法并在文本周围加上引号，因此使用 select 查询来查看它试图生成的查询我下面 SQL 解决了我的问题。

DROP PROCEDURE IF EXISTS cursor_ROWPERROW;
DELIMITER $$
CREATE PROCEDURE cursor_ROWPERROW()
BEGIN
    DECLARE cursor_COL VARCHAR(50);
    DECLARE cursor_TAB VARCHAR(50);
    DECLARE tab VARCHAR(100);
    DECLARE col1 VARCHAR(50);
    DECLARE col2 VARCHAR(50);
    DECLARE done INT DEFAULT 0;
    DECLARE cursor_i CURSOR FOR SELECT COLUMN_NAME, TABLE_NAME FROM INFORMATION_SCHEMA.COLUMNS WHERE TABLE_SCHEMA='xxxxx' AND TABLE_NAME='yyyyy' AND COLUMN_NAME = 'zzzzz';
    DECLARE CONTINUE HANDLER FOR NOT FOUND SET done = 1;
    OPEN cursor_i;
    read_loop: LOOP
        FETCH cursor_i INTO cursor_COL, cursor_TAB;
        SET tab := CONCAT('PD', '_', cursor_TAB, '_' , cursor_COL);
        SET col1 := CONCAT(cursor_COL);
        SET col2 := CONCAT(cursor_COL, '_', 'value');
        IF done THEN
            LEAVE read_loop;
        END IF;
        SET @dyn_sql := CONCAT('CREATE TABLE ',tab,' AS SELECT Codevalue as ',col1,', valueLabel as ',col2,' from valuesets14 where varName = "',cursor_COL,'" and TableName = "',cursor_TAB,'";');
        PREPARE stmt_dyn_view FROM @dyn_sql;
        #SELECT @dyn_sql;
        EXECUTE stmt_dyn_view;
        DEALLOCATE PREPARE stmt_dyn_view;
    END LOOP;
    CLOSE cursor_i;
END;
$$

DELIMITER ;

在存储过程中替换变量和游标的问题

Issue with substituting variable and cursor in stored procedure

mysql

variables

loops

stored-procedures

cursor