如何调用另一个存储过程中的存储过程(PHP和mysqli的)(How to call a store

2019-10-30 10:54发布

我奋力调用另一个存储过程中的存储过程。 就像是现在的存储过程从来没有作为一个结果返回SELECT语句回在PHP中的mysqli通话(但在MySQL工作台工作正常)。

DELIMITER $$

CREATE DEFINER=`root`@`localhost` PROCEDURE `new_bid`(IN bid_in decimal(6,2),
                                                      IN ticker_in varchar(5),
                                                      IN share_amount_in BIGINT)
BEGIN

    DECLARE company_id_var INT;
    DECLARE highest_bid BIT;
    DECLARE generated_bid_id BIGINT;

    SET company_id_var = (SELECT ID
                      FROM Companies
                      WHERE Ticker = ticker_in);

    -- Put the bid into the Bids table.
    INSERT INTO Bids(company_id,bid,share_amount)
    VALUES (company_id_var,bid_in,share_amount_in);

    SET generated_bid_id = LAST_INSERT_ID();

    CALL check_available_shares(bid_in,share_amount_in,generated_bid_id,@shares_left);

    -- Check if the bid is higher than the current highest bid.
    -- If so update the CurrentState table to have the new value.
    UPDATE CurrentState SET buyer = bid_in
                        WHERE ID = company_id_var
                        AND buyer < bid_in;

    IF (ROW_COUNT() = 1)
     THEN
     SELECT 1 AS highest_bid, @shares_left AS shares_left, CS.buyer, CS.seller, CS.last_price, CO.name,  CO.ticker
     FROM CurrentState CS, Companies CO
     WHERE CS.id = CO.id
     AND CO.ticker = ticker_in;
    ELSE
     SELECT 0 AS highest_bid, @shares_left AS shares_left, CS.buyer, CS.seller, CS.last_price, CO.name,  CO.ticker
     FROM CurrentState CS, Companies CO
     WHERE CS.id = CO.id
     AND CO.ticker = ticker_in;
    END IF;
END

如果我从这个存储过程删除“CALL”功能,它会返回在底部的SELECT语句之一,但如果我把“CALL”功能,它不返回任何东西。 我曾尝试与exec和执行,但只有当我试图挽救MySQL工作台内的程序给我语法错误。 这个问题涉及到https://stackoverflow.com/questions/23193085/mysqli-does-not-return-any-results-but-stored-procedure-does 。 但似乎这个问题可能涉及到的mysqli如何处理存储过程的执行,因为当我打电话的MySQL工作台手动存储过程,它工作正常(?)

Answer 1:

后敲我的头在墙上的小时里,我找到了解决办法。 由于此存储过程调用它使用游标我只好用另一个存储过程$mysqli->multi_query()函数。 以下是我得到它的工作:

NEW_BID存储过程:

-- --------------------------------------------------------------------------------
-- Routine DDL
-- Note: comments before and after the routine body will not be stored by the server
-- --------------------------------------------------------------------------------
DELIMITER $$

CREATE DEFINER=`root`@`localhost` PROCEDURE `new_bid`(IN bid_in decimal(6,2),
                                                      IN ticker_in varchar(5),
                                                      IN share_amount_in BIGINT)
BEGIN

    -- Store the company ID into a variable as this value will used more than once.
    DECLARE company_id_var INT;
    DECLARE ParamtoPass INT;
    DECLARE highest_bid BIT;
    DECLARE generated_bid_id BIGINT;

    SET company_id_var = (SELECT ID
                      FROM Companies
                      WHERE Ticker = ticker_in);

    -- Put the bid into the Bids table.
    INSERT INTO Bids(company_id,bid,share_amount)
    VALUES (company_id_var,bid_in,share_amount_in);

    SET generated_bid_id = LAST_INSERT_ID();
    -- EXECUTE check_available_shares bid_in, @share_amount_in,@generated_bid_id,@shares_left;
    CALL check_available_shares (bid_in,@share_amount_in,generated_bid_id,@shares_left);

    -- Check if the bid is higher than the current highest bid.
    -- If so update the CurrentState table to have the new value.
    UPDATE CurrentState SET buyer = bid_in
                        WHERE ID = company_id_var
                        AND buyer < bid_in;

    IF (ROW_COUNT() = 1)
     THEN
     SELECT 1 AS highest_bid, @shares_left AS shares_left, CS.buyer, CS.seller, CS.last_price, CO.name,  CO.ticker
     FROM CurrentState CS, Companies CO
     WHERE CS.id = CO.id
     AND CO.ticker = ticker_in;
    ELSE
     SELECT 0 AS highest_bid, @shares_left AS shares_left, CS.buyer, CS.seller, CS.last_price, CO.name,  CO.ticker
     FROM CurrentState CS, Companies CO
     WHERE CS.id = CO.id
     AND CO.ticker = ticker_in;
    END IF;
END

check_available_shares过程:

-- --------------------------------------------------------------------------------
-- Routine DDL
-- Note: comments before and after the routine body will not be stored by the server
-- --------------------------------------------------------------------------------
DELIMITER $$

CREATE DEFINER=`root`@`localhost` PROCEDURE `check_available_shares`(IN bid_in decimal(6,2),
                                                                     IN share_amount_in int,
                                                                     IN bid_id bigint,
                                                                     OUT shares_left BIT)
BEGIN
    DECLARE num_shares INT;
    DECLARE selling_id INT;
    DECLARE selling_price DECIMAL(6,2);
    DECLARE done INT DEFAULT FALSE;

    DECLARE cur CURSOR FOR SELECT share_amount,sell_price,ID
                           FROM ShareSell
                           WHERE sell_price <= bid_in
                           ORDER BY sell_price ASC, sell_timestamp ASC;

    DECLARE CONTINUE HANDLER FOR NOT FOUND SET done = TRUE;

    OPEN cur;   /* open cursor */

    read_loop: LOOP
        FETCH NEXT FROM cur
                   INTO num_shares, selling_price, selling_id;

        IF (done) THEN
            LEAVE read_loop;
        END IF;

        IF ((share_amount_in - num_shares) > 0) THEN
            SET share_amount_in = (share_amount_in - num_shares);

            DELETE FROM ShareSell
                   WHERE ID = selling_id;
        ELSEIF((share_amount_in - num_shares) < 0) THEN
            UPDATE ShareSell
            SET share_amount = (share_amount - share_amount_in)
            WHERE ID = selling_id;

            DELETE FROM Bids
            WHERE ID = bid_id;

            LEAVE read_loop;
        ELSE
            DELETE FROM ShareSell
                   WHERE ID = selling_id;

            DELETE FROM Bids
                   WHERE ID = bid_id;
        END IF;

        SELECT num_shares,selling_price;
    END LOOP;

    CLOSE cur;

    IF (share_amount_in > 0) THEN
        UPDATE Bids
        SET share_amount = share_amount_in
        WHERE ID = bid_id;
        SET shares_left = 1;
    ELSE
        SET shares_left = 0;
    END IF;
END

最后是PHP电话:

$bid = 43.10;
$ticker = "GOS";
$share_amount = 1000;

if ($mysqli->multi_query("CALL new_bid($bid,'$ticker',$share_amount)"))
{
 if ($result = $mysqli->store_result())
 {
   while ($row = $result->fetch_assoc())
   {
     print_r($row);
   }

   $result->close();
 }
}


Answer 2:

谢谢! 这正是我的问题太多。 我也打破了一个确切的类似的问题,我的头(见调用存储过程时,PHP的mysqli没有捕捉一些错误 )。 您的文章帮我解决我的问题!

我也曾经有过的PHP调用SP1,而这又被称为SP2,一切都在一个MySQL客户端工作正常,但在被称为PHP打破的情况下! 事实上,我也曾经有过一个SELECT在SP2中的结果集的。 我的问题症状完全相同你的,它从来没有让我吃惊使用multi_query()

我注意到,您还可以选择在“结果集* check_available_shares (见行SELECT num_shares,selling_price;不知道为什么你有这样的行如果删除该行,我怀疑你应该能够做一个query()代替的multi_query()



文章来源: How to call a stored procedure within another stored procedure (PHP and mysqli)