Code Coverage for /Users/gregor/PhpstormProjects/siesta/src/Siesta/Driver/MySQL/MetaData/MySQLTable.php

	Code Coverage
	Classes and Traits			Functions and Methods				Lines
Total	0.00% covered (danger)	0.00%	0 / 1	92.31% covered (success)	92.31%	12 / 13	CRAP	93.59% covered (success)	93.59%	73 / 78
MySQLTable	0.00% covered (danger)	0.00%	0 / 1	92.31% covered (success)	92.31%	12 / 13	31.25	93.59% covered (success)	93.59%	73 / 78
__construct				100.00% covered (success)	100.00%	1 / 1	1	100.00% covered (success)	100.00%	9 / 9
getName				100.00% covered (success)	100.00%	1 / 1	1	100.00% covered (success)	100.00%	1 / 1
getColumnList				100.00% covered (success)	100.00%	1 / 1	1	100.00% covered (success)	100.00%	1 / 1
getColumnByName				100.00% covered (success)	100.00%	1 / 1	3	100.00% covered (success)	100.00%	4 / 4
getConstraintList				100.00% covered (success)	100.00%	1 / 1	1	100.00% covered (success)	100.00%	1 / 1
getIndexList				100.00% covered (success)	100.00%	1 / 1	1	100.00% covered (success)	100.00%	1 / 1
getPrimaryKeyAttributeList				0.00% covered (danger)	0.00%	0 / 1	12	0.00% covered (danger)	0.00%	0 / 5
getConstraintByName				100.00% covered (success)	100.00%	1 / 1	3	100.00% covered (success)	100.00%	4 / 4
getIndexByName				100.00% covered (success)	100.00%	1 / 1	3	100.00% covered (success)	100.00%	4 / 4
getDataBaseSpecific				100.00% covered (success)	100.00%	1 / 1	1	100.00% covered (success)	100.00%	2 / 2
extractColumnData				100.00% covered (success)	100.00%	1 / 1	2	100.00% covered (success)	100.00%	8 / 8
extractReferenceData				100.00% covered (success)	100.00%	1 / 1	6	100.00% covered (success)	100.00%	22 / 22
extractIndexData				100.00% covered (success)	100.00%	1 / 1	5	100.00% covered (success)	100.00%	16 / 16

