sql >> Database teknologi >  >> RDS >> Mysql

PDO - Indsæt stort array til MySQL-database

Selvom jeg stadig tvivler på, at transaktioner og/eller batch-indlæg er en levedygtig løsning på dit ressourceforbrugsproblem, er de stadig en bedre løsning end at forberede massive erklæringer, som Dave har foreslået.

Giv dem en chance og se, om de hjælper.

Det følgende antager, at PDO's fejlhåndteringstilstand er indstillet til at kaste undtagelser. F.eks.:$db->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); Hvis du af en eller anden grund ikke kan bruge undtagelsestilstand, skal du kontrollere returneringen af ​​execute() hver gang og smid din egen Undtagelse.

Enkelt transaktion:

$sql = $db->prepare("INSERT INTO players (name, level, vocation, world, month, today, online) VALUES (:name, :level, :vocation, :world, :time, :time, :online) ON DUPLICATE KEY UPDATE level = :level, vocation = :vocation, world = :world, month = month + :time, today = today + :time, online = :online");

$db->beginTransaction();
try {
    foreach ($players as $player) {
        $sql->execute([
            ":name" => $player->name,
            ":level" => $player->level,
            ":vocation" => $player->vocation,
            ":world" => $player->world,
            ":time" => $player->time,
            ":online" => $player->online
        ]);
    }
    $db->commit();
} catch( PDOException $e ) {
    $db->rollBack();
    // at this point you would want to implement some sort of error handling
    // or potentially re-throw the exception to be handled at a higher layer
}

Batchtransaktioner:

$batch_size = 1000;
for( $i=0,$c=count($players); $i<$c; $i+=$batch_size ) {
    $db->beginTransaction();
    try {
        for( $k=$i; $k<$c && $k<$i+$batch_size; $k++ ) {
            $player = $players[$k];
            $sql->execute([
                ":name" => $player->name,
                ":level" => $player->level,
                ":vocation" => $player->vocation,
                ":world" => $player->world,
                ":time" => $player->time,
                ":online" => $player->online
            ]);
        }
    } catch( PDOException $e ) {
        $db->rollBack();
        // at this point you would want to implement some sort of error handling
        // or potentially re-throw the exception to be handled at a higher layer
        break;
    }
    $db->commit();
}


  1. gemmer MySQL-indstillinger

  2. DECOMPOSE() Funktion i Oracle

  3. Mysql:Find rækker, hvor kolonneværdien slutter med en bestemt understreng

  4. JSON_INSERT() vs JSON_SET() vs JSON_REPLACE() i SQLite