9

我正在编写一个存储过程，它打开一个表的游标，然后遍历所有记录。在迭代过程中，我根据第一个游标的结果创建了一个动态查询。

我需要在动态 SQL 上打开游标，但 MySQL 不允许我这样做。根据 MySQL 的官方文档：“游标必须在声明处理程序之前声明。变量和条件必须在声明游标或处理程序之前声明”。

这是脚本：

DELIMITER $$

DROP PROCEDURE IF EXISTS sp_test$$

CREATE PROCEDURE `sp_test`()
BEGIN
    -- Declarations
    
    DECLARE prepared_sql VARCHAR(1000);
    DECLARE index_count INT;

    -- Cursors
    DECLARE cursor1 CURSOR FOR SELECT * from table1;
    -- Continue Handler for Cursor
    DECLARE CONTINUE HANDLER FOR NOT FOUND SET no_more_rows = TRUE;
    -- Open cursors
    OPEN cursor1;

    -- Business Logic
    all_alerts_loop: LOOP
        -- Fetch record from cursor1 and create a dynamic sql
                
        -- Check if cursor has reached to end than leave the loop
        IF no_more_rows THEN
            LEAVE all_alerts_loop;
        END IF;
        
        
        WHILE @some_other_variable <> 0
        DO
                              -- I want to open cursor 2 on this sql
            -- set @prepared_sql =  'create dynamic sql here';  
                    END WHILE;
        
                    -- This works fine
        PREPARE stmt FROM @prepared_sql;
        EXECUTE stmt;

                    -- But can't define cursor here? so what is the solution
                    -- Gives syntax error, I have tried with @prepared_sql also rather than stmt
        DECLARE cursor2 CURSOR FOR stmt;
        
    END LOOP;
    
    -- closing cursors
    CLOSE cursor1;
    END$$

DELIMITER ;

关于如何为动态查询创建游标的任何想法？在 MySQL 中？

4

7 回答 7

9

不允许 DEFINE cur CURSOR FORprepared_statement，您必须定义有效的 SQL 语句。好消息是您可以在稍后可以动态创建的视图上定义光标。例如...

DROP PROCEDURE IF EXISTS my_dynamic_proc;
DELIMITER //
CREATE PROCEDURE my_dynamic_proc(tablename varchar(64), fieldname varchar(64), country VARCHAR(64))
BEGIN
    DECLARE adr_value varchar(500);
    DECLARE done BOOLEAN DEFAULT FALSE;
    -- Cursor definition
    DECLARE cur1 CURSOR FOR SELECT address FROM tmp_view_address;
    DECLARE CONTINUE HANDLER FOR NOT FOUND SET done = TRUE;
    -- Dynamic view definition and creation
    SET @v = concat('CREATE OR REPLACE VIEW tmp_view_address as SELECT `',fieldname,'` as address FROM ',tablename,' WHERE country_name = "',country,'" group by 1 order by count(1) desc');
    PREPARE stm FROM @v;
    EXECUTE stm;
    DEALLOCATE PREPARE stm;
    -- Open cursor
    OPEN cur1;
    read_loop: LOOP
      FETCH cur1 INTO adr_value;
      IF done THEN
        LEAVE read_loop;
      END IF;
      -- Basic output result
      SELECT concat("My address is ",adr_value);
      -- Use every result in a dynamic update
      SET @u = concat('update ',tablename,' set new_field_address = "',adr_value,'" where country_name = "',country,'" and new_field_address is null');
      PREPARE stm FROM @u;
      EXECUTE stm;
      DEALLOCATE PREPARE stm;
  END LOOP;
  CLOSE cur1;
END//
DELIMITER ;
于 2018-05-11T14:37:29.003 回答
6

创建另一个过程并在此新过程中编写游标代码，然后从您要声明游标的位置调用该过程...

于 2011-10-11T15:57:36.523 回答
1

由于您不能对游标使用动态查询，因为您不能SET在DECLARE. 你也不能使用存储CALL过程CURSOR FOR

DECLARE cursor_name CURSOR FOR select_statement

CALL不是select_statement。

作为一种解决方法：
您应该创建 3 个过程而不是仅 1 个。

  1. 临时表/视图生成器
    编写一个存储过程来为您的动态查询生成临时表或视图。
  2. 计算结果
    您当前的过程将使用CURSOR FOR SELECT FROM临时表。但是您应该确保首先运行临时表/视图过程 - 以获得更新的结果。并且您不能在光标CALL之前执行程序。DECLARE这就是您需要第三步的原因。
  3. 一起运行生成临时表/视图的过程 的最终存储过程CALL，然后CALL是计算结果的预期过程。您最终应该使用最后一个过程作为执行结果的过程。
于 2015-03-31T04:50:37.230 回答
0

我在您的脚本中看到 2 个可能的问题：

