Doctrine 原生SQL与存储过程调用：弃用方法替代方案详解

use Doctrine\ORM\EntityManagerInterface;

class MyRepository
{
    private $entityManager;

    public function __construct(EntityManagerInterface $entityManager)
    {
        this->entityManager = $entityManager;
    }

    public function callStoredProcedureDeprecated(string $param): array
    {
        $sql = 'CALL spWithParams(:param)';
        // prepare() 和 execute() 已弃用，fetchAllAssociative() 也已弃用
        $stmt = $this->entityManager->getConnection()->prepare($sql);
        $stmt->execute([":param" => $param]);
        return $stmt->fetchAllAssociative(); // 返回关联数组
    }
}

<?php

namespace App\Repository;

use Doctrine\ORM\EntityManagerInterface;
use Doctrine\ORM\Query\ResultSetMapping;

class MyRepository
{
    private $entityManager;

    public function __construct(EntityManagerInterface $entityManager)
    {
        $this->entityManager = $entityManager;
    }

    /**
     * 调用存储过程并获取标量结果。
     *
     * @param string $param 存储过程参数
     * @return array 返回一个包含关联数组的结果集
     */
    public function callStoredProcedure(string $param): array
    {
        // 1. 定义结果集映射
        // ResultSetMapping 允许我们定义如何将数据库返回的列映射到PHP数组的键。
        // addScalarResult('数据库列名', 'PHP数组键名')
        // 例如，如果存储过程返回一个名为 'my_database_column' 的列，
        // 我们希望在PHP数组中以 'myField' 作为键访问它。
        $rsm = new ResultSetMapping();
        $rsm->addScalarResult('my_database_column', 'myField');
        // 如果存储过程返回多个列，可以多次调用 addScalarResult
        // $rsm->addScalarResult('another_db_column', 'anotherField');

        // 2. 创建原生查询
        // createNativeQuery 方法接受 SQL 语句和 ResultSetMapping 对象。
        // 这将创建一个 Doctrine\ORM\NativeQuery 对象。
        $query = $this->entityManager->createNativeQuery(
            'CALL spWithParams(:param)', // 您的原生SQL或存储过程调用语句
            $rsm
        );

        // 3. 设置查询参数
        // 使用 setParameters 方法安全地绑定参数，防止SQL注入。
        $query->setParameters([
            ':param' => $param // 将 PHP 变量绑定到 SQL 中的 :param 占位符
        ]);

        // 4. 获取结果
        // getArrayResult() 方法执行查询并返回一个包含关联数组的数组。
        // 每个内部数组代表一行结果，键名是您在 addScalarResult 中定义的 PHP 键名。
        $results = $query->getArrayResult();

        /*
         * $results 的预期结构示例:
         * [
         *   ['myField' => 'foo'],
         *   ['myField' => 'bar']
         * ]
         */

        return $results;
    }
}