Ubiquity\orm\bulk\BulkDeletes

Complexity

Total Complexity

5

Size/Duplication

Total Lines	30
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	2
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	createSQL()	0	6	1
A	addInstance()	0	3	1
A	groupOp()	0	15	3

<?php

namespace Ubiquity\orm\bulk;

use Ubiquity\orm\OrmUtils;

/**
 * Ubiquity\orm\bulk$BulkDeletes
 * This class is part of Ubiquity
 *
 * @author jcheron <myaddressmail@gmail.com>
 * @version 1.0.0
 *
 */
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 = [ ];
	}
}