<?php

namespace FluentForm\Framework\Database;

use FluentForm\Framework\Database\Concerns\MaintainsDatabase;

class Schema
{
	use MaintainsDatabase;

	/**
	 * Keep track of custom tables when unit testing
	 * 
	 * @var array
	 */
	public static $customTempTables = [];

	/**
	 * Get the global $wpdb instance
	 * 
	 * @return \wpdb The global $wpdb
	 */
	public static function db()
	{
		return $GLOBALS['wpdb'];
	}

	/**
	 * Get schema/db information
	 *
	 * @return string|array
	 */
	public static function getInfo($key = null)
	{
		$db = static::db();

		if (static::isSqlite()) {
			$info = [
			    'dbname' => 'sqlite',
			    'prefix' => $db->prefix,
			    'dbhost' => '',
			    'username' => '',
			    'password' => '',
			    'charset' => 'utf8',
			    'collation' => '',
			    'tables' => static::getTableList(),
			];

			return $key ? ($info[$key] ?? null) : $info;
		}

		$info = [
		    // @phpstan-ignore-next-line
		    'dbname' => $db->dbname,
		    'prefix' => $db->prefix,
		    // @phpstan-ignore-next-line
		    'dbhost' => $db->dbhost,
		    // @phpstan-ignore-next-line
		    'username' => $db->dbuser,
		    // @phpstan-ignore-next-line
		    'password' => $db->dbpassword,
		    'charset' => $db->charset,
		    'collation' => $db->collate,
		    'tables' => static::getTableList(),
		];

		return $key ? $info[$key] : $info;
	}

	/**
	 * Migrates database table(s)
	 * 
	 * @param  string|array $table The table name without prefix
	 *  or an array where each key is table name and value is sql.
	 *  
	 * @param  string $sql Optional
	 * @return mixed
	 */
	public static function migrate($table, $sql = null)
	{
		if (!$sql && is_array($table)) {
			$result = [];
			foreach ($table as $t => $s) {
				$result = array_merge(
					$result, (array) static::createTable($t, $s)
				);
			}
			return $result;
		} else {
			return static::createTable($table, $sql);
		}
	}

	/**
	 * Creates a new table if doesn't exist using dbDelta function
	 * 
	 * @param  string $table The table name without the prefix
	 * @param  string $sql   The sql to create table or an absolute path of a
	 * .sql file containing the column definations for creating the new table.
	 * 
	 * @return string Message
	 */
	public static function createTableIfNotExist($table, $sql)
	{
		if (!static::hasTable($table)) {
			return static::createTable($table, $sql);
		}
	}

	/**
	 * Checks if a column exists in a table
	 * 
	 * @param  string $column The column name of the table
	 * @param  string $table The table name without prefix
	 * @return boolean
	 */

	public static function hasColumn($column, $table)
    {
        $wpdb = static::db();

		$table = static::table($table);

        $columns = $wpdb->get_col("DESCRIBE $table");

        return in_array($column, $columns);
    }

	/**
	 * Checks if a table exists
	 * 
	 * @param  string $table The table name without prefix
	 * @return boolean
	 */
	public static function hasTable($table)
	{
		$wpdb = static::db();

		$table = static::table($table);

		$result = $wpdb->get_var("SHOW TABLES LIKE '" . $table . "'") == $table;

		if ($result) {
			return $result;
		}

		// Check if any temporary table exists by this table name.

		// At first, store the original state of the error suppress
		// error and then turn off the error from being shown, so
		// error will be not shown if there is no temporary
		// table, then restore the error state.
		$isErrorSuppressed = $wpdb->suppress_errors;

		$wpdb->suppress_errors = true;

		static::query("SELECT 1 FROM %{$table}% WHERE 0");

		$hasError = !empty($wpdb->last_error);

		$wpdb->suppress_errors = $isErrorSuppressed;

		return !$hasError;
	}

