如何循环遍历表的所有行？ (MySQL)

Question

我有一张表 A，并且有一个主键 ID。

现在我想遍历 A 中的所有行。

我发现了类似“针对 A 中的每条记录”的内容，但这似乎不是您在 MySQL 中的做法。

事情是对于我想要获取一个字段并对其进行转换的每一行，将其插入另一个表中，然后更新该行的一些字段。我可以将选择部分和插入放在一个语句中，但我也不知道如何在其中获取更新。所以我想循环。为了练习，我不想使用 MySQL 以外的任何东西。

编辑

我会很感激一个例子。

还有一个不需要放入程序的解决方案。

编辑 2

好吧，想想这个场景：

表 A 和 B，每个都有字段 ID 和 VAL。

现在这是我想做的伪代码：

for(each row in A as rowA)
{
  insert into B(ID, VAL) values(rowA[ID], rowA[VAL]);
}

基本上使用循环将 A 的内容复制到 B 中。

（这只是一个简化的例子，当然你不会为此使用循环。） }

Answer 1

由于循环的建议意味着对过程类型解决方案的请求。这是我的。

对从表中提取的任何单个记录起作用的任何查询都可以包装在一个过程中，使其遍历表的每一行，如下所示：

首先删除任何现有的同名过程，并更改分隔符，这样您的 SQL 就不会在您尝试编写过程时尝试运行每一行。

DROP PROCEDURE IF EXISTS ROWPERROW;
DELIMITER ;;

那么这里是按照你的例子的过程（table_A 和 table_B 用于清楚）

CREATE PROCEDURE ROWPERROW()
BEGIN
DECLARE n INT DEFAULT 0;
DECLARE i INT DEFAULT 0;
SELECT COUNT(*) FROM table_A INTO n;
SET i=0;
WHILE i<n DO 
  INSERT INTO table_B(ID, VAL) SELECT (ID, VAL) FROM table_A LIMIT i,1;
  SET i = i + 1;
END WHILE;
End;
;;

然后别忘了重置分隔符

DELIMITER ;

然后运行新程序

CALL ROWPERROW();

您可以在“INSERT INTO”行中做任何您想做的事情，我只是从您的示例请求中复制了该行。

请注意，此处使用的“INSERT INTO”行反映了问题中的行。根据这个答案的 cmets，您需要确保您的查询对于您正在运行的任何 SQL 版本在语法上都是正确的。

在您的 ID 字段递增并从 1 开始的简单情况下，示例中的行可能变为：

INSERT INTO table_B(ID, VAL) VALUES(ID, VAL) FROM table_A WHERE ID=i;

将“SELECT COUNT”行替换为

SET n=10;

将让您仅在 table_A 中的前 10 条记录上测试您的查询。

最后一件事。这个过程也很容易嵌套在不同的表中，并且是我可以在一个表上执行一个过程的唯一方法，该过程将不同数量的记录从父表的每一行动态插入到一个新表中。

如果您需要它运行得更快，那么请务必尝试使其基于设置，如果不是那么这很好。 您也可以以光标形式重写上述内容，但可能不会提高性能。例如：

DROP PROCEDURE IF EXISTS cursor_ROWPERROW;
DELIMITER ;;

CREATE PROCEDURE cursor_ROWPERROW()
BEGIN
  DECLARE cursor_ID INT;
  DECLARE cursor_VAL VARCHAR;
  DECLARE done INT DEFAULT FALSE;
  DECLARE cursor_i CURSOR FOR SELECT ID,VAL FROM table_A;
  DECLARE CONTINUE HANDLER FOR NOT FOUND SET done = TRUE;
  OPEN cursor_i;
  read_loop: LOOP
    FETCH cursor_i INTO cursor_ID, cursor_VAL;
    IF done THEN
      LEAVE read_loop;
    END IF;
    INSERT INTO table_B(ID, VAL) VALUES(cursor_ID, cursor_VAL);
  END LOOP;
  CLOSE cursor_i;
END;
;;

请记住将您将使用的变量声明为与查询表中的变量相同的类型。

我的建议是尽可能使用基于集合的查询，并且仅在必要时使用简单的循环或游标。

Answer 2

您应该真正使用涉及两个查询的基于集合的解决方案（基本插入）：

INSERT INTO TableB (Id2Column, Column33, Column44)
SELECT id, column1, column2 FROM TableA

UPDATE TableA SET column1 = column2 * column3

为了你的转变：

INSERT INTO TableB (Id2Column, Column33, Column44)
SELECT 
    id, 
    column1 * column4 * 100, 
    (column2 / column12) 
FROM TableA

UPDATE TableA SET column1 = column2 * column3

现在，如果您的转换比这更复杂并且涉及多个表，请发布另一个包含详细信息的问题。

Answer 3

CURSORS 是这里的一个选项，但通常不受欢迎，因为它们通常不能充分利用查询引擎。考虑调查“基于 SET 的查询”，看看您是否可以在不使用 CURSOR 的情况下实现您想要做的事情。

Answer 4

Purple 先生的例子我在 mysql 触发器中使用的那样，

begin
DECLARE n INT DEFAULT 0;
DECLARE i INT DEFAULT 0;
Select COUNT(*) from user where deleted_at is null INTO n;
SET i=0;
WHILE i<n DO 
  INSERT INTO user_notification(notification_id,status,userId)values(new.notification_id,1,(Select userId FROM user LIMIT i,1)) ;
  SET i = i + 1;
END WHILE;
end

Answer 5

    Use this:

    $stmt = $user->runQuery("SELECT * FROM tbl WHERE ID=:id");
    $stmt->bindparam(":id",$id);
    $stmt->execute();

        $stmt->bindColumn("a_b",$xx);
        $stmt->bindColumn("c_d",$yy);


    while($rows = $stmt->fetch(PDO::FETCH_BOUND))
    {
        //---insert into new tble
    }