BulkDeletes.php

Go to the documentation of this file.

<?php
 
namespace Ubiquity\orm\bulk;
 
use Ubiquity\orm\OrmUtils;
 
class BulkDeletes extends AbstractBulks {
 
    public function addInstance($instance, $id = null) {
        $id = $id ?? OrmUtils::getFirstKeyValue ( $instance );
        $this->instances [$id] = $instance;
    }
 
    public function createSQL() {
        $quote = $this->db->quote;
        $this->parameters = \array_keys ( $this->instances );
        $count = \count ( $this->parameters );
 
        return "DELETE FROM {$quote}{$this->tableName}{$quote} WHERE {$quote}{$this->pkName}{$quote} IN (" . \implode ( ',', \array_fill ( 0, $count, '?' ) ) . ')';
    }
 
    public function groupOp($count = 5) {
        $quote = $this->db->quote;
        $groups = \array_chunk ( $this->instances, $count );
 
        $deleteTable = "DELETE FROM {$quote}{$this->tableName}{$quote} WHERE ";
        foreach ( $groups as $group ) {
            $sql = '';
            foreach ( $group as $instance ) {
                $kv = OrmUtils::getKeyFieldsAndValues ( $instance );
                $sql .= $deleteTable . $this->db->getCondition ( $kv ) . ';';
            }
            $this->execGroupTrans ( $sql );
        }
        $this->instances = [ ];
        $this->parameters = [ ];
    }
}