	/**
	 * Resolves the table prefix and makes the table name with prefix
	 * 
	 * @param  string $table The table name without the prefix
	 * @return string The resolved table name with the prefix
	 */
	public static function table($table)
	{
		$wpdb = static::db();
		
		$prefix = $wpdb->prefix;

		if (strpos($table, $prefix) === 0) {
			return $table;
		}

		return isset($wpdb->{$table}) ? $wpdb->{$table} : ($wpdb->prefix.$table);
	}


    /**
     * Resolves the sql prefix
     *
     * @param string $sql The file name or the raw sql
     * @return string The resolved sql
     */
    public static function sql($sql = '')
    {
        $allowedSqlFileFormats = [
            'sql'
        ];

        foreach ($allowedSqlFileFormats as $format) {
            if (str_ends_with($sql, '.' . $format)) {
                $sql = @file_exists($sql) ? file_get_contents($sql) : $sql;
                break;
            }
        }
        
        return $sql;
    }

    /**
     * Clean the sql string by removing the comments.
     * 
     * @param  string $sql
     * @return string
     */
	public static function cleanUp($sql)
	{
	    $sql = static::sql($sql);

	    // Remove inline -- comments
	    $sql = preg_replace('/--.*$/m', '', $sql);

	    // Remove inline # comments
	    $sql = preg_replace('/#.*$/m', '', $sql);

	    // Remove block /* ... */
	    $sql = preg_replace('/\/\*.*?\*\//s', '', $sql);

	    // Collapse multiple spaces & newlines
	    // $sql = preg_replace('/\s+/', ' ', $sql);

	    // Remove dangling commas before closing parenthesis
	    $sql = preg_replace('/,\s*\)/', ')', $sql);

	    return trim($sql);
	}

