DB2SchemaManager.php — MailPoet – Newsletters, Email Marketing, and Automation 5.35.1

mailpoet / vendor-prefixed / doctrine / dbal / src / Schema / DB2SchemaManager.php

mailpoet / vendor-prefixed / doctrine / dbal / src / Schema Last commit date

Exception 2 years ago Visitor 9 months ago AbstractAsset.php 2 years ago AbstractSchemaManager.php 9 months ago Column.php 2 years ago ColumnDiff.php 2 years ago Comparator.php 2 years ago Constraint.php 2 years ago DB2SchemaManager.php 2 years ago DefaultSchemaManagerFactory.php 2 years ago ForeignKeyConstraint.php 9 months ago Identifier.php 2 years ago Index.php 2 years ago LegacySchemaManagerFactory.php 2 years ago MySQLSchemaManager.php 9 months ago OracleSchemaManager.php 2 years ago PostgreSQLSchemaManager.php 9 months ago SQLServerSchemaManager.php 9 months ago Schema.php 2 years ago SchemaConfig.php 2 years ago SchemaDiff.php 2 years ago SchemaException.php 2 years ago SchemaManagerFactory.php 2 years ago Sequence.php 2 years ago SqliteSchemaManager.php 8 months ago Table.php 2 years ago TableDiff.php 2 years ago UniqueConstraint.php 2 years ago View.php 2 years ago

DB2SchemaManager.php

292 lines