1	<?php
2	declare(strict_types = 1);
3	namespace Siesta\Driver\MySQL\MetaData;
4
5	use Siesta\Database\Connection;
6	use Siesta\Database\MetaData\ColumnMetaData;
7	use Siesta\Database\MetaData\ConstraintMetaData;
8	use Siesta\Database\MetaData\IndexMetaData;
9	use Siesta\Database\MetaData\TableMetaData;
10	use Siesta\Driver\MySQL\MySQLDriver;
11	use Siesta\Driver\MySQL\MySQLTableCreator;
12
13	/**
14	* @author Gregor Müller
15	*/
16	class MySQLTable implements TableMetaData
17	{
18
19	const SQL_GET_COLUMN_DETAILS = "SELECT * FROM information_schema.COLUMNS WHERE TABLE_SCHEMA = '%s' AND TABLE_NAME = '%s';";
20
21	const SQL_GET_KEY_COLUMN_USAGE = "SELECT * FROM information_schema.key_column_usage as KC WHERE KC.CONSTRAINT_SCHEMA = '%s' AND KC.TABLE_NAME = '%s'";
22
23	const SQL_GET_REFERENTIAL_CONSTRAINTS = "SELECT * FROM information_schema.REFERENTIAL_CONSTRAINTS AS RC WHERE RC.CONSTRAINT_SCHEMA = '%s' AND RC.TABLE_NAME = '%s'";
24
25	const SQL_GET_INDEX_LIST = "SELECT S.* FROM INFORMATION_SCHEMA.STATISTICS AS S WHERE S.TABLE_SCHEMA = '%s' AND S.TABLE_NAME = '%s';";
26
27	/**
28	* @var Connection
29	*/
30	protected $connection;
31
32	/**
33	* @var TableDTO
34	*/
35	protected $tableDTO;
36
37	/**
38	* @var MySQLColumn[]
39	*/
40	protected $columnList;
41
42	/**
43	* @var MySQLConstraint[]
44	*/
45	protected $constraintList;
46
47	/**
48	* @var MySQLIndex[]
49	*/
50	protected $indexList;
51
52	/**
53	* MySQLTable constructor.
54	*
55	* @param Connection $connection
56	* @param TableDTO $tableDTO
57	*/
58	public function __construct(Connection $connection, TableDTO $tableDTO)
59	{
60	$this->connection = $connection;
61	$this->tableDTO = $tableDTO;
62	$this->columnList = [];
63	$this->constraintList = [];
64	$this->indexList = [];
65	$this->extractColumnData();
66	$this->extractReferenceData();
67	$this->extractIndexData();
68	}
69
70	/**
71	* @return string
72	*/
73	public function getName() : string
74	{
75	return $this->tableDTO->name;
76	}
77
78	/**
79	* @return ColumnMetaData[]
80	*/
81	public function getColumnList() : array
82	{
83	return $this->columnList;
84	}
85
86	/**
87	* @param string $name
88	*
89	* @return ColumnMetaData\|null
90	*/
91	public function getColumnByName(string $name)
92	{
93	foreach ($this->columnList as $column) {
94	if ($column->getDBName() === $name) {
95	return $column;
96	}
97	}
98	return null;
99	}
100
101	/**
102	* @return ConstraintMetaData[]
103	*/
104	public function getConstraintList() : array
105	{
106	return $this->constraintList;
107	}
108
109	/**
110	* @return IndexMetaData[]
111	*/
112	public function getIndexList() : array
113	{
114	return $this->indexList;
115	}
116
117	/**
118	* @return ColumnMetaData[]
119	*/
120	public function getPrimaryKeyAttributeList() : array
121	{
122	$primaryKeyColumnList = [];
123	foreach ($this->getColumnList() as $column) {
124	if ($column->getIsPrimaryKey()) {
125	$primaryKeyColumnList[] = $column;
126	}
127	}
128	return $primaryKeyColumnList;
129	}
130
131	/**
132	* @param string $name
133	*
134	* @return null\|MySQLConstraint
135	*/
136	public function getConstraintByName(string $name)
137	{
138	foreach ($this->constraintList as $constraint) {
139	if ($constraint->getConstraintName() === $name) {
140	return $constraint;
141	}
142	}
143	return null;
144	}
145
146	/**
147	* @param string $indexName
148	*
149	* @return null\|MySQLIndex
150	*/
151	public function getIndexByName(string $indexName)
152	{
153	foreach ($this->indexList as $index) {
154	if ($index->getName() === $indexName) {
155	return $index;
156	}
157	}
158	return null;
159	}
160
161	/**
162	* @return array
163	*/
164	public function getDataBaseSpecific() : array
165	{
166	return [
167	MySQLDriver::MYSQL_DRIVER_NAME => [
168	MySQLTableCreator::MYSQL_ENGINE_ATTRIBUTE => $this->tableDTO->engine,
169	MySQLTableCreator::MYSQL_COLLATE_ATTRIBUTE => $this->tableDTO->collation
170	]
171	];
172	}
173
174	/**
175	*
176	*/
177	protected function extractColumnData()
178	{
179
180	$sql = sprintf(self::SQL_GET_COLUMN_DETAILS, $this->connection->getDatabase(), $this->getName());
181
182	$resultSet = $this->connection->query($sql);
183	while ($resultSet->hasNext()) {
184	$column = new MySQLColumn();
185	$column->fromResultSet($resultSet, $this->tableDTO->autoincrement);
186	$this->columnList[] = $column;
187	}
188
189	$resultSet->close();
190	}
191
192	/**
193	*
194	*/
195	protected function extractReferenceData()
196	{
197	$sql = sprintf(self::SQL_GET_KEY_COLUMN_USAGE, $this->connection->getDatabase(), $this->getName());
198
199	$resultSet = $this->connection->query($sql);
200
201	while ($resultSet->hasNext()) {
202
203	// skip primary key index
204	if ($resultSet->getStringValue(MySQLConstraint::REFERENCED_TABLE_NAME) === null) {
205	continue;
206	}
207
208	$constraintName = $resultSet->getStringValue(MySQLConstraint::CONSTRAINT_NAME);
209	$constraint = $this->getConstraintByName($constraintName);
210
211	if ($constraint === null) {
212	$constraint = new MySQLConstraint($resultSet);
213	$constraint->fromResultSet($resultSet);
214	$this->constraintList[] = $constraint;
215	} else {
216	$constraint->addConstraint($resultSet);
217	}
218
219	}
220	$resultSet->close();
221
222	$sql = sprintf(self::SQL_GET_REFERENTIAL_CONSTRAINTS, $this->connection->getDatabase(), $this->getName());
223	$resultSet = $this->connection->query($sql);
224
225	while ($resultSet->hasNext()) {
226	$constraintName = $resultSet->getStringValue(MySQLConstraint::CONSTRAINT_NAME);
227	$constraint = $this->getConstraintByName($constraintName);
228
229	if ($constraint !== null) {
230	$constraint->addUpdateAndDeleteRule($resultSet);
231	}
232
233	}
234	$resultSet->close();
235
236	}
237
238	/**
239	* extracts index data
240	*/
241	protected function extractIndexData()
242	{
243	$sql = sprintf(self::SQL_GET_INDEX_LIST, $this->connection->getDatabase(), $this->getName());
244
245	$resultSet = $this->connection->query($sql);
246	while ($resultSet->hasNext()) {
247
248	$indexName = $resultSet->getStringValue(MySQLIndex::INDEX_NAME);
249	if ($indexName === MySQLIndex::PRIMARY_KEY_INDEX_NAME) {
250	continue;
251	}
252
253	$constraint = $this->getConstraintByName($indexName);
254	if ($constraint !== null) {
255	continue;
256	}
257
258	$index = $this->getIndexByName($indexName);
259	if ($index === null) {
260	$index = new MySQLIndex();
261	$index->fromResultSet($resultSet);
262	$this->indexList[] = $index;
263	} else {
264	$index->addIndexPart($resultSet);
265	}
266	}
267	}
268
269	}