1

我已经在 Google 上搜索了一段时间,我确信问题在于我不清楚 MySQL 中的 CURSOR 是如何工作的。

问题的简短解释:我正在编写这样的函数(简化):

CREATE DEFINER=`me`@`localhost` FUNCTION `product_move`(prID INT, tr_type VARCHAR(2), clID INT, am INT, dnID INT, usrID INT, price FLOAT(10,2), ti DATETIME, barc TINYTEXT, cmt TINYTEXT, lnID INT)
BEGIN
    DECLARE done INT DEFAULT FALSE;
    DECLARE cur_id INT;
    DECLARE net_pr FLOAT(10,2);
    DECLARE cur_r INT;
    DECLARE remaind INT DEFAULT 0;
    DECLARE avg_price FLOAT(10,2) DEFAULT 0;
    DECLARE curs CURSOR FOR SELECT  `products_transactionsID`,
                                                `price`,
                                                `remains`
                                        FROM `products_transactions`
                                        WHERE `productID`=prID AND `remains`>0 AND `type`='V'
                                        ORDER BY `products_transactionsID` ASC;
DECLARE CONTINUE HANDLER FOR NOT FOUND SET done = TRUE;
 OPEN curs;
           SET remaind=am;
           read_loop:LOOP
                FETCH curs INTO cur_id,net_pr,cur_r;
                 IF done THEN
                  LEAVE read_loop;
                END IF;
                IF (cur_r>=remaind) THEN
                    SET avg_price = avg_price + (net_pr * remaind);
                    UPDATE `products_transactions` SET `remains`=`remains`-remaind WHERE products_transactionsID=cur_id;
                    LEAVE read_loop;
                ELSE

                    SET avg_price = avg_price + (net_pr * cur_r);
                    SET remaind=remaind-cur_r;
                    UPDATE `products_transactions` SET `remains`=0 WHERE products_transactionsID=cur_id;
                END IF;
           END LOOP;

CLOSE curs;
           SET avg_price=avg_price/am;
 INSERT INTO products_transactions
                       (`products_transactionsID`,`clientID`,`date_created`,`delivery_notesID`,`type`,`productID`,`amountIN`,`amountOUT`,`barcodes`,`in_stock`,`out_stock`,`out_repair`,`out_loss`,`booked`,`ordered`,`userID`,`price`,`comments`,`fifo_buy_price`)
                   SELECT NULL, clID, ti, dnID , tr_type, prID, 0, am, barc, products_transactions.in_stock-am, products_transactions.out_stock,
                       products_transactions.out_repair, products_transactions.out_loss, products_transactions.booked, products_transactions.ordered,usrID,price,cmt,avg_price
                   FROM
                       products_transactions WHERE productID=prID ORDER BY products_transactionsID DESC LIMIT 1;

因此,我们在此表中插入一个新行,基于先前选择的行的一些计算并同时更新这些行。

问题出在avg_price变量上,它应该根据net_pr从游标中获取的变量来计算。但不知何故,该net_pr变量不是从 SELECT 中获取,而是采用price我的函数的输入参数的值!这怎么可能?

到目前为止,我的猜测是:

  • 变量名冲突?搜索了代码,但我找不到任何东西。

  • 更新 LOOP 中的表会使 CURSOR 失去其位置?这是有道理的,但这也不会导致这种情况......

我很欣赏任何想法。

4

1 回答 1

2

我可以看到两件事:

1)不要更新您在游标中使用的表。MySQL说游标是只读的,但我不相信这一点。设置您的值,退出游标,然后更新表。

2)对proc定义中的变量和select中的列使用相同的名称会产生冲突:http ://dev.mysql.com/doc/refman/5.0/en/local-variable-scope.html

“局部变量不应与表列同名。如果 SQL 语句(例如 SELECT ... INTO 语句)包含对列的引用和已声明的同名局部变量,则 MySQL 当前解释引用作为变量的名称。”

于 2012-11-23T14:18:23.003 回答