ElkArte\Database\AbstractQuery::prepareInsert()

Complexity

Conditions	6
Paths	13

Size

Total Lines	44
Code Lines	18

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	1
CRAP Score	30.1171

Importance

Changes

0

<?php
	protected function prepareInsert($table, $columns, $data)
	{
		// With nothing to insert, simply return.
		if (empty($data))
		{
			throw new \Exception('No data to insert');
		}

		// Inserting data as a single row can be done as a single array.
		if (!is_array($data[array_rand($data)]))
		{
			$data = [$data];
		}

		// Replace the prefix holder with the actual prefix.
		$table = str_replace('{db_prefix}', $this->_db_prefix, $table);
		$this->_skip_error = $table === $this->_db_prefix . 'log_errors';

		// Create the mold for a single row insert.
		$insertData = '(';
		foreach ($columns as $columnName => $type)
		{
			// Are we restricting the length?
			if (strpos($type, 'string-') !== false)
			{
				$insertData .= sprintf('SUBSTRING({string:%1$s}, 1, ' . substr($type, 7) . '), ', $columnName);
			}
			else
			{
				$insertData .= sprintf('{%1$s:%2$s}, ', $type, $columnName);
			}
		}
		$insertData = substr($insertData, 0, -2) . ')';

		// Create an array consisting of only the columns.
		$indexed_columns = array_keys($columns);

		// Here's where the variables are injected to the query.
		$insertRows = [];
		foreach ($data as $dataRow)
		{
			$insertRows[] = $this->quote($insertData, $this->_array_combine($indexed_columns, $dataRow));
		}
		return [$table, $indexed_columns, $insertRows];
	}