438 lines
11 KiB
PHP
438 lines
11 KiB
PHP
<?php
|
|
/* vim: set expandtab sw=4 ts=4 sts=4: */
|
|
/**
|
|
* Library for extracting information about the partitions
|
|
*
|
|
* @package PhpMyAdmin
|
|
*/
|
|
if (! defined('PHPMYADMIN')) {
|
|
exit;
|
|
}
|
|
|
|
/**
|
|
* Represents a sub partition of a table
|
|
*
|
|
* @package PhpMyAdmin
|
|
*/
|
|
class PMA_SubPartition
|
|
{
|
|
/**
|
|
* @var string the database
|
|
*/
|
|
protected $db;
|
|
/**
|
|
* @var string the table
|
|
*/
|
|
protected $table;
|
|
/**
|
|
* @var string partition name
|
|
*/
|
|
protected $name;
|
|
/**
|
|
* @var integer ordinal
|
|
*/
|
|
protected $ordinal;
|
|
/**
|
|
* @var string partition method
|
|
*/
|
|
protected $method;
|
|
/**
|
|
* @var string partition expression
|
|
*/
|
|
protected $expression;
|
|
/**
|
|
* @var integer no of table rows in the partition
|
|
*/
|
|
protected $rows;
|
|
/**
|
|
* @var integer data length
|
|
*/
|
|
protected $dataLength;
|
|
/**
|
|
* @var integer index length
|
|
*/
|
|
protected $indexLength;
|
|
/**
|
|
* @var string partition comment
|
|
*/
|
|
protected $comment;
|
|
|
|
/**
|
|
* Constructs a partition
|
|
*
|
|
* @param array $row fetched row from information_schema.PARTITIONS
|
|
*/
|
|
public function __construct($row)
|
|
{
|
|
$this->db = $row['TABLE_SCHEMA'];
|
|
$this->table = $row['TABLE_NAME'];
|
|
$this->loadData($row);
|
|
}
|
|
|
|
/**
|
|
* Loads data from the fetched row from information_schema.PARTITIONS
|
|
*
|
|
* @param array $row fetched row
|
|
*
|
|
* @return void
|
|
*/
|
|
protected function loadData($row)
|
|
{
|
|
$this->name = $row['SUBPARTITION_NAME'];
|
|
$this->ordinal = $row['SUBPARTITION_ORDINAL_POSITION'];
|
|
$this->method = $row['SUBPARTITION_METHOD'];
|
|
$this->expression = $row['SUBPARTITION_EXPRESSION'];
|
|
$this->loadCommonData($row);
|
|
}
|
|
|
|
/**
|
|
* Loads some data that is common to both partitions and sub partitions
|
|
*
|
|
* @param array $row fetched row
|
|
*
|
|
* @return void
|
|
*/
|
|
protected function loadCommonData($row)
|
|
{
|
|
$this->rows = $row['TABLE_ROWS'];
|
|
$this->dataLength = $row['DATA_LENGTH'];
|
|
$this->indexLength = $row['INDEX_LENGTH'];
|
|
$this->comment = $row['PARTITION_COMMENT'];
|
|
}
|
|
|
|
/**
|
|
* Return the partition name
|
|
*
|
|
* @return string partition name
|
|
*/
|
|
public function getName()
|
|
{
|
|
return $this->name;
|
|
}
|
|
|
|
/**
|
|
* Return the ordinal of the partition
|
|
*
|
|
* @return number the ordinal
|
|
*/
|
|
public function getOrdinal()
|
|
{
|
|
return $this->ordinal;
|
|
}
|
|
|
|
/**
|
|
* Returns the partition method
|
|
*
|
|
* @return string partition method
|
|
*/
|
|
public function getMethod()
|
|
{
|
|
return $this->method;
|
|
}
|
|
|
|
/**
|
|
* Returns the partition expression
|
|
*
|
|
* @return string partition expression
|
|
*/
|
|
public function getExpression()
|
|
{
|
|
return $this->expression;
|
|
}
|
|
|
|
/**
|
|
* Returns the number of data rows
|
|
*
|
|
* @return integer number of rows
|
|
*/
|
|
public function getRows()
|
|
{
|
|
return $this->rows;
|
|
}
|
|
|
|
/**
|
|
* Returns the data length
|
|
*
|
|
* @return integer data length
|
|
*/
|
|
public function getDataLength()
|
|
{
|
|
return $this->dataLength;
|
|
}
|
|
|
|
/**
|
|
* Returns the index length
|
|
*
|
|
* @return integer index length
|
|
*/
|
|
public function getIndexLength()
|
|
{
|
|
return $this->indexLength;
|
|
}
|
|
|
|
/**
|
|
* Returns the partition comment
|
|
*
|
|
* @return string partition comment
|
|
*/
|
|
public function getComment()
|
|
{
|
|
return $this->comment;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* base Partition Class
|
|
*
|
|
* @package PhpMyAdmin
|
|
*/
|
|
class PMA_Partition extends PMA_SubPartition
|
|
{
|
|
/**
|
|
* @var string partition description
|
|
*/
|
|
protected $description;
|
|
/**
|
|
* @var PMA_SubPartition[] sub partitions
|
|
*/
|
|
protected $subPartitions = array();
|
|
|
|
/**
|
|
* Loads data from the fetched row from information_schema.PARTITIONS
|
|
*
|
|
* @param array $row fetched row
|
|
*
|
|
* @return void
|
|
*/
|
|
protected function loadData($row)
|
|
{
|
|
$this->name = $row['PARTITION_NAME'];
|
|
$this->ordinal = $row['PARTITION_ORDINAL_POSITION'];
|
|
$this->method = $row['PARTITION_METHOD'];
|
|
$this->expression = $row['PARTITION_EXPRESSION'];
|
|
$this->description = $row['PARTITION_DESCRIPTION'];
|
|
// no sub partitions, load all data to this object
|
|
if (empty($row['SUBPARTITION_NAME'])) {
|
|
$this->loadCommonData($row);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Returns the partiotion description
|
|
*
|
|
* @return string partition description
|
|
*/
|
|
public function getDescription()
|
|
{
|
|
return $this->description;
|
|
}
|
|
|
|
/**
|
|
* Add a sub partition
|
|
*
|
|
* @param PMA_SubPartition $partition Sub partition
|
|
*
|
|
* @return void
|
|
*/
|
|
public function addSubPartition(PMA_SubPartition $partition)
|
|
{
|
|
$this->subPartitions[] = $partition;
|
|
}
|
|
|
|
/**
|
|
* Whether there are sub partitions
|
|
*
|
|
* @return boolean
|
|
*/
|
|
public function hasSubPartitions()
|
|
{
|
|
return ! empty($this->subPartitions);
|
|
}
|
|
|
|
/**
|
|
* Returns the number of data rows
|
|
*
|
|
* @return integer number of rows
|
|
*/
|
|
public function getRows()
|
|
{
|
|
if (empty($this->subPartitions)) {
|
|
return $this->rows;
|
|
} else {
|
|
$rows = 0;
|
|
foreach ($this->subPartitions as $subPartition) {
|
|
$rows += $subPartition->rows;
|
|
}
|
|
return $rows;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Returns the total data length
|
|
*
|
|
* @return integer data length
|
|
*/
|
|
public function getDataLength()
|
|
{
|
|
if (empty($this->subPartitions)) {
|
|
return $this->dataLength;
|
|
} else {
|
|
$dataLength = 0;
|
|
foreach ($this->subPartitions as $subPartition) {
|
|
$dataLength += $subPartition->dataLength;
|
|
}
|
|
return $dataLength;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Returns the tatal index length
|
|
*
|
|
* @return integer index length
|
|
*/
|
|
public function getIndexLength()
|
|
{
|
|
if (empty($this->subPartitions)) {
|
|
return $this->indexLength;
|
|
} else {
|
|
$indexLength = 0;
|
|
foreach ($this->subPartitions as $subPartition) {
|
|
$indexLength += $subPartition->indexLength;
|
|
}
|
|
return $indexLength;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Returns the list of sub partitions
|
|
*
|
|
* @return PMA_SubPartition[]
|
|
*/
|
|
public function getSubPartitions()
|
|
{
|
|
return $this->subPartitions;
|
|
}
|
|
|
|
/**
|
|
* Returns array of partitions for a specific db/table
|
|
*
|
|
* @param string $db database name
|
|
* @param string $table table name
|
|
*
|
|
* @access public
|
|
* @return PMA_Partition[]
|
|
*/
|
|
static public function getPartitions($db, $table)
|
|
{
|
|
if (PMA_Partition::havePartitioning()) {
|
|
$result = $GLOBALS['dbi']->fetchResult(
|
|
"SELECT * FROM `information_schema`.`PARTITIONS`"
|
|
. " WHERE `TABLE_SCHEMA` = '" . PMA_Util::sqlAddSlashes($db)
|
|
. "' AND `TABLE_NAME` = '" . PMA_Util::sqlAddSlashes($table) . "'"
|
|
);
|
|
if ($result) {
|
|
$partitionMap = array();
|
|
foreach ($result as $row) {
|
|
if (isset($partitionMap[$row['PARTITION_NAME']])) {
|
|
$partition = $partitionMap[$row['PARTITION_NAME']];
|
|
} else {
|
|
$partition = new PMA_Partition($row);
|
|
$partitionMap[$row['PARTITION_NAME']] = $partition;
|
|
}
|
|
|
|
if (! empty($row['SUBPARTITION_NAME'])) {
|
|
$parentPartition = $partition;
|
|
$partition = new PMA_SubPartition($row);
|
|
$parentPartition->addSubPartition($partition);
|
|
}
|
|
}
|
|
return array_values($partitionMap);
|
|
}
|
|
return array();
|
|
} else {
|
|
return array();
|
|
}
|
|
}
|
|
|
|
/**
|
|
* returns array of partition names for a specific db/table
|
|
*
|
|
* @param string $db database name
|
|
* @param string $table table name
|
|
*
|
|
* @access public
|
|
* @return array of partition names
|
|
*/
|
|
static public function getPartitionNames($db, $table)
|
|
{
|
|
if (PMA_Partition::havePartitioning()) {
|
|
return $GLOBALS['dbi']->fetchResult(
|
|
"SELECT `PARTITION_NAME` FROM `information_schema`.`PARTITIONS`"
|
|
. " WHERE `TABLE_SCHEMA` = '" . PMA_Util::sqlAddSlashes($db)
|
|
. "' AND `TABLE_NAME` = '" . PMA_Util::sqlAddSlashes($table) . "'"
|
|
);
|
|
} else {
|
|
return array();
|
|
}
|
|
}
|
|
|
|
/**
|
|
* returns the partition method used by the table.
|
|
*
|
|
* @param string $db database name
|
|
* @param string $table table name
|
|
*
|
|
* @return string partition method
|
|
*/
|
|
static public function getPartitionMethod($db, $table)
|
|
{
|
|
if (PMA_Partition::havePartitioning()) {
|
|
$partition_method = $GLOBALS['dbi']->fetchResult(
|
|
"SELECT `PARTITION_METHOD` FROM `information_schema`.`PARTITIONS`"
|
|
. " WHERE `TABLE_SCHEMA` = '" . PMA_Util::sqlAddSlashes($db) . "'"
|
|
. " AND `TABLE_NAME` = '" . PMA_Util::sqlAddSlashes($table) . "'"
|
|
);
|
|
if (! empty($partition_method)) {
|
|
return $partition_method[0];
|
|
}
|
|
}
|
|
return null;
|
|
}
|
|
|
|
/**
|
|
* checks if MySQL server supports partitioning
|
|
*
|
|
* @static
|
|
* @staticvar boolean $have_partitioning
|
|
* @staticvar boolean $already_checked
|
|
* @access public
|
|
* @return boolean
|
|
*/
|
|
static public function havePartitioning()
|
|
{
|
|
static $have_partitioning = false;
|
|
static $already_checked = false;
|
|
|
|
if (! $already_checked) {
|
|
if (PMA_MYSQL_INT_VERSION < 50600) {
|
|
if ($GLOBALS['dbi']->fetchValue(
|
|
"SELECT @@have_partitioning;"
|
|
)) {
|
|
$have_partitioning = true;
|
|
}
|
|
} else {
|
|
// see http://dev.mysql.com/doc/refman/5.6/en/partitioning.html
|
|
$plugins = $GLOBALS['dbi']->fetchResult("SHOW PLUGINS");
|
|
foreach ($plugins as $value) {
|
|
if ($value['Name'] == 'partition') {
|
|
$have_partitioning = true;
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
$already_checked = true;
|
|
}
|
|
return $have_partitioning;
|
|
}
|
|
}
|