ꦫꦣꦺꦤ꧀ꦄꦤ꧀ꦠꦱꦺꦤ

PATH: home / letacommog / menuiserie-convert / wp-content / plugins / wordpress-seo / lib

<?php
/**
 * Yoast model class.
 *
 * @package Yoast\WP\Lib
 */

namespace Yoast\WP\Lib;

use YoastSEO_Vendor\Ruckusing_Adapter_ColumnDefinition;
use YoastSEO_Vendor\Ruckusing_Adapter_Interface;
use YoastSEO_Vendor\Ruckusing_Adapter_MySQL_Base;
use YoastSEO_Vendor\Ruckusing_Adapter_MySQL_TableDefinition;
use YoastSEO_Vendor\Ruckusing_Exception;
use YoastSEO_Vendor\Ruckusing_Util_Naming;

use const YoastSEO_Vendor\MYSQL_MAX_IDENTIFIER_LENGTH;
use const YoastSEO_Vendor\SQL_ALTER;
use const YoastSEO_Vendor\SQL_CREATE;
use const YoastSEO_Vendor\SQL_DELETE;
use const YoastSEO_Vendor\SQL_DROP;
use const YoastSEO_Vendor\SQL_INSERT;
use const YoastSEO_Vendor\SQL_RENAME;
use const YoastSEO_Vendor\SQL_SELECT;
use const YoastSEO_Vendor\SQL_SET;
use const YoastSEO_Vendor\SQL_SHOW;
use const YoastSEO_Vendor\SQL_UNKNOWN_QUERY_TYPE;
use const YoastSEO_Vendor\SQL_UPDATE;

/**
 * Ruckusing_Adapter
 */
