1
0
Fork 0
MySQLDumper/library/Msd/Db/MysqlCommon.php
2011-06-10 21:55:32 +00:00

533 Zeilen
16 KiB
PHP

<?php
/**
* This file is part of MySQLDumper released under the GNU/GPL 2 license
* http://www.mysqldumper.net
*
* @package MySQLDumper
* @subpackage Db
* @version SVN: $rev: 1205 $
* @author $Author$
*/
/**
* Class offers some db related methods that are equal for Mysql and MySQLi.
*
* @package MySQLDumper
* @subpackage Db
*/
abstract class Msd_Db_MysqlCommon extends Msd_Db
{
/**
* Get the list of table and view names of given database
*
* @param string $dbName Name of database
*
* @return array
*/
public function getTables($dbName)
{
$tables = array();
$sql = 'SHOW TABLES FROM `' . $dbName . '`';
$res = $this->query($sql, self::ARRAY_NUMERIC);
foreach ($res as $val) {
$tables[] = $val[0];
}
return $tables;
}
/**
* Get the list of tables of the given database. The result include tables
* meta data.
*
* @param string $dbName Name of database
*
* @return array
*/
public function getTablesMeta($dbName)
{
$tablesSql = 'SELECT * FROM `information_schema`.`TABLES` '
. 'WHERE `TABLE_SCHEMA` = \'' . $this->escape($dbName) . '\'';
$rawTables = $this->query($tablesSql, self::ARRAY_ASSOC);
$tables = array();
foreach ($rawTables as $rawTable) {
$tables[$rawTable['TABLE_NAME']] = $rawTable;
}
return $tables;
}
/**
* Get information of databases
*
* Gets list and info of all databases that the actual MySQL-User can access
* and saves it in $this->databases.
*
* @param bool $addViews If set nr of views and routines are added
*
* @return array
*/
public function getDatabases($addViews = false)
{
$query = 'SELECT `is`.*, count(`t`.`TABLE_NAME`) `tables`'
. ' FROM `information_schema`.`SCHEMATA` `is`'
. ' LEFT JOIN `information_schema`.`TABLES` `t` '
. ' ON `t`.`TABLE_SCHEMA` = `is`.`SCHEMA_NAME`'
. ' GROUP BY `is`.`SCHEMA_NAME`'
. ' ORDER BY `is`.`SCHEMA_NAME` ASC';
$res = $this->query($query, self::ARRAY_ASSOC, true);
if ($addViews) {
$views = $this->getNrOfViews();
$routines = $this->getNrOfRoutines();
$sizes = $this->getDatabaseSizes();
}
foreach ($res as $row) {
$database = $row['SCHEMA_NAME'];
if ($addViews) {
$row['views'] = 0;
$row['routines'] = 0;
$row['size'] = 0;
$row[$database] = 0;
if (isset($sizes[$database])) {
$row['size'] = $sizes[$database];
}
// add views
if (isset($views[$database])) {
$row['views'] = $views[$database];
$row['tables'] -= $views[$database];
}
// add routines
if (isset($routines[$database])) {
$row['routines'] = $routines[$database];
}
}
unset($row['SCHEMA_NAME']);
$this->_databases[$database] = $row;
}
return $this->_databases;
}
/**
* Return assoc array with the names of accessable databases
*
* @return array Assoc array with database names
*/
public function getDatabaseNames()
{
if ($this->_databases == null) {
$this->getDatabases();
}
return array_keys($this->_databases);
}
/**
* Returns the actual selected database.
*
* @return string
*/
public function getSelectedDb()
{
return $this->_dbSelected;
}
/**
* Returns the CREATE Statement of a table.
*
* @param string $table
*
* @return string
*/
public function getTableCreate($table)
{
$sql = 'SHOW CREATE TABLE `' . $table . '`';
$res = $this->query($sql, self::ARRAY_ASSOC);
return $res[0]['Create Table'];
}
/**
* Gets the full description of all columns of a table.
*
* Saves it to $this->metaTables[$database][$table].
*
* @param string $table
*
* @return array
*/
public function getTableColumns($table)
{
$dbName = $this->getSelectedDb();
$sql = 'SHOW FULL FIELDS FROM `' . $table . '`';
$res = $this->query($sql, self::ARRAY_ASSOC);
if (!isset($this->_metaTables[$dbName])) {
$this->_metaTables[$dbName] = array();
}
if (is_array($res)) {
$this->_metaTables[$dbName][$table] = array();
foreach ($res as $r) {
$this->_metaTables[$dbName][$table][$r['Field']] = $r;
}
}
return $this->_metaTables[$dbName][$table];
}
/**
* Optimize given table.
*
* Returns false on error or Sql's Msg_text if query succeeds.
*
* @param string $table Name of table
*
* @return array
*/
public function optimizeTable($table)
{
return $this->_executeMaintainAction('OPTIMIZE', $table);
}
/**
* Analyze given table.
*
* Returns false on error or Sql's Msg_text if query succeeds.
*
* @param string $table Name of table
*
* @return array
*/
public function analyzeTable($table)
{
return $this->_executeMaintainAction('ANALYZE', $table);
}
/**
* Check given table.
*
* Returns false on error or Sql's Msg_text if query succeeds.
*
* @param string $table Name of table
*
* @return array
*/
public function checkTable($table)
{
return $this->_executeMaintainAction('CHECK', $table);
}
/**
* Repair given table.
*
* Returns false on error or Sql's Msg_text if query succeeds.
*
* @param string $table Name of table
*
* @return array
*/
public function repairTable($table)
{
return $this->_executeMaintainAction('REPAIR', $table);
}
/**
* Truncate a table (delete all records)
*
* @param string $table The tabel to truncate
*
* @return bool
*/
public function truncateTable($table)
{
$sql = 'TRUNCATE `' . $this->escape($table) . '`';
$res = $this->query($sql, self::SIMPLE);
return $res;
}
/**
* Execute maintaining action on a table (optimize, analyze, check, repair)
*
* @param string $action Action to perform
*
* @return array Result array conataining messages
*/
private function _executeMaintainAction($action, $table)
{
$sql = $action . ' TABLE `' . $this->escape($table) . '`';
try {
$res = $this->query($sql, Msd_Db::ARRAY_ASSOC);
if (isset($res[0]['Msg_text'])) {
return $res[0];
}
} catch (Msd_Exception $e) {
unset($e);
}
$ret = array('Table' => $table);
return array_merge($ret, $this->getLastError());
}
/**
* Get list of known charsets from MySQL-Server.
*
* @return array
*/
public function getCharsets()
{
if (!empty($this->_charsets)) {
return $this->_charsets;
}
$sql = 'SELECT * FROM `information_schema`.`CHARACTER_SETS` ORDER BY `CHARACTER_SET_NAME`';
$result = $this->query($sql, self::ARRAY_ASSOC);
$this->_charsets = array();
foreach ($result as $res) {
$this->_charsets[$res['CHARACTER_SET_NAME']] = $res;
}
return $this->_charsets;
}
/**
* Gets extended table information for one or all tables.
*
* @param string | false $tableName
* @param string | false $databaseName
*
* @return array
*/
public function getTableStatus($tableName = false, $databaseName = false)
{
if ($databaseName === false) {
$databaseName = $this->getSelectedDb();
}
$sql = "SELECT * FROM `information_schema`.`TABLES` WHERE "
. "`TABLE_SCHEMA`='" . $this->escape($databaseName) . "'";
if ($tableName !== false) {
$sql .= " AND `TABLE_NAME` LIKE '" . $this->escape($tableName) . "'";
}
$res = $this->query($sql, self::ARRAY_ASSOC);
return $res;
}
/**
* Get variables of SQL-Server and return them as assoc array
*
* @return array
*/
public function getVariables()
{
$ret = array();
$variables = $this->query('SHOW VARIABLES', Msd_Db::ARRAY_ASSOC);
foreach ($variables as $val) {
$ret[$val['Variable_name']] = $val['Value'];
}
return $ret;
}
/**
* Get global status variables of SQL-Server and return them as assoc array
*
* @return array
*/
public function getGlobalStatus()
{
$ret = array();
$variables = $this->query('SHOW GLOBAL STATUS', Msd_Db::ARRAY_ASSOC);
foreach ($variables as $val) {
$ret[$val['Variable_name']] = $val['Value'];
}
return $ret;
}
/**
* Get the number of records of a table by query SELECT COUNT(*)
*
* @param string $tableName The name of the table
* @param string $dbName The name of the database
*
* @return integer The number of rows isnide table
*/
public function getNrOfRowsBySelectCount($tableName, $dbName = null)
{
if ($dbName === null) {
$dbName = $this->getSelectedDb();
}
;
$sql = 'SELECT COUNT(*) as `Rows` FROM `%s`.`%s`';
$sql = sprintf($sql, $this->escape($dbName), $this->escape($tableName));
$rows = $this->query($sql, Msd_Db::ARRAY_ASSOC);
return (int)$rows[0]['Rows'];
}
/**
* Retrieves the collations from information schema.
*
* @param string|null $charsetName Name of the charset
*
* @return array
*/
public function getCollations($charsetName = null)
{
$where = "";
if (!empty($charsetName)) {
$where = "WHERE `CHARACTER_SET_NAME` = '" . $this->escape($charsetName) . "'";
}
$collationSql = "SELECT `CHARACTER_SET_NAME` `charset`, "
. "GROUP_CONCAT(`COLLATION_NAME` ORDER BY `COLLATION_NAME`) "
. "`collations` FROM `information_schema`."
. "`COLLATION_CHARACTER_SET_APPLICABILITY` GROUP BY "
. "`CHARACTER_SET_NAME` $where";
$rawCollations = $this->query($collationSql, Msd_Db::ARRAY_ASSOC);
$collations = array();
foreach ($rawCollations as $charset) {
$collations[$charset['charset']] = explode(
",",
$charset['collations']
);
}
return $collations;
}
/**
* Retrieves the default collation for the charset or the given charset.
*
* @param string|null $charsetName Name of the charset
*
* @return array|string
*/
public function getDefaultCollations($charsetName = null)
{
if (!empty($charsetName)) {
$defaultCollationSql = 'SELECT `DEFAULT_COLLATE_NAME` FROM '
. '`information_schema`.`CHARACTER_SETS` WHERE '
. '`CHARACTER_SET_NAME` = \'' . $this->escape($charsetName)
. '\'';
$result = $this->query($defaultCollationSql, self::ARRAY_NUMERIC);
$defaultCollation = $result[0][0];
} else {
$defaultCollationSql = 'SELECT `CHARACTER_SET_NAME` `charset`, '
. '`DEFAULT_COLLATE_NAME` `collation` FROM '
. '`information_schema`.`CHARACTER_SETS`';
$result = $this->query($defaultCollationSql, self::ARRAY_ASSOC);
$defaultCollation = array();
foreach ($result as $row) {
$defaultCollation[$row['charset']] = $row['collation'];
}
}
return $defaultCollation;
}
/**
* Gets the views of the given database.
*
* @param string $dbName Name of database
*
* @return array
*/
public function getViews($dbName)
{
$sql = 'SELECT * FROM `information_schema`.`VIEWS` WHERE '
. '`TABLE_SCHEMA` = \'' . $this->escape($dbName) . '\'';
$rawViews = $this->query($sql, self::ARRAY_ASSOC);
$views = array();
foreach ($rawViews as $rawView) {
$views[$rawView['TABLE_NAME']] = $rawView;
}
return $views;
}
/**
* Get the number of views per database.
*
* @return array
*/
public function getNrOfViews()
{
$sql = 'SELECT `TABLE_SCHEMA`, count(*) as `views` FROM '
. '`information_schema`.`VIEWS` '
. ' GROUP BY `TABLE_SCHEMA`';
$res = $this->query($sql, self::ARRAY_ASSOC);
$views = array();
foreach ($res as $view) {
$views[$view['TABLE_SCHEMA']] = $view['views'];
}
return $views;
}
/**
* Get the number of routines (procedures and functions).
*
* @return array
*/
public function getNrOfRoutines()
{
$sql = 'SELECT `ROUTINE_SCHEMA`, count(`ROUTINE_NAME`) as `routines`'
. ' FROM `information_schema`.`ROUTINES` '
. ' GROUP BY `ROUTINE_SCHEMA`';
$res = $this->query($sql, self::ARRAY_ASSOC);
$routines = array();
foreach ($res as $routine) {
$routines[$routine['ROUTINE_SCHEMA']] = $routine['routines'];
}
return $routines;
}
/**
* Get the size of tabledata in bytes
*
* @return array
*/
public function getDatabaseSizes()
{
$sql = 'SELECT `TABLE_SCHEMA`, sum(`DATA_LENGTH`) as `size`'
. ' FROM `information_schema`.`TABLES` '
. ' GROUP BY `TABLE_SCHEMA`';
$res = $this->query($sql, self::ARRAY_ASSOC);
$sizes = array();
foreach ($res as $size) {
$sizes[$size['TABLE_SCHEMA']] = $size['size'];
}
return $sizes;
}
/**
* Gets the stored procedurs of the given database.
*
* @param string $dbName Name of database
*
* @return array
*/
public function getStoredProcedures($dbName)
{
$routinesSql = 'SELECT * FROM `information_schema`.`ROUTINES` WHERE '
. '`ROUTINE_SCHEMA` = \'' . $this->escape($dbName) . '\'';
$rawRoutines = $this->query($routinesSql, self::ARRAY_ASSOC);
$routines = array();
foreach ($rawRoutines as $rawRoutine) {
$routines[$rawRoutine['ROUTINE_NAME']] = $rawRoutine;
}
return $routines;
}
/**
* Creates a new database via building a MySQL statement and its execution.
*
* @param string $databaseName Name of the new database
* @param string $databaseCharset Charackter set of the new database
* @param string $databaseCollation Collation of the new database
*
* @return boolean
*/
public function createDatabase(
$databaseName,
$databaseCharset = '',
$databaseCollation = ''
)
{
if ($databaseCharset != '') {
$databaseCharset = "DEFAULT CHARSET "
. $this->escape($databaseCharset);
}
if ($databaseCollation != '') {
$databaseCollation = "DEFAULT COLLATE "
. $this->escape($databaseCollation);
}
$sql = "CREATE DATABASE `" . $databaseName
. "` $databaseCharset $databaseCollation";
$dbCreated = $this->query($sql, Msd_Db::SIMPLE);
return $dbCreated;
}
}