sql >> Databáze >  >> RDS >> Mysql

jak načíst sadu více výsledků z uložené procedury mysql v laravel

Používám následující kód a funguje to bezchybně. Změňte jej podle svých potřeb.

public static function CallRaw($procName, $parameters = null, $isExecute = false)
{
    $syntax = '';
    for ($i = 0; $i < count($parameters); $i++) {
        $syntax .= (!empty($syntax) ? ',' : '') . '?';
    }
    $syntax = 'CALL ' . $procName . '(' . $syntax . ');';

    $pdo = DB::connection()->getPdo();
    $pdo->setAttribute(\PDO::ATTR_EMULATE_PREPARES, true);
    $stmt = $pdo->prepare($syntax,[\PDO::ATTR_CURSOR=>\PDO::CURSOR_SCROLL]);
    for ($i = 0; $i < count($parameters); $i++) {
        $stmt->bindValue((1 + $i), $parameters[$i]);
    }
    $exec = $stmt->execute();
    if (!$exec) return $pdo->errorInfo();
    if ($isExecute) return $exec;

    $results = [];
    do {
        try {
            $results[] = $stmt->fetchAll(\PDO::FETCH_OBJ);
        } catch (\Exception $ex) {

        }
    } while ($stmt->nextRowset());


    if (1 === count($results)) return $results[0];
    return $results;
}

Příklad volání:

$params = ['2014-01-01','2014-12-31',100];
$results = APIDB::CallRaw('spGetData',$params);

Výsledné volání bude:

CALL spGetData(?,?,?)

Pokud existuje pouze jedna sada výsledků, bude vrácena tak, jak je. Pokud je jich více, vrátí pole sad výsledků. Klíč používá $pdo->setAttribute(\PDO::ATTR_EMULATE_PREPARES, true); . Bez ní dojde k příšernému SQLSTATE[HY000]: General error: 2053 bude vyvolána výjimka.

Blok try{} catch() se používá k odstranění sad výsledků, které nelze načíst. Konkrétně mám procedury, které vrací dvě sady výsledků, jednu jako výsledek aktualizace (nebo jiných příkazů k provedení) a poslední jako skutečná data. Výjimka vyvolaná při fetchAll() s prováděcím dotazem bude PDOException .

Upozornění:funkce není optimalizována. Můžete jej přepsat jediným průchodem parametry.



  1. Migrace problémů a otázek MySQL UTF8 na UTF8MB4

  2. Vyberte dotaz pomocí IN() a bez jakéhokoli řazení

  3. Příklady MySQL SOUNDEX().

  4. Jak povolit INNODB v mysql