	/**
	 * Creates a new table using dbDelta function or alters the table if exists.
	 * 
	 * @param  string $table The table name without the prefix
	 * @param  string $sql   The sql to create table or an absolute path of a
	 * .sql file containing the column definations for creating the new table.
	 * 
	 * @return string message
	 */
	public static function createTable($table, $sql)
	{
		$table = static::table($table);

		$sql = static::cleanUp($sql);

		if (static::isSqlite()) {
            $sql = preg_replace('/\bjson\b/i', 'longtext', $sql);
        }

        $collate = static::db()->get_charset_collate();

        return static::callDBDelta(
        	"CREATE TABLE $table (
        		".PHP_EOL.trim(trim($sql), ',').PHP_EOL."
        	) $collate;"
        );
	}

	/**
	 * Alters an existing table if exists
	 * 
	 * @param  string $table The table name without the prefix
	 * @param    string $sql   The sql to create table or an absolute path of a
	 * .sql file containing the column definations for creating the new table.
	 * 
	 * @return string message
	 */
	public static function alterTableIfExists($table, $sql)
	{
		if (static::hasTable($table)) {
			return static::alterTable($table, $sql);
		}
	}

	/**
	 * Alters an existing table
	 *
	 * @param  string $table The table name without the prefix
	 * @param  string $sql   The sql to create table or an absolute path of a
	 * .sql file containing the column definations for creating the new table.
	 *
	 * @return string message
	 */
	public static function alterTable($table, $sql)
	{
		$table = static::table($table);

		$sql = static::cleanUp($sql);

		if (static::isSqlite()) {
            $sql = preg_replace('/\bjson\b/i', 'longtext', $sql);
        }

		$parts = array_filter(array_map('trim', static::splitAlterClauses($sql)));

		if (static::isSqlite()) {
			// SQLite only supports one ALTER TABLE operation per statement.
			$result = null;
			foreach ($parts as $part) {
				$result = static::query("ALTER TABLE $table {$part};");
			}
			return $result;
		}

        $sql = "ALTER TABLE $table ".PHP_EOL.rtrim(
        	trim(implode(','.PHP_EOL, $parts)), ';'
        ).";";

        return static::query($sql);
	}

	/**
	 * Split a comma-separated ALTER TABLE clause list, respecting parentheses
	 * so that DECIMAL(10,2) and similar types are not split mid-definition.
	 *
	 * @param  string $sql
	 * @return string[]
	 */
	protected static function splitAlterClauses($sql)
	{
		$parts = [];
		$depth = 0;
		$current = '';

		for ($i = 0, $len = strlen($sql); $i < $len; $i++) {
			$char = $sql[$i];
			if ($char === '(') {
				$depth++;
			} elseif ($char === ')') {
				$depth--;
			} elseif ($char === ',' && $depth === 0) {
				$parts[] = $current;
				$current = '';
				continue;
			}
			$current .= $char;
		}

		if ($current !== '') {
			$parts[] = $current;
		}

		return $parts;
	}

	/**
	 * Alters an existing table using dbDelta function if exists, otherwise creates
	 * it. Alters an existing table but takes the table creation column defination.
	 * This is because, the dbDelta functioin can create or update a table using 
	 * the table creation defination. In this, case, if a table exists and the
	 * columns are matched then nothing happens but if there's any difference
	 * in the new sql then the dbDelta alters the table using the new sql
	 * defination but doesn't delete any columns. So, after the dbDelta
	 * finishes it's job, any non-existing columns in the new sql
	 * defination will be deleted from the existing table. if
	 * table is not there then the table gets created.
	 * 
	 * @param  string $table The table name without the prefix
	 * @param  string $sql   The sql to create table or an absolute path of a
	 * .sql file containing the column definations for creating the new table.
	 * 
	 * @return string message
	 */
	public static function updateTable($table, $sql)
	{
	    $sql = static::cleanUp($sql);

	    if (static::isSqlite()) {
            $sql = preg_replace('/\bjson\b/i', 'longtext', $sql);
        }

	    $columnsDefinitions = array_map('trim', static::splitAlterClauses($sql));
	    $schemaSql = implode(",\n", $columnsDefinitions);

	    // Extract desired column names (skip constraint/index clauses)
	    $columns = [];
	    foreach ($columnsDefinitions as $definition) {
	        if (preg_match('/^(?:PRIMARY\s+KEY|UNIQUE(?:(?:\s+KEY|\s+INDEX))?|KEY|INDEX|CONSTRAINT|FOREIGN\s+KEY|FULLTEXT|SPATIAL)\b/i', ltrim($definition))) {
	            continue;
	        }

	        if (preg_match('/^`?(\w+)`?\s+/i', $definition, $matches)) {
	            $columns[$matches[1]] = $definition;
	        }
	    }

	    $tbl = static::table($table);

	    // SQLite cannot drop PRIMARY KEY columns or columns referenced by indexes
	    // via native ALTER TABLE DROP COLUMN.
	    //
	    // Workarounds:
	    //   - Indexed columns: drop the index first with DROP INDEX,
	    //     then drop the column.
	    //   - PRIMARY KEY columns: use CHANGE COLUMN to rebuild the table without
	    //     the PK attribute (renaming the column to a temp name), then drop
	    //     the renamed column.
	    if (static::isSqlite()) {
	        // Collect PRIMARY KEY columns and per-column index key names.
	        $indexRows     = (array) static::db()->get_results("SHOW INDEX FROM {$tbl}");
	        $pkColumns     = [];
	        $columnIndexes = []; // column_name => [key_name, ...]
	        foreach ($indexRows as $row) {
	            if ($row->Key_name === 'PRIMARY') {
	                $pkColumns[] = $row->Column_name;
	            } else {
	                $columnIndexes[$row->Column_name][] = $row->Key_name;
	            }
	        }

	        $existingColumns = static::getColumns($table) ?: [];

	        // 1. Add any desired columns not yet in the table.
	        foreach ($columns as $colName => $definition) {
	            if (!in_array($colName, $existingColumns)) {
	                static::db()->query("ALTER TABLE {$tbl} ADD COLUMN {$definition}");
	            }
	        }

	        // 2. Drop every column that is not in the desired schema.
	        foreach ($existingColumns as $column) {
	            if (isset($columns[$column])) {
	                continue; // desired — keep it
	            }

	            // Drop non-primary indexes referencing this column first, otherwise
	            // native SQLite ALTER TABLE DROP COLUMN fails.
	            foreach ($columnIndexes[$column] ?? [] as $keyName) {
	                static::db()->query("ALTER TABLE {$tbl} DROP INDEX {$keyName}");
	            }

	            if (in_array($column, $pkColumns)) {
	                // Native SQLite ALTER TABLE DROP COLUMN rejects PRIMARY KEY columns.
	                // Use CHANGE COLUMN to trigger an internal table rebuild that strips
	                // the PK attribute, then drop the (now ordinary) renamed column.
	                $tmpCol = $column . '_wpf_drop';
	                static::db()->query("ALTER TABLE {$tbl} CHANGE COLUMN {$column} {$tmpCol} INT NULL");
	                static::db()->query("ALTER TABLE {$tbl} DROP COLUMN {$tmpCol}");
	            } else {
	                static::db()->query("ALTER TABLE {$tbl} DROP COLUMN {$column}");
	            }
	        }

	        return [$tbl => "Updated table structure"];
	    }

	    // MySQL path: use dbDelta to create/update, then drop extra columns.
	    $result = static::createTable($table, $schemaSql);
	    $existingColumns = static::getColumns($table) ?: [];

	    // Add missing columns
	    foreach ($columns as $colName => $definition) {
	        if (!in_array($colName, $existingColumns)) {
	            static::query("ALTER TABLE $tbl ADD COLUMN $definition");
	            $result[$tbl.'.'.$colName] = "Added column {$tbl}.{$colName}";
	        }
	    }

	    // Drop extra columns
	    foreach ($existingColumns as $column) {
	        if (!isset($columns[$column])) {
	            static::query("ALTER TABLE $tbl DROP COLUMN $column");
	            $result[$tbl.'.'.$column] = "Dropped column {$tbl}.{$column}";
	        }
	    }

	    return $result;
	}

	/**
	 * Drops/deletes an existing table.
	 * 
	 * @param string $table The table name without the prefix
     * @param bool $disableForeignKeyCheck Optional.
     * @return bool
	 */
	public static function dropTable($table, $disableForeignKeyCheck = true)
    {
        return static::db()->query('DROP TABLE ' . static::table($table));
    }

    /**
     * Drops/deletes an existing table if exists
     *
     * @param string $table The table name without the prefix
     * @param bool $disableForeignKeyCheck Optional.
     * @return bool
     */
    public static function dropTableIfExists($table, $disableForeignKeyCheck = true)
    {
        if (static::hasTable($table)) {
            return static::dropTable($table, $disableForeignKeyCheck);
        }
    }

	/**
	 * Truncate a table.
	 *
	 * @param  string $table
	 * @return bool
	 */
	public static function truncate($table)
	{
		$table = static::table($table);

		$result = static::db()->query("TRUNCATE TABLE $table");

		if (static::isSqlite()) {
			// SQLite translates TRUNCATE TABLE to DELETE FROM, which does NOT reset
			// the auto-increment counter. Manually clear the sqlite_sequence row so
			// that the next INSERT starts at id=1 (matching MySQL TRUNCATE behaviour).
			static::db()->query("DELETE FROM sqlite_sequence WHERE name='{$table}'");
		}

		return $result;
	}

	/**
	 * Truncate a table if exists.
	 *
	 * @param  string $table
	 * @return bool
	 */
	public static function truncateTableIfExists($table)
	{
		if (static::hasTable($table)) {
			return static::truncate($table);
		}
	}

	/**
	 * Adds a new  index to a column of given table.
	 * 
	 * @param string $table Table name
	 * @param string $index Columns name
	 * @return bool
	 * @see https://developer.wordpress.org/reference/functions/add_clean_index
	 */
	public static function addIndex($table, $index)
	{
		return add_clean_index(static::table($table), $index);
	}

	/**
	 * Drops an index from a column of given table.
	 * 
	 * @param  string $table Table name
	 * @param  string $index Columns name
	 * @return bool
	 * @see https://developer.wordpress.org/reference/functions/drop_index
	 */
	public static function dropIndex($table, $index)
	{
		if (static::isSqlite()) {
			$tbl = static::table($table);
			return static::db()->query("ALTER TABLE {$tbl} DROP INDEX {$index}");
		}

		return drop_index(static::table($table), $index);
	}

	/**
	 * Makes raw query and can resolve the table name from the query
	 * and can form a full table name including the table prefix if
	 * the table name is wrapped like: %table_name% in the query.
	 * 
	 * @param  string $query
	 * @return mixed
	 */
	public static function query($query)
	{
		$query = preg_replace_callback('/(?<![\'"])%([a-zA-Z0-9_-]+)%(?![\'"])/', function ($matches) {
			return static::table($matches[1]);
		}, $query);

		if (preg_match('/^(SELECT|SHOW|DESCRIBE|EXPLAIN)\s+/i', trim($query))) {
	        return static::db()->get_results($query, OBJECT);
	    }

		return static::db()->query($query);
	}

	/**
	 * Get a list of all columns from the given table name.
	 *
	 * @param  string $table The table name without the prefix
	 * @return array|null
	 */
	public static function getColumns($table)
	{
		if (!static::hasTable($table)) {
			return null;
		}

		return static::db()->get_col(
            'DESCRIBE ' . static::table($table), 0
        );
	}

	/**
	 * Gets a list of all columns including column information
	 * 
	 * @param  string $table The table name without the prefix
	 * @return array
	 */
	protected static function protectedGetColumnsWithTypes($table)
	{
		if (!static::hasTable($table)) return;

		$table = static::table($table);

		if (static::isSqlite()) {
			// INFORMATION_SCHEMA is not available in SQLite.
			// Use DESCRIBE which the WP SQLite plugin translates with
			// proper MySQL type mapping from its data type cache.
			$columns = (array) static::db()->get_results("DESCRIBE {$table}");
			return array_map(function ($col, $pos) {
				$extra = $col->Extra ?? '';
				// SQLite INTEGER PRIMARY KEY is auto_increment but DESCRIBE
				// doesn't report it in Extra — detect from Key + Type.
				if (empty($extra) && ($col->Key ?? '') === 'PRI') {
					$type = strtoupper($col->Type ?? '');
					if (in_array($type, ['INTEGER', 'BIGINT', 'BIGINT(20)', 'BIGINT(20) UNSIGNED', 'INT'])) {
						$extra = 'auto_increment';
					}
				}

				return [
					'column_name' => $col->Field,
					'ordinal_position' => $pos + 1,
					'column_default' => $col->Default,
					'is_nullable' => ($col->Null === 'YES' ? 'YES' : 'NO'),
					'data_type' => strtolower(
						preg_replace('/\(.*/', '', $col->Type)
					),
					'character_maximum_length' => preg_match(
						'/\((\d+)\)/', $col->Type, $matches
					) ? (int)$matches[1] : null,
					'numeric_precision' => null,
					'numeric_scale' => null,
					'column_key' => $col->Key ?? '',
					'extra' => $extra,
				];
			}, $columns, array_keys($columns));
		}

		// @phpstan-ignore-next-line
		$db = static::db()->dbname;

		$fields = [
			'COLUMN_NAME',
			'ORDINAL_POSITION',
			'COLUMN_DEFAULT',
			'IS_NULLABLE',
			'DATA_TYPE',
			'CHARACTER_MAXIMUM_LENGTH',
			'NUMERIC_PRECISION',
			'NUMERIC_SCALE',
			'COLUMN_KEY',
			'EXTRA',
		];

		$sql = "SELECT " . implode(',', $fields) . " FROM INFORMATION_SCHEMA.COLUMNS";
		$sql .= " WHERE TABLE_NAME = '".$table."' AND TABLE_SCHEMA = '".$db."'";

		return array_map(function($i) {
			$item = [];
			foreach ((array) $i as $key => $value) {
				$item[strtolower($key)] = $value;
			}
			return $item;
		}, (array) static::db()->get_results($sql));
	}

	public static function getColumnsWithTypes($table)
	{
	    $columns = static::protectedGetColumnsWithTypes($table);

	    if (!empty($columns)) {
	    	return $columns;
	    }

		if (static::isSqlite()) {
			return [];
		}

	    $columns = static::db()->get_results(
	    	'SHOW COLUMNS FROM `'.static::table($table).'`'
	    );

        return array_map(function ($col) {
            return [
                'column_name' => $col->Field,
                'ordinal_position' => null,
                'column_default' => $col->Default,
                'is_nullable' => ($col->Null === 'YES' ? 'YES' : 'NO'),
                'data_type' => strtolower(
                	preg_replace('/\(.*/', '', $col->Type)
                ),
                'character_maximum_length' => preg_match(
                	'/\((\d+)\)/', $col->Type, $matches
                ) ? (int)$matches[1] : null,
                'numeric_precision' => null,
                'numeric_scale' => null,
                'column_key' => $col->Key,
                'extra' => $col->Extra,
            ];
        }, (array) $columns);
	}

	/**
	 * Gets a list of all columns including column information
	 * 
	 * @param  string $table The table name without the prefix
	 * @return array
	 */
	public static function describeTable($table)
	{
		return static::getColumnsWithTypes($table);
	}

	/**
	 * Gets a list of all foreign keys from the given table name.
	 * 
	 * @param  string $table
	 * @return array
	 */
	public static function getTableForeignKeys($table)
	{
	    $table = static::table($table);

	    if (static::isSqlite()) {
	        // Parse foreign keys from the CREATE TABLE statement in sqlite_master
	        // since PRAGMA queries cannot go through $wpdb.
	        $row = static::db()->get_row(
	            "SELECT sql FROM sqlite_master WHERE type='table' AND name='{$table}'"
	        );
	        if (!$row || empty($row->sql)) {
	            return [];
	        }
	        $fks = [];
	        if (preg_match_all(
	            '/FOREIGN\s+KEY\s*\(\s*[`"]?(\w+)[`"]?\s*\)\s*REFERENCES\s+[`"]?(\w+)[`"]?\s*\(\s*[`"]?(\w+)[`"]?\s*\)/i',
	            $row->sql, $matches, PREG_SET_ORDER
	        )) {
	            foreach ($matches as $m) {
	                $fks[] = [
	                    'column_name'       => $m[1],
	                    'referenced_table'  => $m[2],
	                    'referenced_column' => $m[3],
	                ];
	            }
	        }
	        return $fks;
	    }

		// @phpstan-ignore-next-line
	    $db = static::db()->dbname;

	    $sql = "SELECT COLUMN_NAME, REFERENCED_TABLE_NAME, REFERENCED_COLUMN_NAME
	            FROM INFORMATION_SCHEMA.KEY_COLUMN_USAGE
	            WHERE TABLE_NAME = '{$table}'
	              AND TABLE_SCHEMA = '{$db}'
	              AND REFERENCED_TABLE_NAME IS NOT NULL";

	    return array_map(function ($i) {
	        return [
	            'column_name'       => $i->COLUMN_NAME,
	            'referenced_table'  => $i->REFERENCED_TABLE_NAME,
	            'referenced_column' => $i->REFERENCED_COLUMN_NAME,
	        ];
	    }, (array) static::db()->get_results($sql));
	}

	/**
	 * Retrieves the list of all available built-in tables from
	 * the database using WordPress' $wpdb->tables native method.
	 * 
	 * @param  string  $scope
	 * @param  boolean $prefix
	 * @param  integer $blogId
	 * @return string[] WP Table names. When a prefix is requested,
	 * the key is the unprefixed table name.
	 * @see https://developer.wordpress.org/reference/classes/wpdb/tables/
	 */
	public static function tables($scope = 'all', $prefix = true, $blogId = 0)
	{
		return static::db()->tables($scope, $prefix, $blogId);
	}

	/**
	 * Retrieves the list of all available tables from the database.
	 * 
	 * @param  string $dbname optional
	 * @return array
	 */
	public static function getTables($dbname = null)
	{
		return static::getTableList($dbname);
	}

	/**
	 * Retrieves the list of all available tables in the database.
	 * 
	 * @param  string $dbname optional
	 * @return array
	 */
	public static function getTableList($dbname = null)
	{
		if (static::isSqlite()) {
			return array_map(function ($i) {
				return $i->name;
			}, (array) static::db()->get_results(
				"SELECT name FROM sqlite_master WHERE type='table' AND name NOT LIKE 'sqlite_%'"
			));
		}

		// @phpstan-ignore-next-line
		$dbname = $dbname ?: static::db()->dbname;
		$sql = "SELECT TABLE_NAME FROM INFORMATION_SCHEMA.TABLES";
		$sql .= " WHERE TABLE_SCHEMA = '".$dbname."'";

		return array_map(function($i) {
			return $i->TABLE_NAME;
		}, (array) static::db()->get_results($sql));
	}

	/**
	 * Retrieves the list of all available views in the database.
	 *
	 * @param  string $dbname optional
	 * @return array
	 */
	public static function getViews($dbname = null)
	{
		if (static::isSqlite()) {
			return array_map(function ($i) {
				return $i->name;
			}, (array) static::db()->get_results(
				"SELECT name FROM sqlite_master WHERE type='view'"
			));
		}

		// @phpstan-ignore-next-line
		$dbname = $dbname ?: static::db()->dbname;
		$sql = "SELECT TABLE_NAME FROM INFORMATION_SCHEMA.VIEWS";
		$sql .= " WHERE TABLE_SCHEMA = '".$dbname."'";

		return array_map(function ($i) {
			return $i->TABLE_NAME;
		}, (array) static::db()->get_results($sql));
	}

	/**
	 * Retrieves the SQL definition of a specific view.
	 *
	 * @param  string $name   The view name
	 * @param  string $dbname optional
	 * @return string|null
	 */
	public static function getView($name, $dbname = null)
	{
		if (static::isSqlite()) {
			$result = static::db()->get_row(
				"SELECT sql FROM sqlite_master WHERE type='view' AND name='".$name."'"
			);

			return $result ? $result->sql : null;
		}

		// @phpstan-ignore-next-line
		$dbname = $dbname ?: static::db()->dbname;
		$result = static::db()->get_row(
			"SELECT VIEW_DEFINITION FROM INFORMATION_SCHEMA.VIEWS"
			. " WHERE TABLE_SCHEMA = '".$dbname."'"
			. " AND TABLE_NAME = '".$name."'"
		);

		return $result ? $result->VIEW_DEFINITION : null;
	}

	/**
     * Determine if the connected database is a sqlite database.
     *
     * @return bool
     */
    public static function isSqlite()
    {
        return defined('DB_ENGINE') && DB_ENGINE === 'sqlite';
    }

    /**
     * Determine if the connected database is a mariadb database.
     *
     * @return bool
     */
    public static function isMaria()
    {
        if (static::isSqlite()) {
            return false;
        }

        return str_contains(
        	static::db()->get_var('SELECT VERSION()'), 'MariaDB'
        );
    }

	/**
	 * Retrieve the current database engine name.
	 * 
	 * @param  string $table
	 * @return string
	 */
	public static function getEngine($table)
	{
		if (static::isSqlite()) {
			return 'sqlite';
		}

		return static::db()->get_var(
            'SELECT ENGINE FROM information_schema.TABLES WHERE TABLE_SCHEMA = DATABASE() AND TABLE_NAME = "' . static::table($table) . '"'
        );
	}

	/**
	 * The wrapper for calling dbDelta function
	 * 
	 * @param  string $sql
	 * @return mixed
	 */
	public static function callDBDelta($sql)
	{
		if (!function_exists('dbDelta')) {
			require (ABSPATH . 'wp-admin/includes/upgrade.php');
		}

		$result = dbDelta($sql);

		if (php_sapi_name() === 'cli') {
			$key = array_key_first($result);
			if ($key && !str_contains($key, '.')) {
				static::$customTempTables[] = $key;
			}
		}

		return $result;
	}

	/**
     * Helper to get the driver-specific JSON type.
     */
    public static function jsonType()
    {
        return static::isSqlite() ? 'longtext' : 'json';
    }
}