fluent-cart / database / Migrations / Migrator.php

Migrator.php in FluentCart A New Era of eCommerce – Faster, Lighter, and Simpler 1.5.2, at database/Migrations/Migrator.php

199 lines 5.1 KB

Raw Download Zip

1	<?php
2
3	namespace FluentCart\Database\Migrations;
4
5	use FluentCart\Framework\Database\Schema;
6
7	abstract class Migrator
8	{
9	public static string $tableName = '';
10
11	/**
12	* Migrate the table.
13	*
14	* @return void
15	*/
16
17	public static function migrate()
18	{
19	Schema::createTableIfNotExist(
20	static::getTableName(),
21	static::getSqlSchema()
22	);
23
24	static::migrated();
25	}
26
27	/**
28	* Called once migration is done.
29	*
30	* Override this method in child migrators to perform
31	* post-migration tasks like seeding data or adding indexes.
32	*
33	* @return void
34	*/
35	public static function migrated()
36	{
37	// Override in child classes as needed.
38	}
39
40	/**
41	* Add a column if it does not exist.
42	*
43	* @param string $column Column name
44	* @param string $definition Column definition (e.g. "VARCHAR(100) NULL")
45	* @param string\|null $after Place after this column (ignored on SQLite)
46	* @return void
47	*/
48	protected static function addColumnIfNotExists($column, $definition, $after = null)
49	{
50	if (Schema::hasColumn($column, static::$tableName)) {
51	return;
52	}
53
54	$sql = "ADD COLUMN `{$column}` {$definition}";
55
56	if ($after && !Schema::isSqlite()) {
57	$sql .= " AFTER `{$after}`";
58	}
59
60	Schema::alterTable(static::$tableName, $sql);
61	}
62
63	/**
64	* Rename a column if the old name exists.
65	*
66	* @param string $oldColumn Current column name
67	* @param string $newColumn New column name
68	* @param string $definition New column definition
69	* @return void
70	*/
71	protected static function renameColumnIfExists($oldColumn, $newColumn, $definition)
72	{
73	if (!Schema::hasColumn($oldColumn, static::$tableName)) {
74	return;
75	}
76
77	Schema::alterTable(
78	static::$tableName,
79	"CHANGE `{$oldColumn}` `{$newColumn}` {$definition}"
80	);
81	}
82
83	/**
84	* Modify a column type/definition if it exists.
85	*
86	* @param string $column Column name
87	* @param string $definition New column definition
88	* @return void
89	*/
90	protected static function modifyColumnIfExists($column, $definition)
91	{
92	if (!Schema::hasColumn($column, static::$tableName)) {
93	return;
94	}
95
96	if (Schema::isSqlite()) {
97	// SQLite has no MODIFY; use CHANGE with same name to trigger rebuild
98	Schema::alterTable(
99	static::$tableName,
100	"CHANGE COLUMN `{$column}` `{$column}` {$definition}"
101	);
102	} else {
103	Schema::alterTable(
104	static::$tableName,
105	"MODIFY COLUMN `{$column}` {$definition}"
106	);
107	}
108	}
109
110	/**
111	* Check if an index exists on the table.
112	*
113	* @param string $indexName Index name
114	* @return bool
115	*/
116	protected static function hasIndex($indexName)
117	{
118	$wpdb = Schema::db();
119	$tableName = static::getTableName();
120
121	// SHOW INDEX works on both MySQL and SQLite (the WP SQLite integration
122	// plugin translates it).
123	// phpcs:ignore WordPress.DB.DirectDatabaseQuery.DirectQuery, WordPress.DB.DirectDatabaseQuery.NoCaching
124	$results = $wpdb->get_results($wpdb->prepare(
125	"SHOW INDEX FROM %i WHERE Key_name = %s",
126	$tableName,
127	$indexName
128	));
129
130	return !empty($results);
131	}
132
133	/**
134	* Add an index if it does not exist.
135	*
136	* @param string $indexName Index name
137	* @param string\|array $columns Column name(s)
138	* @param bool $unique Whether the index is unique
139	* @return void
140	*/
141	protected static function addIndexIfNotExists($indexName, $columns, $unique = false)
142	{
143	if (static::hasIndex($indexName)) {
144	return;
145	}
146
147	$type = $unique ? 'UNIQUE INDEX' : 'INDEX';
148
149	if (is_array($columns)) {
150	$colsSql = '`' . implode('`, `', $columns) . '`';
151	} else {
152	$colsSql = "`{$columns}`";
153	}
154
155	Schema::alterTable(
156	static::$tableName,
157	"ADD {$type} `{$indexName}` ({$colsSql})"
158	);
159	}
160
161	/**
162	* Drop an index if it exists.
163	*
164	* @param string $indexName Index name
165	* @return void
166	*/
167	protected static function dropIndexIfExists($indexName)
168	{
169	if (!static::hasIndex($indexName)) {
170	return;
171	}
172
173	Schema::dropIndex(static::$tableName, $indexName);
174	}
175
176	public static function getTableName(bool $withPrefix = true): string
177	{
178	return ($withPrefix ? static::getDbPrefix() : '') . static::$tableName;
179	}
180
181	public static function getDbPrefix(): string
182	{
183	global $wpdb;
184	return $wpdb->prefix;
185	}
186
187	public static function getCharsetCollate(): string
188	{
189	global $wpdb;
190	return $wpdb->get_charset_collate();
191	}
192
193	public static function dropTable()
194	{
195	Schema::dropTableIfExists(static::getTableName(false));
196	}
197
198	abstract public static function getSqlSchema(): string;
199	}