Правильный способ получения выходного параметра из оператора вызова PDO

Question

Я пытаюсь получить параметр out, возвращаемый после вызова вставки. Я не могу понять, как исправить синтаксис моего PDO, чтобы он возвращал идентификатор вновь созданного раздела.

connection.php

$host = "127.0.0.1";
$db = "my_db";
$user = "root";
$pass = "";
$charset = "utf8";

$dsn = "mysql:host=$host; dbname=$db; charset=$charset";

try {
    $opt = [
        \PDO::ATTR_ERRMODE => \PDO::ERRMODE_EXCEPTION,
        \PDO::ATTR_DEFAULT_FETCH_MODE => \PDO::FETCH_ASSOC,
        \PDO::ATTR_EMULATE_PREPARES => false,
    ];

    $pdo = new \PDO($dsn, $user, $pass, $opt);
}catch(Exception $e){
    $errorMessage = $e->getMessage();
    echo "<script type='text/javascript'>alert('$errorMessage');</script>";
}

daoimpl.php

function addNewSection(Section $section)
{
    //$isSuccessful = false;
    $outSectionId = 0;

    $sectionName = $section->getSectionName();

    $this->connection->beginTransaction();
    try {
        $sp_addNewSection = $this->connection->prepare('CALL addSection(?,@outSectionId)');
        $sp_addNewSection->bind_param('s',$sectionName);
        $sp_addNewSection->execute();

        //not sure how to do it correctly here
        $select = $this->connection->prepare('SELECT @outSectionId');
        $select->execute();
        $resultSet = $select->fetchAll(PDO::FETCH_ASSOC);
        $outSectionId = $resultSet['@outSectionId'];

        $this->connection->commit();
        //$isSuccessful = true;
    } catch (PDOException $e) {
        die($e->getMessage());
        $this->connection->rollback();
    }
        //return $isSuccessful;
    return $outSectionId;
}

addSection хранимая процедура

CREATE DEFINER=`root`@`localhost` PROCEDURE `addSection`(`pSectionName` VARCHAR(255), OUT opSectionId INT)
BEGIN

INSERT INTO section(section_name)
VALUES(pSectionName);

SELECT LAST_INSERT_ID() INTO opSectionId;

SELECT opSectionId;

END

Важно, чтобы я получил значение идентификатора секции out-параметра обратно в php, потому что я буду добавлять больше запросов в блок транзакции.

Я просто не могу заставить его работать. Я могу получить sectionId, если я запускаю / вызываю хранимый процесс в MySQL Workbench, но он не работает в PHP.

Буду признателен за любую помощь.

Спасибо.

Answer 1

Попробуйте определить DELIMITER в вашей процедуре:

DELIMITER $$
CREATE DEFINER=`root`@`localhost` PROCEDURE `addSection`(`pSectionName` VARCHAR(255), OUT opSectionId INT) BEGIN
    INSERT INTO section(section_name) VALUES(pSectionName);
    SELECT LAST_INSERT_ID() INTO opSectionId;
   SELECT opSectionId;
END $$
DELIMITER ;