class Ruckusing_Adapter extends Ruckusing_Adapter_MySQL_Base implements Ruckusing_Adapter_Interface {

/**
	 * Name of adapter
	 *
	 * @var string
	 */
	private $_name = 'MySQL';
	/**
	 * Tables
	 *
	 * @var array
	 */
	private $_tables = [];
	/**
	 * Tables_loaded
	 *
	 * @var boolean
	 */
	private $_tables_loaded = false;
	/**
	 * Version
	 *
	 * @var string
	 */
	private $_version = '1.0';
	/**
	 * Indicate if is in transaction
	 *
	 * @var boolean
	 */
	private $_in_trx = false;

/**
	 * Creates an instance of Ruckusing_Adapter.
	 *
	 * @param array $config The configuration.
	 *
	 * @return Ruckusing_Adapter
	 */
	public function __construct( $config ) {
		$this->set_dsn( $config );
	}

/**
	 * Get the current db name
	 *
	 * @return string
	 */
	public function get_database_name() {
		global $wpdb;

return $wpdb->dbname;
	}

/**
	 * Check support for migrations
	 *
	 * @return boolean
	 */
	public function supports_migrations() {
		return true;
	}

/**
	 * Get the column native types
	 *
	 * @return array
	 */
	public function native_database_types() {
		$types = [
			'primary_key'   => [ 'name' => 'integer', 'limit' => 11, 'null' => false ],
			'string'        => [ 'name' => 'varchar', 'limit' => 255 ],
			'text'          => [ 'name' => 'text' ],
			'tinytext'      => [ 'name' => 'tinytext' ],
			'mediumtext'    => [ 'name' => 'mediumtext' ],
			'integer'       => [ 'name' => 'int', 'limit' => 11 ],
			'tinyinteger'   => [ 'name' => 'tinyint' ],
			'smallinteger'  => [ 'name' => 'smallint' ],
			'mediuminteger' => [ 'name' => 'mediumint' ],
			'biginteger'    => [ 'name' => 'bigint' ],
			'float'         => [ 'name' => 'float' ],
			'decimal'       => [ 'name' => 'decimal', 'scale' => 0, 'precision' => 10 ],
			'datetime'      => [ 'name' => 'datetime' ],
			'timestamp'     => [ 'name' => 'timestamp' ],
			'time'          => [ 'name' => 'time' ],
			'date'          => [ 'name' => 'date' ],
			'binary'        => [ 'name' => 'blob' ],
			'tinybinary'    => [ 'name' => 'tinyblob' ],
			'mediumbinary'  => [ 'name' => 'mediumblob' ],
			'longbinary'    => [ 'name' => 'longblob' ],
			'boolean'       => [ 'name' => 'tinyint', 'limit' => 1 ],
			'enum'          => [ 'name' => 'enum', 'values' => [] ],
			'uuid'          => [ 'name' => 'char', 'limit' => 36 ],
			'char'          => [ 'name' => 'char' ]
		];

return $types;
	}

/**
	 * Create the schema table, if necessary
	 */
	public function create_schema_version_table() {
		if ( ! $this->has_table( $this->get_schema_version_table_name() ) ) {
			$t = $this->create_table( $this->get_schema_version_table_name(), [ 'id' => false ] );
			$t->column( 'version', 'string' );
			$t->finish();
			$this->add_index( $this->get_schema_version_table_name(), 'version', [ 'unique' => true ] );
		}
	}

/**
	 * Start Transaction
	 */
	public function start_transaction() {
		if ( $this->inTransaction() === false ) {
			$this->beginTransaction();
		}
	}

/**
	 * Commit Transaction
	 */
	public function commit_transaction() {
		if ( $this->inTransaction() ) {
			$this->commit();
		}
	}

/**
	 * Rollback Transaction
	 */
	public function rollback_transaction() {
		if ( $this->inTransaction() ) {
			$this->rollback();
		}
	}

/**
	 * Quote a table name string
	 *
	 * @param string $str table name.
	 *
	 * @return string
	 */
	public function quote_table( $str ) {
		return '`' . $str . '`';
	}

/**
	 * Column definition
	 *
	 * @param string $column_name The column name.
	 * @param string $type        The type of the column.
	 * @param array  $options     Column options.
	 *
	 * @return string
	 */
	public function column_definition( $column_name, $type, $options = null ) {
		$col = new Ruckusing_Adapter_ColumnDefinition( $this, $column_name, $type, $options );

return $col->__toString();
	}
	// -------- DATABASE LEVEL OPERATIONS

/**
	 * Check if a db exists
	 *
	 * @param string $db The db name.
	 *
	 * @return boolean
	 */
	public function database_exists( $db ) {
		$ddl    = 'SHOW DATABASES';
		$result = $this->select_all( $ddl );
		if ( \count( $result ) == 0 ) {
			return false;
		}
		foreach ( $result as $dbrow ) {
			if ( $dbrow['Database'] == $db ) {
				return true;
			}
		}

return false;
	}

/**
	 * Create a database
	 *
	 * @param string $db the db name
	 *
	 * @return boolean
	 */
	public function create_database( $db ) {
		if ( $this->database_exists( $db ) ) {
			return false;
		}
		$ddl    = \sprintf( 'CREATE DATABASE %s', $this->identifier( $db ) );
		$result = $this->query( $ddl );

return $result === true;
	}

/**
	 * Drop a database
	 *
	 * @param string $db the db name
	 *
	 * @return boolean
	 */
	public function drop_database( $db ) {
		if ( ! $this->database_exists( $db ) ) {
			return false;
		}
		$ddl    = \sprintf( 'DROP DATABASE IF EXISTS %s', $this->identifier( $db ) );
		$result = $this->query( $ddl );

return $result === true;
	}

/**
	 * Dump the complete schema of the DB. This is really just all of the
	 * CREATE TABLE statements for all of the tables in the DB.
	 * NOTE: this does NOT include any INSERT statements or the actual data
	 * (that is, this method is NOT a replacement for mysqldump)
	 *
	 * @param string $output_file the filepath to output to
	 *
	 * @return int|FALSE
	 */
	public function schema( $output_file ) {
		$final = '';
		$views = '';
		$this->load_tables( true );
		foreach ( $this->_tables as $tbl => $idx ) {
			if ( $tbl == 'schema_info' ) {
				continue;
			}
			$stmt   = \sprintf( 'SHOW CREATE TABLE %s', $this->identifier( $tbl ) );
			$result = $this->query( $stmt );
			if ( \is_array( $result ) && \count( $result ) == 1 ) {
				$row = $result[0];
				if ( \count( $row ) == 2 ) {
					if ( isset( $row['Create Table'] ) ) {
						$final .= $row['Create Table'] . ";\n\n";
					} elseif ( isset( $row['Create View'] ) ) {
						$views .= $row['Create View'] . ";\n\n";
					}
				}
			}
		}
		$data = $final . $views;

return \file_put_contents( $output_file, $data, \LOCK_EX );
	}

/**
	 * Check if a table exists
	 *
	 * @param string  $tbl           the table name
	 * @param boolean $reload_tables reload table or not
	 *
	 * @return boolean
	 */
	public function table_exists( $tbl, $reload_tables = false ) {
		global $wpdb;

// We need last error to be clear so we can check against it easily.
		$previous_last_error      = $wpdb->last_error;
		$previous_suppress_errors = $wpdb->suppress_errors;
		$wpdb->last_error         = '';
		$wpdb->suppress_errors    = true;

$result = $wpdb->query( "SELECT * FROM $tbl LIMIT 1" );

// Restore the last error, as this is not truly an error and we don't want to alarm people.
		$wpdb->last_error      = $previous_last_error;
		$wpdb->suppress_errors = $previous_suppress_errors;

return $result !== false;
	}

/**
	 * Wrapper to execute a query
	 *
	 * @param string $query query to run
	 *
	 * @return boolean
	 */
	public function execute( $query ) {
		return $this->query( $query );
	}

/**
	 * Execute a query
	 *
	 * @param string $query query to run
	 *
	 * @return boolean
	 * @throws Ruckusing_Exception
	 */
	public function query( $query ) {
		global $wpdb;

$query_type = $this->determine_query_type( $query );
		$data       = [];
		if ( $query_type == SQL_SELECT || $query_type == SQL_SHOW ) {
			$data = $wpdb->get_results( $query, ARRAY_A );
			if ( $this->isError( $data ) ) {
				throw new Ruckusing_Exception( \sprintf( "Error executing 'query' with:\n%s\n\nReason: %s\n\n", $query, $wpdb->last_error ), Ruckusing_Exception::QUERY_ERROR );
			}

return $data;
		} else {
			// INSERT, DELETE, etc...
			$res = $wpdb->query( $query );
			if ( $this->isError( $res ) ) {
				throw new Ruckusing_Exception( \sprintf( "Error executing 'query' with:\n%s\n\nReason: %s\n\n", $query, $wpdb->last_error ), Ruckusing_Exception::QUERY_ERROR );
			}
			if ( $query_type == SQL_INSERT ) {
				return $wpdb->insert_id;
			}

return true;
		}
	}

/**
	 * Execute several queries
	 *
	 * @param string $queries queries to run
	 *
	 * @return boolean
	 * @throws Ruckusing_Exception
	 */
	public function multi_query( $queries ) {
		if ( \defined( 'YOAST_ENVIRONMENT' ) && YOAST_ENVIRONMENT !== 'production' ) {
			throw new Ruckusing_Exception( 'WPDB does not support multi_query.', Ruckusing_Exception::QUERY_ERROR );
		}

return false;
	}

/**
	 * Select one
	 *
	 * @param string $query query to run
	 *
	 * @return array
	 * @throws Ruckusing_Exception
	 */
	public function select_one( $query ) {
		global $wpdb;

$query_type = $this->determine_query_type( $query );
		if ( $query_type == SQL_SELECT || $query_type == SQL_SHOW ) {
			$res = $wpdb->query( $query );
			if ( $this->isError( $res ) ) {
				throw new Ruckusing_Exception( \sprintf( "Error executing 'query' with:\n%s\n\nReason: %s\n\n", $query, $wpdb->last_error ), Ruckusing_Exception::QUERY_ERROR );
			}

return $wpdb->last_result;
		} else {
			throw new Ruckusing_Exception( "Query for select_one() is not one of SELECT or SHOW: {$query}", Ruckusing_Exception::QUERY_ERROR );
		}
	}

/**
	 * Select all
	 *
	 * @param string $query query to run
	 *
	 * @return array
	 */
	public function select_all( $query ) {
		return $this->query( $query );
	}

/**
	 * Use this method for non-SELECT queries
	 * Or anything where you dont necessarily expect a result string, e.g. DROPs, CREATEs, etc.
	 *
	 * @param string $ddl query to run
	 *
	 * @return boolean
	 */
	public function execute_ddl( $ddl ) {
		$result = $this->query( $ddl );

return true;
	}

/**
	 * Drop table
	 *
	 * @param string $tbl the table name
	 *
	 * @return boolean
	 */
	public function drop_table( $tbl ) {
		$ddl    = \sprintf( 'DROP TABLE IF EXISTS %s', $this->identifier( $tbl ) );
		$result = $this->query( $ddl );

return true;
	}

/**
	 * Create table
	 *
	 * @param string $table_name the table name
	 * @param array  $options    the options
	 *
	 * @return bool|Ruckusing_Adapter_MySQL_TableDefinition
	 */
	public function create_table( $table_name, $options = [] ) {
		return new Ruckusing_Adapter_MySQL_TableDefinition( $this, $table_name, $options );
	}

/**
	 * Escape a string for mysql
	 *
	 * @param string $str the string
	 *
	 * @return string
	 */
	public function quote_string( $str ) {
		global $wpdb;

return $wpdb->_escape( $str );
	}

/**
	 * Quote a string
	 *
	 * @param string $str the string
	 *
	 * @return string
	 */
	public function identifier( $str ) {
		return '`' . $str . '`';
	}

/**
	 * Quote a string
	 *
	 * @param string $value  the string
	 * @param string $column the column
	 *
	 * @return string
	 */
	public function quote( $value, $column = null ) {
		return $this->quote_string( $value );
	}

/**
	 * Rename a table
	 *
	 * @param string $name     the current table name
	 * @param string $new_name the new table name
	 *
	 * @return boolean
	 * @throws Ruckusing_Exception
	 */
	public function rename_table( $name, $new_name ) {
		if ( empty( $name ) ) {
			throw new Ruckusing_Exception( 'Missing original column name parameter', Ruckusing_Exception::INVALID_ARGUMENT );
		}
		if ( empty( $new_name ) ) {
			throw new Ruckusing_Exception( 'Missing new column name parameter', Ruckusing_Exception::INVALID_ARGUMENT );
		}
		$sql = \sprintf( 'RENAME TABLE %s TO %s', $this->identifier( $name ), $this->identifier( $new_name ) );

return $this->execute_ddl( $sql );
	}
	// create_table

/**
	 * Add a column
	 *
	 * @param string $table_name  the table name
	 * @param string $column_name the column name
	 * @param string $type        the column type
	 * @param array  $options     column options
	 *
	 * @return boolean
	 * @throws Ruckusing_Exception
	 */
	public function add_column( $table_name, $column_name, $type, $options = [] ) {
		if ( empty( $table_name ) ) {
			throw new Ruckusing_Exception( 'Missing table name parameter', Ruckusing_Exception::INVALID_ARGUMENT );
		}
		if ( empty( $column_name ) ) {
			throw new Ruckusing_Exception( 'Missing column name parameter', Ruckusing_Exception::INVALID_ARGUMENT );
		}
		if ( empty( $type ) ) {
			throw new Ruckusing_Exception( 'Missing type parameter', Ruckusing_Exception::INVALID_ARGUMENT );
		}
		// default types
		if ( ! \array_key_exists( 'limit', $options ) ) {
			$options['limit'] = null;
		}
		if ( ! \array_key_exists( 'precision', $options ) ) {
			$options['precision'] = null;
		}
		if ( ! \array_key_exists( 'scale', $options ) ) {
			$options['scale'] = null;
		}
		$sql = \sprintf( 'ALTER TABLE %s ADD `%s` %s', $this->identifier( $table_name ), $column_name, $this->type_to_sql( $type, $options ) );
		$sql .= $this->add_column_options( $type, $options );

return $this->execute_ddl( $sql );
	}
	// add_column

/**
	 * Drop a column
	 *
	 * @param string $table_name  the table name
	 * @param string $column_name the column name
	 *
	 * @return boolean
	 */
	public function remove_column( $table_name, $column_name ) {
		$sql = \sprintf( 'ALTER TABLE %s DROP COLUMN %s', $this->identifier( $table_name ), $this->identifier( $column_name ) );

return $this->execute_ddl( $sql );
	}
	// remove_column

/**
	 * Rename a column
	 *
	 * @param string $table_name      the table name
	 * @param string $column_name     the column name
	 * @param string $new_column_name the new column name
	 *
	 * @return boolean
	 * @throws Ruckusing_Exception
	 */
	public function rename_column( $table_name, $column_name, $new_column_name ) {
		if ( empty( $table_name ) ) {
			throw new Ruckusing_Exception( 'Missing table name parameter', Ruckusing_Exception::INVALID_ARGUMENT );
		}
		if ( empty( $column_name ) ) {
			throw new Ruckusing_Exception( 'Missing original column name parameter', Ruckusing_Exception::INVALID_ARGUMENT );
		}
		if ( empty( $new_column_name ) ) {
			throw new Ruckusing_Exception( 'Missing new column name parameter', Ruckusing_Exception::INVALID_ARGUMENT );
		}
		$column_info  = $this->column_info( $table_name, $column_name );
		$current_type = $column_info['type'];
		$sql          = \sprintf( 'ALTER TABLE %s CHANGE %s %s %s', $this->identifier( $table_name ), $this->identifier( $column_name ), $this->identifier( $new_column_name ), $current_type );
		$sql          .= $this->add_column_options( $current_type, $column_info );

return $this->execute_ddl( $sql );
	}
	// rename_column

/**
	 * Change a column
	 *
	 * @param string $table_name  the table name
	 * @param string $column_name the column name
	 * @param string $type        the column type
	 * @param array  $options     column options
	 *
	 * @return boolean
	 * @throws Ruckusing_Exception
	 */
	public function change_column( $table_name, $column_name, $type, $options = [] ) {
		if ( empty( $table_name ) ) {
			throw new Ruckusing_Exception( 'Missing table name parameter', Ruckusing_Exception::INVALID_ARGUMENT );
		}
		if ( empty( $column_name ) ) {
			throw new Ruckusing_Exception( 'Missing original column name parameter', Ruckusing_Exception::INVALID_ARGUMENT );
		}
		if ( empty( $type ) ) {
			throw new Ruckusing_Exception( 'Missing type parameter', Ruckusing_Exception::INVALID_ARGUMENT );
		}
		$column_info = $this->column_info( $table_name, $column_name );
		// default types
		if ( ! \array_key_exists( 'limit', $options ) ) {
			$options['limit'] = null;
		}
		if ( ! \array_key_exists( 'precision', $options ) ) {
			$options['precision'] = null;
		}
		if ( ! \array_key_exists( 'scale', $options ) ) {
			$options['scale'] = null;
		}
		$sql = \sprintf( 'ALTER TABLE `%s` CHANGE `%s` `%s` %s', $table_name, $column_name, $column_name, $this->type_to_sql( $type, $options ) );
		$sql .= $this->add_column_options( $type, $options );

return $this->execute_ddl( $sql );
	}
	// change_column

/**
	 * Get a column info
	 *
	 * @param string $table  the table name
	 * @param string $column the column name
	 *
	 * @return array
	 * @throws Ruckusing_Exception
	 */
	public function column_info( $table, $column ) {
		if ( empty( $table ) ) {
			throw new Ruckusing_Exception( 'Missing table name parameter', Ruckusing_Exception::INVALID_ARGUMENT );
		}
		if ( empty( $column ) ) {
			throw new Ruckusing_Exception( 'Missing original column name parameter', Ruckusing_Exception::INVALID_ARGUMENT );
		}
		try {
			$sql    = \sprintf( "SHOW FULL COLUMNS FROM %s LIKE '%s'", $this->identifier( $table ), $column );
			$result = $this->select_one( $sql );
			if ( \is_array( $result ) ) {
				// lowercase key names
				$result = \array_change_key_case( $result, \CASE_LOWER );
			}

return $result;
		} catch ( \Exception $e ) {
			return null;
		}
	}

/**
	 * Add an index
	 *
	 * @param string $table_name  the table name
	 * @param string $column_name the column name
	 * @param array  $options     index options
	 *
	 * @return boolean
	 * @throws Ruckusing_Exception
	 */
	public function add_index( $table_name, $column_name, $options = [] ) {
		if ( empty( $table_name ) ) {
			throw new Ruckusing_Exception( 'Missing table name parameter', Ruckusing_Exception::INVALID_ARGUMENT );
		}
		if ( empty( $column_name ) ) {
			throw new Ruckusing_Exception( 'Missing column name parameter', Ruckusing_Exception::INVALID_ARGUMENT );
		}
		// unique index?
		if ( \is_array( $options ) && \array_key_exists( 'unique', $options ) && $options['unique'] === true ) {
			$unique = true;
		} else {
			$unique = false;
		}
		// did the user specify an index name?
		if ( \is_array( $options ) && \array_key_exists( 'name', $options ) ) {
			$index_name = $options['name'];
		} else {
			$index_name = Ruckusing_Util_Naming::index_name( $table_name, $column_name );
		}
		if ( \strlen( $index_name ) > MYSQL_MAX_IDENTIFIER_LENGTH ) {
			$msg = 'The auto-generated index name is too long for MySQL (max is 64 chars). ';
			$msg .= "Considering using 'name' option parameter to specify a custom name for this index.";
			$msg .= ' Note: you will also need to specify';
			$msg .= ' this custom name in a drop_index() - if you have one.';
			throw new Ruckusing_Exception( $msg, Ruckusing_Exception::INVALID_INDEX_NAME );
		}
		if ( ! \is_array( $column_name ) ) {
			$column_names = [ $column_name ];
		} else {
			$column_names = $column_name;
		}
		$cols = [];
		foreach ( $column_names as $name ) {
			$cols[] = $this->identifier( $name );
		}
		$sql = \sprintf( 'CREATE %sINDEX %s ON %s(%s)', $unique ? 'UNIQUE ' : '', $this->identifier( $index_name ), $this->identifier( $table_name ), \join( ', ', $cols ) );

return $this->execute_ddl( $sql );
	}

/**
	 * Drop an index
	 *
	 * @param string $table_name  the table name
	 * @param string $column_name the column name
	 * @param array  $options     index options
	 *
	 * @return boolean
	 * @throws Ruckusing_Exception
	 */
	public function remove_index( $table_name, $column_name, $options = [] ) {
		if ( empty( $table_name ) ) {
			throw new Ruckusing_Exception( 'Missing table name parameter', Ruckusing_Exception::INVALID_ARGUMENT );
		}
		if ( empty( $column_name ) ) {
			throw new Ruckusing_Exception( 'Missing column name parameter', Ruckusing_Exception::INVALID_ARGUMENT );
		}
		// did the user specify an index name?
		if ( \is_array( $options ) && \array_key_exists( 'name', $options ) ) {
			$index_name = $options['name'];
		} else {
			$index_name = Ruckusing_Util_Naming::index_name( $table_name, $column_name );
		}
		$sql = \sprintf( 'DROP INDEX %s ON %s', $this->identifier( $index_name ), $this->identifier( $table_name ) );

return $this->execute_ddl( $sql );
	}

/**
	 * Add timestamps
	 *
	 * @param string $table_name          The table name
	 * @param string $created_column_name Created at column name
	 * @param string $updated_column_name Updated at column name
	 *
	 * @return boolean
	 */
	public function add_timestamps( $table_name, $created_column_name, $updated_column_name ) {
		if ( empty( $table_name ) ) {
			throw new Ruckusing_Exception( 'Missing table name parameter', Ruckusing_Exception::INVALID_ARGUMENT );
		}
		if ( empty( $created_column_name ) ) {
			throw new Ruckusing_Exception( 'Missing created at column name parameter', Ruckusing_Exception::INVALID_ARGUMENT );
		}
		if ( empty( $updated_column_name ) ) {
			throw new Ruckusing_Exception( 'Missing updated at column name parameter', Ruckusing_Exception::INVALID_ARGUMENT );
		}
		$created_at = $this->add_column( $table_name, $created_column_name, 'datetime' );
		$updated_at = $this->add_column( $table_name, $updated_column_name, 'timestamp', [
			'null'    => false,
			'default' => 'CURRENT_TIMESTAMP',
			'extra'   => 'ON UPDATE CURRENT_TIMESTAMP'
		] );

return $created_at && $updated_at;
	}

/**
	 * Remove timestamps
	 *
	 * @param string $table_name          The table name
	 * @param string $created_column_name Created at column name
	 * @param string $updated_column_name Updated at column name
	 *
	 * @return boolean
	 */
	public function remove_timestamps( $table_name, $created_column_name, $updated_column_name ) {
		if ( empty( $table_name ) ) {
			throw new Ruckusing_Exception( 'Missing table name parameter', Ruckusing_Exception::INVALID_ARGUMENT );
		}
		if ( empty( $created_column_name ) ) {
			throw new Ruckusing_Exception( 'Missing created at column name parameter', Ruckusing_Exception::INVALID_ARGUMENT );
		}
		if ( empty( $updated_column_name ) ) {
			throw new Ruckusing_Exception( 'Missing updated at column name parameter', Ruckusing_Exception::INVALID_ARGUMENT );
		}
		$updated_at = $this->remove_column( $table_name, $created_column_name );
		$created_at = $this->remove_column( $table_name, $updated_column_name );

return $created_at && $updated_at;
	}

/**
	 * Check an index
	 *
	 * @param string $table_name  the table name
	 * @param string $column_name the column name
	 * @param array  $options     index options
	 *
	 * @return boolean
	 * @throws Ruckusing_Exception
	 */
	public function has_index( $table_name, $column_name, $options = [] ) {
		if ( empty( $table_name ) ) {
			throw new Ruckusing_Exception( 'Missing table name parameter', Ruckusing_Exception::INVALID_ARGUMENT );
		}
		if ( empty( $column_name ) ) {
			throw new Ruckusing_Exception( 'Missing column name parameter', Ruckusing_Exception::INVALID_ARGUMENT );
		}
		// did the user specify an index name?
		if ( \is_array( $options ) && \array_key_exists( 'name', $options ) ) {
			$index_name = $options['name'];
		} else {
			$index_name = Ruckusing_Util_Naming::index_name( $table_name, $column_name );
		}
		$indexes = $this->indexes( $table_name );
		foreach ( $indexes as $idx ) {
			if ( $idx['name'] == $index_name ) {
				return true;
			}
		}

return false;
	}

/**
	 * Return all indexes of a table
	 *
	 * @param string $table_name the table name
	 *
	 * @return array
	 */
	public function indexes( $table_name ) {
		$sql     = \sprintf( 'SHOW KEYS FROM %s', $this->identifier( $table_name ) );
		$result  = $this->select_all( $sql );
		$indexes = [];
		$cur_idx = null;
		foreach ( $result as $row ) {
			// skip primary
			if ( $row['Key_name'] == 'PRIMARY' ) {
				continue;
			}
			$cur_idx   = $row['Key_name'];
			$indexes[] = [ 'name' => $row['Key_name'], 'unique' => (int) $row['Non_unique'] == 0 ? true : false ];
		}

return $indexes;
	}

/**
	 * Convert type to sql
	 * $limit = null, $precision = null, $scale = null
	 *
	 * @param string $type the native type
	 * @param array  $options
	 *
	 * @return string
	 * @throws Ruckusing_Exception
	 */
	public function type_to_sql( $type, $options = [] ) {
		$natives = $this->native_database_types();
		if ( ! \array_key_exists( $type, $natives ) ) {
			$error = \sprintf( "Error:I dont know what column type of '%s' maps to for MySQL.", $type );
			$error .= "\nYou provided: {$type}\n";
			$error .= "Valid types are: \n";
			$types = \array_keys( $natives );
			foreach ( $types as $t ) {
				if ( $t == 'primary_key' ) {
					continue;
				}
				$error .= "\t{$t}\n";
			}
			throw new Ruckusing_Exception( $error, Ruckusing_Exception::INVALID_ARGUMENT );
		}
		$scale     = null;
		$precision = null;
		$limit     = null;
		if ( isset( $options['precision'] ) ) {
			$precision = $options['precision'];
		}
		if ( isset( $options['scale'] ) ) {
			$scale = $options['scale'];
		}
		if ( isset( $options['limit'] ) ) {
			$limit = $options['limit'];
		}
		if ( isset( $options['values'] ) ) {
			$values = $options['values'];
		}
		$native_type = $natives[ $type ];
		if ( \is_array( $native_type ) && \array_key_exists( 'name', $native_type ) ) {
			$column_type_sql = $native_type['name'];
		} else {
			return $native_type;
		}
		if ( $type == 'decimal' ) {
			// ignore limit, use precison and scale
			if ( $precision == null && \array_key_exists( 'precision', $native_type ) ) {
				$precision = $native_type['precision'];
			}
			if ( $scale == null && \array_key_exists( 'scale', $native_type ) ) {
				$scale = $native_type['scale'];
			}
			if ( $precision != null ) {
				if ( \is_int( $scale ) ) {
					$column_type_sql .= \sprintf( '(%d, %d)', $precision, $scale );
				} else {
					$column_type_sql .= \sprintf( '(%d)', $precision );
				}
				// scale
			} else {
				if ( $scale ) {
					throw new Ruckusing_Exception( 'Error adding decimal column: precision cannot be empty if scale is specified', Ruckusing_Exception::INVALID_ARGUMENT );
				}
			}
			// precision
		} elseif ( $type == 'float' ) {
			// ignore limit, use precison and scale
			if ( $precision == null && \array_key_exists( 'precision', $native_type ) ) {
				$precision = $native_type['precision'];
			}
			if ( $scale == null && \array_key_exists( 'scale', $native_type ) ) {
				$scale = $native_type['scale'];
			}
			if ( $precision != null ) {
				if ( \is_int( $scale ) ) {
					$column_type_sql .= \sprintf( '(%d, %d)', $precision, $scale );
				} else {
					$column_type_sql .= \sprintf( '(%d)', $precision );
				}
				// scale
			} else {
				if ( $scale ) {
					throw new Ruckusing_Exception( 'Error adding float column: precision cannot be empty if scale is specified', Ruckusing_Exception::INVALID_ARGUMENT );
				}
			}
			// precision
		} elseif ( $type == 'enum' ) {
			if ( empty( $values ) ) {
				throw new Ruckusing_Exception( 'Error adding enum column: there must be at least one value defined', Ruckusing_Exception::INVALID_ARGUMENT );
			} else {
				$column_type_sql .= \sprintf( "('%s')", \implode( "','", \array_map( [
					$this,
					'quote_string'
				], $values ) ) );
			}
		}
		// not a decimal column
		if ( $limit == null && \array_key_exists( 'limit', $native_type ) ) {
			$limit = $native_type['limit'];
		}
		if ( $limit ) {
			$column_type_sql .= \sprintf( '(%d)', $limit );
		}

return $column_type_sql;
	}

/**
	 * Add column options
	 *
	 * @param string $type the native type
	 * @param array  $options
	 *
	 * @return string
	 * @throws Ruckusing_Exception
	 */
	public function add_column_options( $type, $options ) {
		$sql = '';
		if ( ! \is_array( $options ) ) {
			return $sql;
		}
		if ( \array_key_exists( 'unsigned', $options ) && $options['unsigned'] === true ) {
			$sql .= ' UNSIGNED';
		}
		if ( \array_key_exists( 'character', $options ) ) {
			$sql .= \sprintf( ' CHARACTER SET %s', $this->identifier( $options['character'] ) );
		}
		if ( \array_key_exists( 'collate', $options ) ) {
			$sql .= \sprintf( ' COLLATE %s', $this->identifier( $options['collate'] ) );
		}
		if ( \array_key_exists( 'auto_increment', $options ) && $options['auto_increment'] === true ) {
			$sql .= ' auto_increment';
		}
		if ( \array_key_exists( 'default', $options ) && $options['default'] !== null ) {
			if ( $this->is_sql_method_call( $options['default'] ) ) {
				// $default_value = $options['default'];
				throw new Ruckusing_Exception( 'MySQL does not support function calls as default values, constants only.', Ruckusing_Exception::INVALID_ARGUMENT );
			}
			if ( \is_int( $options['default'] ) ) {
				$default_format = '%d';
			} elseif ( \is_bool( $options['default'] ) ) {
				$default_format = "'%d'";
			} elseif ( $options['default'] == 'CURRENT_TIMESTAMP' ) {
				$default_format = '%s';
			} else {
				$default_format = "'%s'";
			}
			$default_value = \sprintf( $default_format, $options['default'] );
			$sql           .= \sprintf( ' DEFAULT %s', $default_value );
		}
		if ( \array_key_exists( 'null', $options ) ) {
			if ( $options['null'] === false || $options['null'] === 'NO' ) {
				$sql .= ' NOT NULL';
			} elseif ( 'timestamp' === $type ) {
				$sql .= ' NULL';
			}
		}
		if ( \array_key_exists( 'comment', $options ) ) {
			$sql .= \sprintf( " COMMENT '%s'", $this->quote_string( $options['comment'] ) );
		}
		if ( \array_key_exists( 'extra', $options ) ) {
			$sql .= \sprintf( ' %s', $this->quote_string( $options['extra'] ) );
		}
		if ( \array_key_exists( 'after', $options ) ) {
			$sql .= \sprintf( ' AFTER %s', $this->identifier( $options['after'] ) );
		}

return $sql;
	}

/**
	 * Set current version
	 *
	 * @param string $version the version
	 *
	 * @return boolean
	 */
	public function set_current_version( $version ) {
		$sql = \sprintf( "INSERT INTO %s (version) VALUES ('%s')", $this->get_schema_version_table_name(), $version );

return $this->execute_ddl( $sql );
	}

/**
	 * remove a version
	 *
	 * @param string $version the version
	 *
	 * @return boolean
	 */
	public function remove_version( $version ) {
		$sql = \sprintf( "DELETE FROM %s WHERE version = '%s'", $this->get_schema_version_table_name(), $version );

return $this->execute_ddl( $sql );
	}

/**
	 * Return a message displaying the current version
	 *
	 * @return string
	 */
	public function __toString() {
		return 'Ruckusing_Adapter, version ' . $this->_version;
	}
	// -----------------------------------
	// PRIVATE METHODS
	// -----------------------------------
	/**
	 * Delegate to PEAR
	 *
	 * @param boolean $o
	 *
	 * @return boolean
	 */
	private function isError( $o ) {
		return $o === false;
	}

/**
	 * Initialize an array of table names
	 *
	 * @param boolean $reload
	 */
	private function load_tables( $reload = true ) {
		global $wpdb;

if ( $this->_tables_loaded == false || $reload ) {
			$this->_tables = [];
			// clear existing structure
			$query = 'SHOW TABLES';
			$res   = $wpdb->get_results( $query, \ARRAY_N );
			// check for errors
			if ( $this->isError( $res ) ) {
				throw new Ruckusing_Exception( \sprintf( "Error executing 'query' with:\n%s\n\nReason: %s\n\n", $query, $wpdb->last_error ), Ruckusing_Exception::QUERY_ERROR );
			}
			foreach ( $res as $row ) {
				$table                   = $row[0];
				$this->_tables[ $table ] = true;
			}
		}
	}

/**
	 * Check query type
	 *
	 * @param string $query query to run
	 *
	 * @return int
	 */
	private function determine_query_type( $query ) {
		$query = \strtolower( \trim( $query ) );
		$match = [];
		\preg_match( '/^(\\w)*/i', $query, $match );
		$type = $match[0];
		switch ( $type ) {
			case 'select':
				return SQL_SELECT;
			case 'update':
				return SQL_UPDATE;
			case 'delete':
				return SQL_DELETE;
			case 'insert':
				return SQL_INSERT;
			case 'alter':
				return SQL_ALTER;
			case 'drop':
				return SQL_DROP;
			case 'create':
				return SQL_CREATE;
			case 'show':
				return SQL_SHOW;
			case 'rename':
				return SQL_RENAME;
			case 'set':
				return SQL_SET;
			default:
				return SQL_UNKNOWN_QUERY_TYPE;
		}
	}

/**
	 * Check query type
	 *
	 * @param $query_type
	 *
	 * @return boolean
	 * @internal param string $query query to run
	 *
	 */
	private function is_select( $query_type ) {
		if ( $query_type == SQL_SELECT ) {
			return true;
		}

return false;
	}

/**
	 * Detect whether or not the string represents a function call and if so
	 * do not wrap it in single-quotes, otherwise do wrap in single quotes.
	 *
	 * @param string $str
	 *
	 * @return boolean
	 */
	private function is_sql_method_call( $str ) {
		$str = \trim( $str );
		if ( \substr( $str, - 2, 2 ) == '()' ) {
			return true;
		} else {
			return false;
		}
	}

/**
	 * Check if in transaction
	 *
	 * @return boolean
	 */
	private function inTransaction() {
		return $this->_in_trx;
	}

/**
	 * Start transaction
	 */
	private function beginTransaction() {
		global $wpdb;

if ( $this->_in_trx === true ) {
			throw new Ruckusing_Exception( 'Transaction already started', Ruckusing_Exception::QUERY_ERROR );
		}
		$wpdb->query( 'START TRANSACTION' );
		$this->_in_trx = true;
	}

/**
	 * Commit a transaction
	 */
	private function commit() {
		global $wpdb;

if ( $this->_in_trx === false ) {
			throw new Ruckusing_Exception( 'Transaction not started', Ruckusing_Exception::QUERY_ERROR );
		}
		$wpdb->query( 'COMMIT' );
		$this->_in_trx = false;
	}

/**
	 * Rollback a transaction
	 */
	private function rollback() {
		global $wpdb;

if ( $this->_in_trx === false ) {
			throw new Ruckusing_Exception( 'Transaction not started', Ruckusing_Exception::QUERY_ERROR );
		}
		$wpdb->query( 'ROLLBACK' );
		$this->_in_trx = false;
	}
}

[+] ..
[-] model.php [edit]
[-] orm.php [edit]
[-] ruckusing-adapter.php [edit]
[-] ruckusing-framework-runner.php [edit]