MySQLのバックアップ

当初、バックアップに SHOW CREATE TABLE + ergodic を使用することを考えていましたが、テーブルにコメントがあり、文字化けしている場合、SHOW CREATE TABLE から出力されるスクリプトにシンボルが欠けていることがわかりました。それでこのバージョンがあります。

 class MysqlExport{

 /**
 * データベース接続
*/
 private $_db;

 private $_resource;

 /**
 * テーブル構造SQLを作成します
*/
 private $_create_table = '' ;

 public function __construct($host = '', $user = '', $pass = '', $db = '', $port = 3306) {
 if (empty($host) || empty($ user)) {

 } else {
 $this->real_connect($host, $user, $pass, $db, $port);
 }
 }

 public function init() {
 return $this;
 }

 /**
 * データベースに接続します
*/
 public function real_connect($host, $user, $pass, $db = '', $port = 3306) {
 $this->_db = mysql_connect($host . ':' . $port, $user, $pass);
 if ($db) {
 $this->select_db($db);
 }
 return $this->init();
 }

 /**
 * データベースを選択してください
*/
 public function select_db($db) {
 if (mysql_select_db($db, $this->_db)) {
 return true;
 }
 }

 /**
 * クエリステートメント
*/
 public function query($sql) {
 if ($this->_db) {
 if ($this->_resource = mysql_query($sql, $this->_db)) {
 return $ this->init();
 }
 }
 throw new Exception($this->get_error());
 }

 /**
 * 結果セットを取得します
*/
 public function fetch_array($arg = MYSQL_BOTH) {
 $result = array();
 if ($this->_resource && !mysql_errno($this->gt;_db)) {
 while ($rs = mysql_fetch_array($this->_resource, $arg)) {
 $result[] = $rs;
 }
 }
 return $result;
 }

 /**
 * エラーが発生する
*/
 public function get_error() {
 return mysql_errno($this->_db) . ":" 。 mysql_error($this->_db)。 "n";
 }

 /**
 *データテーブルを表示
*/
 public function show_tables($table = '') {
 $sql = "SHOW TABLES";
 $sql .= $table ? " LIKE '{$table}'" : '';
 $result = $this->query($sql)->fetch_array(MYSQL_ASSOC);
 return $result;
 }

 /**
 *データテーブルのフィールドを表示します
 */
 public function show_columns($table) {
 if (empty($table)) {
 return array();
 }
 $sql = "{$table} からの全列を表示";
 $result = $this ->query($sql)->fetch_array(MYSQL_ASSOC);
 return $result;
 }

 /**
 * データテーブルのステータスを表示します
*/
 public function show_table_status($table) {
 if (empty($table) ) {
 return array();
 }
 $result = $this->query("SHOW TABLE STATUS LIKE '{$table}'")->fetch_array(MYSQL_ASSOC);
 $result = restart($result );
 return $result;
 }

 /**
 *データテーブル構造を表示
*/
 public function show_create_table($table) {
 if (empty($table)) {
 return '';
 }
 $this-> ;_create_table = "存在しない場合はテーブルを作成します `{$table}`(" . PHP_EOL;
 $table_status = $this->show_table_status($table);
 $columns = $this->show_columns($table);

 foreach ($columns AS $col) {
 $this->_create_table .= "`{$col['Field']}` {$col['Type']} NOT NULL {$col['Extra' ]}," . PHP_EOL;
 }

 $this->_create_table .= $this->create_indexSyntax($table);

 $char = substr($table_status['照合'], 0, strpos($table_status['照合' ], '_'));
 $table_status['Auto_increment'] = $table_status['Auto_increment'] ? $table_status['Auto_increment'] : 0;
 $this->_create_table .= ")Engine={$table_status['Engine']} AUTO_INCREMENT={$table_status['Auto_increment']} DEFAULT CHARSET={$char} ;" 。 str_repeat(PHP_EOL, 3);

 return $this->_create_table;
 }

 /**
 *トリガーを表示
*/
 public function show_constraint($db_name) {
 if (empty($db_name)) {
 return array();
 }
 $sql = "SELECT a.CONSTRAINT_NAME AS constrint_name、a.TABLE_name AS table_name、a.COLUMN_NAME AS column_name、a.REFERENCED_TABLE_NAME AS Referenced_table_name、a.REFERENCED_COLUMN_NAME AS Referenced_column_name、b.UPDATE_RULE as update_rule、b. DELETE_RULE AS delete_rule FROM information_schema.KEY_COLUMN_USAGE AS a LEFT JOIN information_schema.REFERENTIAL_CONSTRAINTS AS b ON a.constraint_name=b.constraint_name WHERE a.constraint_schema = '{$db_name}' AND a.POSITION_IN_UNIQUE_CONSTRAINT = 1";
 $result = $これ- >query($sql)->fetch_array(MYSQL_ASSOC);
 }

 /**
 * インデックスを表示
*/
 public function show_index($table) {
 if (empty($table)) {
 return array( );
 }
 $sql = "SHOW INDEX FROM {$table}";
 $result = $this->query($sql)->fetch_array(MYSQL_ASSOC);
 return $result;
 }

 /**
 *データベース構造を表示します
*/
 public function show_database_char() {
 $sql = "SHOW VARIABLES LIKE 'character_set_database'";
 $char = $this->query($sql)->fetch_array(MYSQL_ASSOC);
 return reverse($ char);
 }

 /**
 * インデックス構文を作成します
*/
 public function create_indexSyntax($table) {
 if (empty($table)) {
 return array();
 }
 $indexing = $this-> ;show_index($table);
 $syntax = array();
 $indexSyntax = array();
 foreach ($index としての $indexing) {
 $syntax[$index['Index_type']][$index[' Key_name']][] = $index['Column_name'];
 }

 foreach ($syntax as $index_type => $index_value) {
 foreach ($index_value as $key_name => $columns) {
 if ($key_name == 'PRIMARY') {
 $indexSyntax[] = 'PRIMARY KEY (`' . implode("`,`", $columns) . '`)';
 } else {
 if ($index_type = = 'FULLTEXT') {
 $indexSyntax[] = "FULLTEXT KEY `{$key_name}` (`" . implode("`,`", $columns) . '`)';
 } else{
 $indexSyntax[] = "KEY `{$key_name}` USING {$index_type} (`" . implode("`,`", $columns) . '`)';
 }
 }
 }
 }

 return implode(',' . PHP_EOL, $indexSyntax) 。 PHP_EOL;
 }

 /**
 * 挿入構文を作成します
*/
 public function create_insertSyntax($table) {
 if (empty($table)) {
 return '';
 }
 $sql = "SELECT * FROM {$ table}";
 $result = $this->query($sql)->fetch_array(MYSQL_ASSOC);
 $insertStr = '';
 if ($result) {
 $first = reverse($result);
 $key = implode('`,`', array_keys($first));
 $insert = "`{$table}` (`{$key}`) VALUES ";
 $valuesStr = array() ;
 foreach ($result as $value) {
 $values = array();
 foreach ($value as $v) {
 $v = mysql_real_escape_string($v);
 $values[] = preg_replace("#\ +#", "\", $v);
 }
 $valuesStr[] = "('" . implode("','", $values) . "')";
 }
 $valuesStr = array_chunk( $valuesStr, 5000);
 foreach ($valuesStr as $str) {
 $insertStr .= $insert . implode(',', $str) 。 「;」 。 PHP_EOL;
 }

 }
 $insertStr を返します。 str_repeat(PHP_EOL, 3);
 }

 }

 $export = '';
 $test = new MysqlExport('localhost', 'root', '', 'pm_cms');
 $char = $test- >show_database_char();
 $test->query("SET NAMES {$char['Value']}");
 $tables = $test->show_tables();
 foreach ($tables を $table として) ) {
 list($table_name) = array_values($table);
 $export .= $test->show_create_table($table_name);
 $export .= $test->create_insertSyntax($table_name);
 }
 $fp = fopen('pm_cms.sql', 'w');
 fwrite($fp, $export);
 fclose($fp);
?>