Ubiquity\orm\bulk\BulkInserts

Complexity

Total Complexity

8

Size/Duplication

Total Lines	44
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes	3
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	2
A	addInstance()	0	4	1
A	createSQL()	0	12	2
A	groupOp()	0	14	3

<?php

namespace Ubiquity\orm\bulk;

/**
 * Ubiquity\orm\bulk$BulkInserts
 * This class is part of Ubiquity
 *
 * @author jcheron <myaddressmail@gmail.com>
 * @version 1.0.1
 *
 */
class BulkInserts extends AbstractBulks {

	public function __construct($className) {
		parent::__construct ( $className );
		if (($key = \array_search ( $this->pkName, $this->fields )) !== false) {
			unset ( $this->fields [$key] );
		}
		$this->insertFields = \implode ( ',', $this->getQuotedKeys ( $this->fields, $this->db->quote ) );
	}

	public function addInstance($instance, $id = null) {
		$this->updateInstanceRest ( $instance );
		unset ( $instance->_rest [$this->pkName] );
		$this->instances [] = $instance;
	}

	public function createSQL() {
		$quote = $this->db->quote;
		$fieldCount = \count ( $this->fields );
		$parameters = [ ];
		$values = [ ];
		$modelFields = '(' . \implode ( ',', \array_fill ( 0, $fieldCount, '?' ) ) . ')';
		foreach ( $this->instances as $instance ) {
			$parameters = \array_merge ( $parameters, \array_values ( $instance->_rest ) );
			$values [] = $modelFields;
		}
		$this->parameters = $parameters;
		return "INSERT INTO {$quote}{$this->tableName}{$quote} (" . $this->insertFields . ') VALUES ' . \implode ( ',', $values );
	}

	public function groupOp($count = 5) {
		$quote = $this->db->quote;
		$groups = \array_chunk ( $this->instances, $count );

		$insertTable = "INSERT INTO {$quote}{$this->tableName}{$quote} (" . $this->insertFields . ') VALUES(';
		foreach ( $groups as $group ) {
			$sql = '';
			foreach ( $group as $instance ) {
				$sql .= $insertTable . $this->db->getInsertValues ( $instance->_rest ) . ');';
			}
			$this->execGroupTrans ( $sql );
		}
		$this->instances = [ ];
		$this->parameters = [ ];
	}
}