1	<?php
2	namespace MailPoetVendor\Doctrine\DBAL\Schema;
3	if (!defined('ABSPATH')) exit;
4	use MailPoetVendor\Doctrine\DBAL\Exception;
5	use MailPoetVendor\Doctrine\DBAL\Platforms\DB2Platform;
6	use MailPoetVendor\Doctrine\DBAL\Result;
7	use MailPoetVendor\Doctrine\DBAL\Types\Type;
8	use MailPoetVendor\Doctrine\DBAL\Types\Types;
9	use MailPoetVendor\Doctrine\Deprecations\Deprecation;
10	use function array_change_key_case;
11	use function implode;
12	use function preg_match;
13	use function str_replace;
14	use function strpos;
15	use function strtolower;
16	use function strtoupper;
17	use function substr;
18	use const CASE_LOWER;
19	class DB2SchemaManager extends AbstractSchemaManager
20	{
21	public function listTableNames()
22	{
23	return $this->doListTableNames();
24	}
25	public function listTables()
26	{
27	return $this->doListTables();
28	}
29	public function listTableDetails($name)
30	{
31	Deprecation::triggerIfCalledFromOutside('doctrine/dbal', 'https://github.com/doctrine/dbal/pull/5595', '%s is deprecated. Use introspectTable() instead.', __METHOD__);
32	return $this->doListTableDetails($name);
33	}
34	public function listTableColumns($table, $database = null)
35	{
36	return $this->doListTableColumns($table, $database);
37	}
38	public function listTableIndexes($table)
39	{
40	return $this->doListTableIndexes($table);
41	}
42	public function listTableForeignKeys($table, $database = null)
43	{
44	return $this->doListTableForeignKeys($table, $database);
45	}
46	protected function _getPortableTableColumnDefinition($tableColumn)
47	{
48	$tableColumn = array_change_key_case($tableColumn, CASE_LOWER);
49	$length = null;
50	$fixed = null;
51	$scale = \false;
52	$precision = \false;
53	$default = null;
54	if ($tableColumn['default'] !== null && $tableColumn['default'] !== 'NULL') {
55	$default = $tableColumn['default'];
56	if (preg_match('/^\'(.*)\'$/s', $default, $matches) === 1) {
57	$default = str_replace("''", "'", $matches[1]);
58	}
59	}
60	$type = $this->_platform->getDoctrineTypeMapping($tableColumn['typename']);
61	if (isset($tableColumn['comment'])) {
62	$type = $this->extractDoctrineTypeFromComment($tableColumn['comment'], $type);
63	$tableColumn['comment'] = $this->removeDoctrineTypeFromComment($tableColumn['comment'], $type);
64	}
65	switch (strtolower($tableColumn['typename'])) {
66	case 'varchar':
67	if ($tableColumn['codepage'] === 0) {
68	$type = Types::BINARY;
69	}
70	$length = $tableColumn['length'];
71	$fixed = \false;
72	break;
73	case 'character':
74	if ($tableColumn['codepage'] === 0) {
75	$type = Types::BINARY;
76	}
77	$length = $tableColumn['length'];
78	$fixed = \true;
79	break;
80	case 'clob':
81	$length = $tableColumn['length'];
82	break;
83	case 'decimal':
84	case 'double':
85	case 'real':
86	$scale = $tableColumn['scale'];
87	$precision = $tableColumn['length'];
88	break;
89	}
90	$options = ['length' => $length, 'fixed' => (bool) $fixed, 'default' => $default, 'autoincrement' => (bool) $tableColumn['autoincrement'], 'notnull' => $tableColumn['nulls'] === 'N', 'comment' => isset($tableColumn['comment']) && $tableColumn['comment'] !== '' ? $tableColumn['comment'] : null];
91	if ($scale !== null && $precision !== null) {
92	$options['scale'] = $scale;
93	$options['precision'] = $precision;
94	}
95	return new Column($tableColumn['colname'], Type::getType($type), $options);
96	}
97	protected function _getPortableTableDefinition($table)
98	{
99	$table = array_change_key_case($table, CASE_LOWER);
100	return $table['name'];
101	}
102	protected function _getPortableTableIndexesList($tableIndexes, $tableName = null)
103	{
104	foreach ($tableIndexes as &$tableIndexRow) {
105	$tableIndexRow = array_change_key_case($tableIndexRow, CASE_LOWER);
106	$tableIndexRow['primary'] = (bool) $tableIndexRow['primary'];
107	}
108	return parent::_getPortableTableIndexesList($tableIndexes, $tableName);
109	}
110	protected function _getPortableTableForeignKeyDefinition($tableForeignKey)
111	{
112	return new ForeignKeyConstraint($tableForeignKey['local_columns'], $tableForeignKey['foreign_table'], $tableForeignKey['foreign_columns'], $tableForeignKey['name'], $tableForeignKey['options']);
113	}
114	protected function _getPortableTableForeignKeysList($tableForeignKeys)
115	{
116	$foreignKeys = [];
117	foreach ($tableForeignKeys as $tableForeignKey) {
118	$tableForeignKey = array_change_key_case($tableForeignKey, CASE_LOWER);
119	if (!isset($foreignKeys[$tableForeignKey['index_name']])) {
120	$foreignKeys[$tableForeignKey['index_name']] = ['local_columns' => [$tableForeignKey['local_column']], 'foreign_table' => $tableForeignKey['foreign_table'], 'foreign_columns' => [$tableForeignKey['foreign_column']], 'name' => $tableForeignKey['index_name'], 'options' => ['onUpdate' => $tableForeignKey['on_update'], 'onDelete' => $tableForeignKey['on_delete']]];
121	} else {
122	$foreignKeys[$tableForeignKey['index_name']]['local_columns'][] = $tableForeignKey['local_column'];
123	$foreignKeys[$tableForeignKey['index_name']]['foreign_columns'][] = $tableForeignKey['foreign_column'];
124	}
125	}
126	return parent::_getPortableTableForeignKeysList($foreignKeys);
127	}
128	protected function _getPortableForeignKeyRuleDef($def)
129	{
130	if ($def === 'C') {
131	return 'CASCADE';
132	}
133	if ($def === 'N') {
134	return 'SET NULL';
135	}
136	return null;
137	}
138	protected function _getPortableViewDefinition($view)
139	{
140	$view = array_change_key_case($view, CASE_LOWER);
141	$sql = '';
142	$pos = strpos($view['text'], ' AS ');
143	if ($pos !== \false) {
144	$sql = substr($view['text'], $pos + 4);
145	}
146	return new View($view['name'], $sql);
147	}
148	protected function normalizeName(string $name) : string
149	{
150	$identifier = new Identifier($name);
151	return $identifier->isQuoted() ? $identifier->getName() : strtoupper($name);
152	}
153	protected function selectTableNames(string $databaseName) : Result
154	{
155	$sql = <<<'SQL'
156	SELECT NAME
157	FROM SYSIBM.SYSTABLES
158	WHERE TYPE = 'T'
159	AND CREATOR = ?
160	SQL;
161	return $this->_conn->executeQuery($sql, [$databaseName]);
162	}
163	protected function selectTableColumns(string $databaseName, ?string $tableName = null) : Result
164	{
165	$sql = 'SELECT';
166	if ($tableName === null) {
167	$sql .= ' C.TABNAME AS NAME,';
168	}
169	$sql .= <<<'SQL'
170	C.COLNAME,
171	C.TYPENAME,
172	C.CODEPAGE,
173	C.NULLS,
174	C.LENGTH,
175	C.SCALE,
176	C.REMARKS AS COMMENT,
177	CASE
178	WHEN C.GENERATED = 'D' THEN 1
179	ELSE 0
180	END AS AUTOINCREMENT,
181	C.DEFAULT
182	FROM SYSCAT.COLUMNS C
183	JOIN SYSCAT.TABLES AS T
184	ON T.TABSCHEMA = C.TABSCHEMA
185	AND T.TABNAME = C.TABNAME
186	SQL;
187	$conditions = ['C.TABSCHEMA = ?', "T.TYPE = 'T'"];
188	$params = [$databaseName];
189	if ($tableName !== null) {
190	$conditions[] = 'C.TABNAME = ?';
191	$params[] = $tableName;
192	}
193	$sql .= ' WHERE ' . implode(' AND ', $conditions) . ' ORDER BY C.TABNAME, C.COLNO';
194	return $this->_conn->executeQuery($sql, $params);
195	}
196	protected function selectIndexColumns(string $databaseName, ?string $tableName = null) : Result
197	{
198	$sql = 'SELECT';
199	if ($tableName === null) {
200	$sql .= ' IDX.TABNAME AS NAME,';
201	}
202	$sql .= <<<'SQL'
203	IDX.INDNAME AS KEY_NAME,
204	IDXCOL.COLNAME AS COLUMN_NAME,
205	CASE
206	WHEN IDX.UNIQUERULE = 'P' THEN 1
207	ELSE 0
208	END AS PRIMARY,
209	CASE
210	WHEN IDX.UNIQUERULE = 'D' THEN 1
211	ELSE 0
212	END AS NON_UNIQUE
213	FROM SYSCAT.INDEXES AS IDX
214	JOIN SYSCAT.TABLES AS T
215	ON IDX.TABSCHEMA = T.TABSCHEMA AND IDX.TABNAME = T.TABNAME
216	JOIN SYSCAT.INDEXCOLUSE AS IDXCOL
217	ON IDX.INDSCHEMA = IDXCOL.INDSCHEMA AND IDX.INDNAME = IDXCOL.INDNAME
218	SQL;
219	$conditions = ['IDX.TABSCHEMA = ?', "T.TYPE = 'T'"];
220	$params = [$databaseName];
221	if ($tableName !== null) {
222	$conditions[] = 'IDX.TABNAME = ?';
223	$params[] = $tableName;
224	}
225	$sql .= ' WHERE ' . implode(' AND ', $conditions) . ' ORDER BY IDX.INDNAME, IDXCOL.COLSEQ';
226	return $this->_conn->executeQuery($sql, $params);
227	}
228	protected function selectForeignKeyColumns(string $databaseName, ?string $tableName = null) : Result
229	{
230	$sql = 'SELECT';
231	if ($tableName === null) {
232	$sql .= ' R.TABNAME AS NAME,';
233	}
234	$sql .= <<<'SQL'
235	FKCOL.COLNAME AS LOCAL_COLUMN,
236	R.REFTABNAME AS FOREIGN_TABLE,
237	PKCOL.COLNAME AS FOREIGN_COLUMN,
238	R.CONSTNAME AS INDEX_NAME,
239	CASE
240	WHEN R.UPDATERULE = 'R' THEN 'RESTRICT'
241	END AS ON_UPDATE,
242	CASE
243	WHEN R.DELETERULE = 'C' THEN 'CASCADE'
244	WHEN R.DELETERULE = 'N' THEN 'SET NULL'
245	WHEN R.DELETERULE = 'R' THEN 'RESTRICT'
246	END AS ON_DELETE
247	FROM SYSCAT.REFERENCES AS R
248	JOIN SYSCAT.TABLES AS T
249	ON T.TABSCHEMA = R.TABSCHEMA
250	AND T.TABNAME = R.TABNAME
251	JOIN SYSCAT.KEYCOLUSE AS FKCOL
252	ON FKCOL.CONSTNAME = R.CONSTNAME
253	AND FKCOL.TABSCHEMA = R.TABSCHEMA
254	AND FKCOL.TABNAME = R.TABNAME
255	JOIN SYSCAT.KEYCOLUSE AS PKCOL
256	ON PKCOL.CONSTNAME = R.REFKEYNAME
257	AND PKCOL.TABSCHEMA = R.REFTABSCHEMA
258	AND PKCOL.TABNAME = R.REFTABNAME
259	AND PKCOL.COLSEQ = FKCOL.COLSEQ
260	SQL;
261	$conditions = ['R.TABSCHEMA = ?', "T.TYPE = 'T'"];
262	$params = [$databaseName];
263	if ($tableName !== null) {
264	$conditions[] = 'R.TABNAME = ?';
265	$params[] = $tableName;
266	}
267	$sql .= ' WHERE ' . implode(' AND ', $conditions) . ' ORDER BY R.CONSTNAME, FKCOL.COLSEQ';
268	return $this->_conn->executeQuery($sql, $params);
269	}
270	protected function fetchTableOptionsByTable(string $databaseName, ?string $tableName = null) : array
271	{
272	$sql = 'SELECT NAME, REMARKS';
273	$conditions = [];
274	$params = [];
275	if ($tableName !== null) {
276	$conditions[] = 'NAME = ?';
277	$params[] = $tableName;
278	}
279	$sql .= ' FROM SYSIBM.SYSTABLES';
280	if ($conditions !== []) {
281	$sql .= ' WHERE ' . implode(' AND ', $conditions);
282	}
283	$metadata = $this->_conn->executeQuery($sql, $params)->fetchAllAssociativeIndexed();
284	$tableOptions = [];
285	foreach ($metadata as $table => $data) {
286	$data = array_change_key_case($data, CASE_LOWER);
287	$tableOptions[$table] = ['comment' => $data['remarks']];
288	}
289	return $tableOptions;
290	}
291	}
292