Zortje\MySQLKeeper\Database\TableFactory

Complexity

Total Complexity

5

Size/Duplication

Total Lines	59
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	5

Test Coverage

Coverage

100%

Importance

Changes	7
Bugs	0	Features	1

1 Method

Rating	Name	Duplication	Size	Complexity
B	create()	0	48	5

<?php

namespace Zortje\MySQLKeeper\Database;

use Zortje\MySQLKeeper\Database\Table\Column;
use Zortje\MySQLKeeper\Database\Table\ColumnCollection;
use Zortje\MySQLKeeper\Database\Table\Index;
use Zortje\MySQLKeeper\Database\Table\IndexCollection;

/**
 * Class TableFactory
 *
 * @package Zortje\MySQLKeeper\Database
 */
class TableFactory {

	/**
	 * Create table
	 *
	 * @param string $tableName Table name
	 * @param \PDO   $pdo       Database connection
	 *
	 * @return Table
	 */
	public static function create($tableName, \PDO $pdo) {
		/**
		 * Table
		 */
		$result = $pdo->query("SHOW TABLE STATUS LIKE '$tableName';");

		if ($result->rowCount() !== 1) {
			throw new \InvalidArgumentException(sprintf('Table %s was not found', $tableName));
		}

		$tableRow = $result->fetch();

		/**
		 * Columns
		 */
		$columns = new ColumnCollection();

		foreach ($pdo->query("SHOW FULL COLUMNS FROM `$tableName`;") as $row) {
			$column = new Column($row);

			$columns->add($column);
		}

		/**
		 * Indices
		 */
		$indexRows = [];

		foreach ($pdo->query("SHOW INDEX FROM `$tableName`;") as $row) {
			$indexRows[$row['Key_name']]['unique']        = $row['Non_unique'] === '0';
			$indexRows[$row['Key_name']]['columnNames'][] = $row['Column_name'];
		}

		$indices = new IndexCollection();

		foreach ($indexRows as $keyName => $indexArray) {
			$index = new Index($keyName, $indexArray['unique'], $indexArray['columnNames']);

			$indices->add($index);
		}

		/**
		 * Initialization
		 */
		$table = new Table($tableName, $tableRow['Collation'], $columns, $indices);

		return $table;
	}
}