1)“声明游标2 CURSOR FOR stmt;” 可能需要与所有其他声明一起移动到过程的顶部，在任何可执行语句之前。

2）游标不能基于动态SQL（即我认为你不能在准备好的语句上构建它）。要解决此限制，您可以基于视图声明游标，然后在打开游标之前使用动态 SQL 创建视图。这种方法的问题是视图是公共的——游标声明必须有一个固定的视图名称，因此多个并发用户可能会无意中看到其他人动态定义的视图。我的解决方法是检查视图是否存在并延迟执行过程，直到视图被删除。这意味着为了在繁忙的环境中可行，您应该创建视图，遍历光标，然后尽快放下视图。在技​​术上并不优雅，但这种方法在我的低流量情况下有效，并避免临时表的开销。或者，正如其他人所建议的那样，临时表是线程安全的，但可能会影响性能。

于 2013-02-01T15:59:45.400 回答
0

karni 的方法不那么麻烦。创建两个或多个 SP 以满足每个条件分支（每个条件分支都需要动态 sql）。创建一个包装器 SP 并将此 SP 的调用扇出到“分支”SP。

另一种方法是“准备好的视图”方法，在运行过程时需要更多的 CPU 周期和内存以及额外的磁盘空间。

于 2014-07-20T01:09:53.067 回答
0

这个线程对我帮助很大，所以这是我关于如何使用一个表中的值通过查询迭代它并存储到第二个表或视图的答案。

DROP PROCEDURE IF EXISTS my_dynamic_proc;

DELIMITER //
CREATE PROCEDURE my_dynamic_proc()
BEGIN
    DECLARE Surname varchar(255);
    DECLARE done BOOLEAN DEFAULT FALSE;
    -- Cursor definition
    DECLARE cur1 CURSOR FOR SELECT distinct Surname_values FROM some_clientdata_table;
    DECLARE CONTINUE HANDLER FOR NOT FOUND SET done = TRUE;
    -- Open cursor
    OPEN cur1;
    read_loop: LOOP
      FETCH cur1 INTO Surname;
      IF done THEN
        LEAVE read_loop;
      END IF;
      -- Use every result in a dynamic update
    INSERT into new_table (column1, column2, column3) 
    -- here is jus an example of query that I am using to loop Surname through. Query calculates days between orders
    SELECT T.Surname, T.Date, IFNULL(datediff(T.Date,(select MAX(TT.Date) as days from some_invoicedata_table TT where TT.Date < T.Date and TT.Surname = Surname)),0) from some_invoicedata_table T where T.Surname = Surname;
    -- Note how Surname value is used in WHERE statement to iterate each value through query in stored procedure.
    END LOOP;
  CLOSE cur1;
END//
DELIMITER ;

call my_dynamic_proc();
于 2020-12-06T05:57:05.120 回答
0

我们可以考虑使用以下方法解决这种情况stmt：

  1. 统计查询将返回的所有记录

  2. 循环并浏览查询返回的每条记录，为此使用限制。

请参见下面的示例：

CREATE PROCEDURE `proc_example`(IN p_where text)
BEGIN

    DECLARE v_where text default "";
    DECLARE v_cont integer default 0;
    
    #build a dynamic where
    set v_where = p_where;
    
    #Count query records 
    set @v_sqlSelect_count = 'select count(*) into @v_total ';
    set @v_sqlSelect_count = concat(@v_sqlSelect_count,'from table ');
    set @v_sqlSelect_count = concat(@v_sqlSelect_count,'where ');
    set @v_sqlSelect_count = concat(@v_sqlSelect_count,v_where);
    
    #Executa query
    PREPARE stmt_total FROM @v_sqlSelect_count;
    EXECUTE stmt_total;
    DEALLOCATE PREPARE stmt_total;
    
    #if exists records
    if (@v_total > 0) then
        
        set v_cont = 0;
        
        navRecords:loop
        
            if (v_cont > (@v_total - 1)) then
                leave getAgend;
            end if;
            
            #build select
            set @v_sqlSelect = 'select id,name ';
            set @v_sqlSelect = concat(@v_sqlSelect,'into @id,@name ');
            set @v_sqlSelect = concat(@v_sqlSelect,'from table ');
            set @v_sqlSelect = concat(@v_sqlSelect,'where ');
            set @v_sqlSelect = concat(@v_sqlSelect,v_where);
            set @v_sqlSelect = concat(@v_sqlSelect,' order by id asc limit ',v_cont,',1'); 
            
            #Execute query
            PREPARE stmt_select FROM @v_sqlSelect;
            EXECUTE stmt_select;
            DEALLOCATE PREPARE stmt_select;   
            
            #Do anything with the data @id, @name
            update table1 set desc1 = @name where id1 = @id;
            
            #Next record
            set v_cont = v_cont + 1;
            
        end loop navRecords;
        
    end if;

END
于 2021-02-18T01:03:18.463 回答