• 異なるストレージエンジン間のレプリケーションって何？
  つまり以下のような構成のレプリケーションのことです。
  
  ちょっと前回の「InfiniDB でリアルタイムDWHを作る PART3 ～驚速DWHの構築」のBLACKBOXの部分の話の種明かしをしてしまうと、リアルタイムのしくみは、このフェデレーションによる透過的なテーブル更新を利用してDWHに書き込んでしまえ！という話だったのです。実は今のところ、この試みはさまざまな問題があり、うまいこと話が進まない状態なので今現在は、ちゃんと説明できる状態にはなっておりません。すみません。それはさておき、上記の図は
  InnoDBのTAB1 (MASTER）→ FederationのTAB1 (SLAVE）→MyISAMのTABとう連鎖的なデータ更新を実現している図です。基本的（INSERT,UPDATE,DELETE）なことであれば、これで問題なく動きます。しかも速い！です。じゃあここで説明する、基本的なこと以外って何？ですが、InnoDBのTAB1 (MASTER）のTAB1の定義が変更になった場合のことを言います。通常、InnoDB→InnoDBのレプリケーションであれば定義の変更も問題なく行われます。うーそうですね。たとえば、schema1（MASTER)のTAB1にカラムが１つ追加になった場合などですかね・・。
  MySQLの良いところとしては、データの変更(DML）だけでなく定義の変更(DDL）もレプリケーションしてくれるというところだと思います。しかし、今回のように、InnoDB->Federationのレプリケーションの少し変わった構成でのレプリケーションなどを行った場合は、その便利な機能が災いします。・・で結果からいうとレプリケーションエラーになります。理由は、「Feaderation」ストレージエンジンは、ALTER TABLE等の定義変更をサポートしていないからです。Feaderationの定義変更は、基本、Drop & Create です。そういう仕様です。これはこれでしょうがない・・。
• エラーでレプリケーションを止めないために
  このままの状態で運用のラインに乗せた場合、定義の変更の作業が入ったと同時に必ずレプリケーションエラーが発生してしまいます。ん？スレーブ側のレプリケーションを止めて（stop slave）、スレーブ→マスターの順で定義を変更すれば問題ないんじゃないの？んー無理無理、スレーブ側を再会（start slave）したと同時にマスターの定義変更がレプリケーションしてくるので結局レプリケーションエラーになってしまうのです。
• 結局エラーになるんじゃん？
  はい、残念ながら結局エラーになるのです・・。
  もうエラーになるのがわかった以上、そのエラーはスルーしてレプリケーションを続けてくれ！という半ばやけくそ（でもないけど）な気分になってきます。
• 結局どうするの？
  そのエラーがきたら無視してレプリケーションを続行させればいいのです。どうすればいいのか？

  --slave-skip-errors
  

  を利用すればいいのです ^^; 荒業ではありますが、定義の変更毎にいちいち対応するよりましです。ちなみに、oracle 非推奨です
  また、上記図の話に戻りますが、マスターサーバの定義が変更になった場合、通常ではスレーブ側では以下のような状態になります。下記にて説明しているのは、innodbのストレージエンジンを利用したusersテーブル（MASTER）から、FEDERATEDストレージエンジンのusers（SLAVE)のレプリケーションの環境から、カラムを追加したときの挙動について説明しております。▼これがマスター側の設定

  mysql> show create table users;
  +-------+-----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
  | Table | Create Table |
  +-------+-----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
  | users | CREATE TABLE `users` (
  `id` int(11) unsigned NOT NULL AUTO_INCREMENT,
  `user_name` varchar(100) NOT NULL COMMENT 'ユーザー名',
  `user_mail` varchar(100) NOT NULL COMMENT 'メールアドレス',
  `last_update` datetime NOT NULL COMMENT '最終更新日',
  PRIMARY KEY (`id`)
  ) ENGINE=InnoDB AUTO_INCREMENT=7 DEFAULT CHARSET=utf8 |
  +-------+-----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
  1 row in set (0.00 sec)

  ▼これがスレーブ側の設定

  mysql> show create table users;
  +-------+------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
  | Table | Create Table |
  +-------+------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
  | users | CREATE TABLE `users` (
  `id` int(11) unsigned NOT NULL AUTO_INCREMENT,
  `user_name` varchar(100) NOT NULL COMMENT 'ユーザー名',
  `user_mail` varchar(100) NOT NULL COMMENT 'メールアドレス',
  `last_update` datetime NOT NULL COMMENT '最終更新日',
  PRIMARY KEY (`id`)
  ) ENGINE=FEDERATED DEFAULT CHARSET=utf8 CONNECTION='s' |
  +-------+------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
  1 row in set (0.00 sec)
  
  [/shqll]
  
  ▼上記の構成で、マスター側のテーブルにcol1というカラムを追加する
  [shell]
  mysql> alter table users add column col1 char(10);
  Query OK, 6 rows affected (0.23 sec)
  Records: 6 Duplicates: 0 Warnings: 0
  
  mysql> show create table users;
  +-------+-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
  | Table | Create Table |
  +-------+-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
  | users | CREATE TABLE `users` (
  `id` int(11) unsigned NOT NULL AUTO_INCREMENT,
  `user_name` varchar(100) NOT NULL COMMENT 'ユーザー名',
  `user_mail` varchar(100) NOT NULL COMMENT 'メールアドレス',
  `last_update` datetime NOT NULL COMMENT '最終更新日',
  `col1` char(10) DEFAULT NULL,
  PRIMARY KEY (`id`)
  ) ENGINE=InnoDB AUTO_INCREMENT=7 DEFAULT CHARSET=utf8 |
  +-------+-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
  1 row in set (0.00 sec)
  

  ▼この状態でスレーブの状態を確認してみます。当然エラーになります。ここで、エラーNOを覚えておいてください。Last_SQL_Errno:  1032

  mysql> show slave status\G
  
  *************************** 1. row ***************************
  Slave_IO_State: Waiting for master to send event
  Master_Host: 192.168.0.42
  Master_User: slave
  Master_Port: 3306
  Connect_Retry: 60
  Master_Log_File: mysql-bin.000006
  Read_Master_Log_Pos: 542
  Relay_Log_File: relay-bin.000006
  Relay_Log_Pos: 474
  Relay_Master_Log_File: mysql-bin.000006
  Slave_IO_Running: Yes
  Slave_SQL_Running: No
  Replicate_Do_DB:
  Replicate_Ignore_DB:
  Replicate_Do_Table:
  Replicate_Ignore_Table:
  Replicate_Wild_Do_Table:
  Replicate_Wild_Ignore_Table:
  Last_Errno: 1031
  Last_Error: Error 'Table storage engine for 'users' doesn't have this option' on query. Default database: 'sqorder'. Query: 'alter table users add column col1 char(10)'
  Skip_Counter: 0
  Exec_Master_Log_Pos: 434
  Relay_Log_Space: 878
  Until_Condition: None
  Until_Log_File:
  Until_Log_Pos: 0
  Master_SSL_Allowed: No
  Master_SSL_CA_File:
  Master_SSL_CA_Path:
  Master_SSL_Cert:
  Master_SSL_Cipher:
  Master_SSL_Key:
  Seconds_Behind_Master: NULL
  Master_SSL_Verify_Server_Cert: No
  Last_IO_Errno: 0
  Last_IO_Error:
  Last_SQL_Errno: 1031
  Last_SQL_Error: Error 'Table storage engine for 'users' doesn't have this option' on query. Default database: 'sqorder'. Query: 'alter table users add column col1 char(10)'
  Replicate_Ignore_Server_Ids:
  Master_Server_Id: 201
  1 row in set (0.00 sec)
  

  ▼ SLAVEのMySQLに以下の設定を追記して再度SLAVEを開始します。

  
  # vi /etc/my.cnf
  ---
  # 下記のエラーコードはskipする
  slave-skip-errors=1032,1031
  

  ▼レプリケーションが稼動している状態で、マスターに対して、再度alter table 文を実行します。尚、先ほどの検証で、col1というカラムを追加してしまいましたので、今回はcol1を削除してみます。目的は、SLAVE側でエラーをSKIPするところの部分なので、replicationがどーたらこうたらとかFEDERATIONがあ＾でもないこーでもないという話は割愛いたします。
  ▼今回は以下のSQLでFEDERATON表である、userのSLAVEがエラーにならないことを確認する作業です

  mysql> alter table users drop col1 ;
  

  ▼結果、SLAVEのSTATUSはエラーになっていないのがわかるかと思います。

  
  mysql> show slave status\G
  *************************** 1. row ***************************
  Slave_IO_State: Waiting for master to send event
  Master_Host: 192.168.0.42
  Master_User: slave
  Master_Port: 3306
  Connect_Retry: 60
  Master_Log_File: mysql-bin.000006
  Read_Master_Log_Pos: 836
  Relay_Log_File: relay-bin.000012
  Relay_Log_Pos: 346
  Relay_Master_Log_File: mysql-bin.000006
  Slave_IO_Running: Yes
  Slave_SQL_Running: Yes
  Replicate_Do_DB:
  Replicate_Ignore_DB:
  Replicate_Do_Table:
  Replicate_Ignore_Table:
  Replicate_Wild_Do_Table:
  Replicate_Wild_Ignore_Table:
  Last_Errno: 0
  Last_Error:
  Skip_Counter: 0
  Exec_Master_Log_Pos: 836
  Relay_Log_Space: 496
  Until_Condition: None
  Until_Log_File:
  Until_Log_Pos: 0
  Master_SSL_Allowed: No
  Master_SSL_CA_File:
  Master_SSL_CA_Path:
  Master_SSL_Cert:
  Master_SSL_Cipher:
  Master_SSL_Key:
  Seconds_Behind_Master: 0
  Master_SSL_Verify_Server_Cert: No
  Last_IO_Errno: 0
  Last_IO_Error:
  Last_SQL_Errno: 0
  Last_SQL_Error:
  Replicate_Ignore_Server_Ids:
  Master_Server_Id: 201
  1 row in set (0.00 sec)
  

  どうでしょうか？

   

   

それをSQLで求めれば一発でわかるよという話です。

* ちなみにSQLはこんな感じで実行すると、結果がでます

$ db2 "select TABSCHEMA,TABNAME,COLNAME,IDENTITY,GENERATED from syscat.columns where IDENTITY = 'Y'"

TABSCHEMA TABNAME COLNAME IDENTITY GENERATED
--------------------------------------------------- ---------
DB2ADMIN TAB1 ID Y A
DB2ADMIN TAB2 ID Y A
DB2ADMIN TAB3 ID Y A
DB2ADMIN TAB4 ID Y A

* これだけだとつまらないので、SQLでさらに加工すれば、identityoverrideを含んだLOAD文を生成できます。

$ db2 -x "select 'load from ' || rtrim(TABSCHEMA) || '.' || rtrim(TABNAME) || '.ixf of IXF modified by identityoverride REPLACE ' || rtrim(TABSCHEMA) || '.' || rtrim(TABNAME) || ' NONRECOVERABLE' as LOAD_SQL from syscat.columns where IDENTITY = 'Y'" > /tmp/load.sql; cat /tmp/load.sql

* 上記の出力結果

load from DB2ADMIN.TAB4.ixf of IXF modified by identityoverride REPLACE DB2ADMIN.TAB4 NONRECOVERABLE
load from DB2ADMIN.TAB1.ixf of IXF modified by identityoverride REPLACE DB2ADMIN.TAB1 NONRECOVERABLE
load from DB2ADMIN.TAB2.ixf of IXF modified by identityoverride REPLACE DB2ADMIN.TAB2 NONRECOVERABLE
load from DB2ADMIN.TAB3.ixf of IXF modified by identityoverride REPLACE DB2ADMIN.TAB3 NONRECOVERABLE

細かいオプションは別として、SYSCATVIEWを利用して、SQL文を生成する手法は結構便利なので、いろいろと応用することができます。

* 余談ですが、正式なロードの構文は以下のような感じになると思います。NONRECOVERABLE オプションは、ロードがエラーになっても、バックアップペンディングにならないよ！というオプションです。

$ db2 "load from tab1.ixf of ixf modified by identityoverride REPLACE into tab1 NONRECOVERABLE"

以上そんなところで・

以下がクエリーキャッシュのヒット率を求めるSQLです。基本的には、show status で計算することができます。私の場合は、それすらめんどくさいので、SQLで対応しました。クエリーキャッシュのヒット率を以下の計算で求めることができます。

@QCACHE_HITS/(@QCACHE_HITS+@QCACHE_INSERTS+@QCACHE_NOT_CACHED)*100

・以下がクエリキャッシュヒット率を求めるSQLです。たぶん。。だけど合ってます。

SELECT
@QCACHE_FREE_BLOCKS := VARIABLE_VALUE
FROM
information_schema.`GLOBAL_STATUS`
where
VARIABLE_NAME = 'QCACHE_FREE_BLOCKS';

SELECT
@QCACHE_FREE_MEMORY := VARIABLE_VALUE
FROM
information_schema.`GLOBAL_STATUS`
where
VARIABLE_NAME = 'QCACHE_FREE_MEMORY';

SELECT
@QCACHE_HITS := VARIABLE_VALUE
FROM
information_schema.`GLOBAL_STATUS`
where
VARIABLE_NAME = 'QCACHE_HITS';

SELECT
@QCACHE_INSERTS := VARIABLE_VALUE
FROM
information_schema.`GLOBAL_STATUS`
where
VARIABLE_NAME = 'QCACHE_INSERTS';

SELECT
@QCACHE_LOWMEM_PRUNES := VARIABLE_VALUE
FROM
information_schema.`GLOBAL_STATUS`
where
VARIABLE_NAME = 'QCACHE_LOWMEM_PRUNES';

SELECT
@QCACHE_NOT_CACHED := VARIABLE_VALUE
FROM
information_schema.`GLOBAL_STATUS`
where
VARIABLE_NAME = 'QCACHE_NOT_CACHED';

SELECT
@QCACHE_QUERIES_IN_CACHE := VARIABLE_VALUE
FROM
information_schema.`GLOBAL_STATUS`
where
VARIABLE_NAME = 'QCACHE_QUERIES_IN_CACHE';

SELECT
@QCACHE_TOTAL_BLOCKS := VARIABLE_VALUE
FROM
information_schema.`GLOBAL_STATUS`
where
VARIABLE_NAME = 'QCACHE_TOTAL_BLOCKS';

select @QCACHE_HITS/(@QCACHE_HITS+@QCACHE_INSERTS+@QCACHE_NOT_CACHED)*100 as CACHE_HIT_RATE;

ちなみに、当サイトのクエリキャッシュヒット率はどうかというとこんな感じです

mysql> select @QCACHE_HITS/(@QCACHE_HITS+@QCACHE_INSERTS+@QCACHE_NOT_CACHED)*100 as CACHE_HIT_RATE;
+------------------+
| CACHE_HIT_RATE |
+------------------+
| 80.5282490931393 |
+------------------+
1 row in set (0.00 sec)

クエリキャッシュヒット率は80%です。すごく優秀！！（ワードプレスが・・・）

前回の図を再度記載します。

▼環境構成図
上記ホストとスキーマの関係を表したのが、下記の図になります。前回同様、肝の部分は、ブラックボックスなのですが、一度にここで書くと話がややこしくなるので、ここの話は次回にいたします。

host:sqdbm02 : MySQL5.5
host:sqdbm03 : MySQL5.5
host:sqdbm04 : MySQL5.5
host:sqdwh01 : InfiniDB
また今回の、sqdwh01で記載されているInfiniDBの構築方法につきましては、OSSなDWH InfiniDB 2.2.2最新版をインストールしてみる をご参照ください。というわけでこちらの環境では、すでに作成されております。

▼リアルタイムDWHの構築手順
1. DWH側の構築
2. BLACKBOX側の構築
の順で行います。sqdbm02と03につきましては、すでに存在しているデータベースという前提です。今回は「1. DWH側の構築について」説明します。

▼必要テーブルの調査
今回のシナリオでは、必要なテーブルはすべてではなく、一部です。sqdbm02,03には、いくつかテーブルが存在しますがDWHで必要なテーブルは、trn_jyucyu、mst_item、usersの合計３つのテーブルだけです。

▼構築手順
以下に構築手順を記載します。

【sqdwh01 : root】
1. DWHのスキーマ作成

1) ストレージエンジンの確認
InfiniDB および、InnoDBが登録されていることを確認します。尚、InfiniDBのインストール時に、InnoDBはインストールされません、個別にインストールする必要がございます。

[root@sqdwh01 ~]# idbmysql -u sysadm -pmypasswd
Welcome to the MySQL monitor. Commands end with ; or \g.
Your MySQL connection id is 11
Server version: 5.1.39 MySQL Community / Calpont InfiniDB Community 2.2.6-1 Final (COSS LA)

Type 'help;' or '\h' for help. Type '\c' to clear the current input statement.

mysql> show engines;
+------------+---------+----------------------------------------------------------------+--------------+------+------------+
| Engine | Support | Comment | Transactions | XA | Savepoints |
+------------+---------+----------------------------------------------------------------+--------------+------+------------+
| CSV | YES | CSV storage engine | NO | NO | NO |
| InnoDB | YES | Supports transactions, row-level locking, and foreign keys | YES | YES | YES |
| MEMORY | YES | Hash based, stored in memory, useful for temporary tables | NO | NO | NO |
| BLACKHOLE | YES | /dev/null storage engine (anything you write to it disappears) | NO | NO | NO |
| MRG_MYISAM | YES | Collection of identical MyISAM tables | NO | NO | NO |
| InfiniDB | YES | Calpont InfiniDB storage engine | YES | NO | NO |
| MyISAM | DEFAULT | Default engine as of MySQL 3.23 with great performance | NO | NO | NO |
+------------+---------+----------------------------------------------------------------+--------------+------+------------+
7 rows in set (0.00 sec)

2)データベース（スキーマ）の作成
図に習ってワーク用の、スキーマと、「Infinidb用」のスキーマを作成します。

mysql> create database wrkorder;
Query OK, 1 row affected (0.00 sec)

mysql> create database wrkitem;
Query OK, 1 row affected (0.00 sec)

mysql> create database wrkuser;
Query OK, 1 row affected (0.00 sec)

mysql> create database dwhorder;
Query OK, 1 row affected (0.00 sec)

mysql> create database dwhitem;
Query OK, 1 row affected (0.00 sec)

mysql> create database dwhuser;
Query OK, 1 row affected (0.00 sec)

mysql> show databases;
+--------------------+
| Database |
+--------------------+
| information_schema |
| calpontsys |
| dwhitem |
| dwhorder |
| dwhuser |
| infinidb_vtable |
| mysql |
| wrkitem |
| wrkorder |
| wrkuser |
+--------------------+
10 rows in set (0.00 sec)

mysql> show create database wrkorder;
+----------+-------------------------------------------------------------------+
| Database | Create Database |
+----------+-------------------------------------------------------------------+
| wrkorder | CREATE DATABASE `wrkorder` /*!40100 DEFAULT CHARACTER SET utf8 */ |
+----------+-------------------------------------------------------------------+
1 row in set (0.00 sec)

2. テーブルのダンプ
各サーバ、および各スキーマから必要なテーブルのみdumpファイルを取得します。

2.1) データ、定義を含むdumpを取得
こちらは、ワークスキーマに格納するためのダンプです。

[root@sqdwh01 ~]# /usr/local/Calpont/mysql/bin/mysqldump -h sqdbm02 -u sysadm -pmypasswd sqorder trn_jyucyu > /tmp/trn_jyucyu.dump
[root@sqdwh01 ~]# /usr/local/Calpont/mysql/bin/mysqldump -h sqdbm03 -u sysadm -pmypasswd sqitem mst_item > /tmp/mst_item.dump
[root@sqdwh01 ~]# /usr/local/Calpont/mysql/bin/mysqldump -h sqdbm03 -u sysadm -pmypasswd squser users > /tmp/users.dump

2.2) 定義のみのダンプを取得
こちらは、後の、InfiniDB用に加工するために出力します

[root@sqdwh01 ~]# /usr/local/Calpont/mysql/bin/mysqldump -d -h sqdbm02 -u sysadm -pmypasswd sqorder trn_jyucyu > /tmp/trn_jyucyu_def_only.sql
[root@sqdwh01 ~]# /usr/local/Calpont/mysql/bin/mysqldump -d -h sqdbm03 -u sysadm -pmypasswd sqitem mst_item > /tmp/mst_item_def_only.sql
[root@sqdwh01 ~]# /usr/local/Calpont/mysql/bin/mysqldump -d -h sqdbm03 -u sysadm -pmypasswd squser users > /tmp/users_def_only.sql

3. テーブルのリストア
当該テーブルは、当該スキーマは後のデータ連携用ワークスキーマとして利用されます。よってストレージエンジン、およびテーブル定義は、sqdbm01と、sqdbm02のそれと何もかわりません。つまり、ストレージエンジンは、innodbであり、データも同様のものが入っております。

[root@sqdwh01 ~]# idbmysql -u sysadm -pmypasswd wrkorder < /tmp/trn_jyucyu.dump
[root@sqdwh01 ~]# idbmysql -u sysadm -pmypasswd wrkitem < /tmp/mst_item.dump
[root@sqdwh01 ~]# idbmysql -u sysadm -pmypasswd wrkuser < /tmp/users.dump

4. InfiniDBストレージエンジンテーブルの作成
InfiniDB用にカスタマイズしたテーブル定義を作成します。この定義を作成するために、「2.2) 定義のみのダンプを取得」にて作成しました定義をInfinbiDB用に加工します。どこをどう直すかについては、以下にdiffを作成しましたのでご確認ください。尚、Infinidbの制約事項に関しては、DWH InfiniDB community edition の制約事項をご参照ください。

[root@sqdwh01 tmp]# cp trn_jyucyu_def_only.sql trn_jyucyu_infinidb.sql
[root@sqdwh01 tmp]# cp mst_item_def_only.sql mst_item_infinidb.sql
[root@sqdwh01 tmp]# cp users_def_only.sql users_infinidb.sql
[root@sqdwh01 tmp]# vi trn_jyucyu_infinidb.sql
[root@sqdwh01 tmp]# diff trn_jyucyu_def_only.sql trn_jyucyu_infinidb.sql
26,34c26,33
< `id` int(11) unsigned NOT NULL AUTO_INCREMENT,
< `j_cd` int(11) NOT NULL COMMENT '受注コード',
< `j_date` date NOT NULL COMMENT '受注日',
< `s_cd` int(11) NOT NULL COMMENT '商品コード',
< `j_price` int(11) NOT NULL COMMENT '受注金額',
< `user_id` int(11) NOT NULL COMMENT 'ユーザーコード',
< `last_update` datetime NOT NULL COMMENT '最終更新日',
< PRIMARY KEY (`id`)
< ) ENGINE=InnoDB AUTO_INCREMENT=599168 DEFAULT CHARSET=utf8;
---
> `id` int(11) ,
> `j_cd` int(11) COMMENT '受注コード',
> `j_date` date COMMENT '受注日',
> `s_cd` int(11) COMMENT '商品コード',
> `j_price` int(11) COMMENT '受注金額',
> `user_id` int(11) COMMENT 'ユーザーコード',
> `last_update` datetime COMMENT '最終更新日'
> ) ENGINE=InfiniDB DEFAULT CHARSET=utf8;

[root@sqdwh01 tmp]# idbmysql -u sysadm -pmypasswd dwhorder < trn_jyucyu_infinidb.sql
[root@sqdwh01 tmp]# idbmysql -u sysadm -pmypasswd dwhitem < mst_item_infinidb.sql
[root@sqdwh01 tmp]# idbmysql -u sysadm -pmypasswd dwhuser < users_infinidb.sql

4.1) 作成された、InfiniDBストレージエンジンの定義を確認する
ちょっとみずらくて申し訳けないですが、これがInfiniDBで定義したテーブル群になります、もちろん定義を作っただけなので、データは空です。

・ dwhorder

[root@sqdwh01 tmp]# idbmysql -u sysadm -pmypasswd dwhorder -e "show create table trn_jyucyu;"
+------------+----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
| Table | Create Table |
+------------+----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
| trn_jyucyu | CREATE TABLE `trn_jyucyu` (
`id` int(11) DEFAULT NULL,
`j_cd` int(11) DEFAULT NULL COMMENT '受注コード',
`j_date` date DEFAULT NULL COMMENT '受注日',
`s_cd` int(11) DEFAULT NULL COMMENT '商品コード',
`j_price` int(11) DEFAULT NULL COMMENT '受注金額',
`user_id` int(11) DEFAULT NULL COMMENT 'ユーザーコード',
`last_update` datetime DEFAULT NULL COMMENT '最終更新日'
) ENGINE=InfiniDB DEFAULT CHARSET=utf8 |
+------------+----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+

・dwhuser

[root@sqdwh01 tmp]# idbmysql -u sysadm -pmypasswd dwhuser -e "show create table users;"
+-------+------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
| Table | Create Table |
+-------+------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
| users | CREATE TABLE `users` (
`id` int(11) DEFAULT NULL,
`user_name` varchar(100) DEFAULT NULL COMMENT 'ユーザー名',
`user_mail` varchar(100) DEFAULT NULL COMMENT 'メールアドレス',
`last_update` datetime DEFAULT NULL COMMENT '最終更新日'
) ENGINE=InfiniDB DEFAULT CHARSET=utf8 |
+-------+------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+

・dwhitems

[root@sqdwh01 tmp]# idbmysql -u sysadm -pmypasswd dwhitem -e "show create table mst_item;"
+----------+----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
| Table | Create Table |
+----------+----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
| mst_item | CREATE TABLE `mst_item` (
`id` int(11) DEFAULT NULL,
`item_name` varchar(100) DEFAULT NULL COMMENT '商品名',
`last_update` datetime DEFAULT NULL COMMENT '最終更新日'
) ENGINE=InfiniDB DEFAULT CHARSET=utf8 |
+----------+----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+

5. データのエクスポート
「2. テーブルのダンプ」でリストアしました。ワークスキーマ上のテーブルをCSVファイルに出力します

[root@sqdwh01 tmp]# idbmysql -u sysadm -pmypasswd -e "SELECT * FROM wrkorder.trn_jyucyu INTO OUTFILE '/tmp/trn_jyucyu.csv' FIELDS TERMINATED BY ',' OPTIONALLY ENCLOSED BY '\"';"

[root@sqdwh01 tmp]# idbmysql -u sysadm -pmypasswd -e "SELECT * FROM wrkuser.users INTO OUTFILE '/tmp/users.csv' FIELDS TERMINATED BY ',' OPTIONALLY ENCLOSED BY '\"';"

[root@sqdwh01 tmp]# idbmysql -u sysadm -pmypasswd -e "SELECT * FROM wrkitem.mst_item INTO OUTFILE '/tmp/mst_item.csv' FIELDS TERMINATED BY ',' OPTIONALLY ENCLOSED BY '\"';"

6. データのロード
上記5にて、エクスポートしたデータを、InifiniDBのバルクローダーでロードします（非常に高速！！）

[root@sqdwh01 tmp]# /usr/local/Calpont/bin/cpimport dwhorder trn_jyucyu '/tmp/trn_jyucyu.csv' -s , -E \"

Column delimiter : ,
Enclosed by Character : "

Using table OID 3000 as the default JOB ID
Bulkload root directory : /usr/local/Calpont/data/bulk
Job description file : /usr/local/Calpont/data/bulk/tmpjob/dwhorder_trn_jyucyu_D20120409_T163059_Job_3000.xml
Log file for this job: /usr/local/Calpont/data/bulk/log/Job_3000.log
2012-04-09 16:30:59 (17790) INFO : successfully loaded job file /usr/local/Calpont/data/bulk/tmpjob/dwhorder_trn_jyucyu_D20120409_T163059_Job_3000.xml
2012-04-09 16:30:59 (17790) INFO : Job file loaded, run time for this step : 0.00211215 seconds
2012-04-09 16:30:59 (17790) INFO : PreProcessing check starts
2012-04-09 16:30:59 (17790) INFO : PreProcessing check completed
2012-04-09 16:30:59 (17790) INFO : preProcess completed, run time for this step : 0.112508 seconds
2012-04-09 16:30:59 (17790) INFO : No of Read Threads Spawned = 1
2012-04-09 16:30:59 (17790) INFO : No of Parse Threads Spawned = 3
2012-04-09 16:31:07 (17790) INFO : For table dwhorder.trn_jyucyu: 599167 rows processed and 599167 rows inserted.
2012-04-09 16:31:07 (17790) WARN : Column dwhorder.trn_jyucyu.j_date; Number of invalid dates replaced with null: 3010
2012-04-09 16:31:07 (17790) INFO : Bulk load completed, total run time : 8.298 seconds

* 他のテーブルにつきましても同様の手順でロードします
[root@sqdwh01 tmp]# /usr/local/Calpont/bin/cpimport dwhuser users '/tmp/users.csv' -s , -E \"
[root@sqdwh01 tmp]# /usr/local/Calpont/bin/cpimport dwhitem mst_item '/tmp/mst_item.csv' -s , -E \"

以上で、初期データの作成は無事完了です！

▼ InfiniDBのパフォーマンス
InfiniDBは本当に速いです！！ InnoDBとInfiniDB、以下のようなSQLを発行し、InfiniDBと、InnoDBの速度比較を行いました。尚、当環境は、XEBのGUEST OSで検証しており、サーバのメモリは、2GBとしております。

●SQL1

1) InfiniDB

select
usr.id as user_id,
usr.user_name ,
itm.id as s_cd,
itm.item_name,
sum(j_price) as sum_price
from
dwhuser.users usr
inner join
dwhorder.trn_jyucyu trn
on
usr.id = trn.user_id
inner join
dwhitem.mst_item itm
on
itm.id = trn.s_cd
group by
usr.id,
itm.id,
usr.user_name,
itm.item_name
order by sum(j_price) desc
limit 100;

2) InnoDB

select
usr.id as user_id,
usr.user_name ,
itm.id as s_cd,
itm.item_name,
sum(j_price) as sum_price
from
wrkuser.users usr
inner join
wrkorder.trn_jyucyu trn
on
usr.id = trn.user_id
inner join
wrkitem.mst_item itm
on
itm.id = trn.s_cd
group by
usr.id,
itm.id,
usr.user_name,
itm.item_name
order by sum(j_price) desc
limit 100;

●SQL2

1) InfiniDB

select
usr.id as user_id,
usr.user_name ,
count(trn.id) as cnt
from
dwhuser.users usr
inner join
dwhorder.trn_jyucyu trn
on
usr.id = trn.user_id
group by
usr.id,
usr.user_name
order by
count(trn.id) desc;

2) InnoDB

select
usr.id as user_id,
usr.user_name ,
count(trn.id) as cnt
from
wrkuser.users usr
inner join
wrkorder.trn_jyucyu trn
on
usr.id = trn.user_id
group by
usr.id,
usr.user_name
order by
count(trn.id) desc;

●SQL3

1) InfiniDB

select
itm.id,
itm.item_name,
sum(trn.j_price) as sum_price
from
dwhorder.trn_jyucyu trn
inner join
dwhitem.mst_item itm
on
itm.id = trn.s_cd
group by
itm.id,
itm.item_name
order by sum(j_price) desc;

2) InnoDB

select
itm.id,
itm.item_name,
sum(trn.j_price) as sum_price
from
wrkorder.trn_jyucyu trn
inner join
wrkitem.mst_item itm
on
itm.id = trn.s_cd
group by
itm.id,
itm.item_name
order by sum(j_price) desc;

▼速度結果
下図の通りのなりました。バーが短いほど、応答速度が速いことになります。平均的に３倍程度の速度向上が見られます。

・MySQL データベースサーバが３台、
・MySQLデータ連携サーバが３台
・InfiniDB データベースサーバが１台
と書きましたが、すみません、そんなに環境ないので
・MySQL データベースサーバが２台、
・MySQLデータ連携サーバが１台でポート毎にインスタンスを作成（ポートは二種類）
・InfiniDB データベースサーバが１台
という構成に変更します（汗）もうすこし詳細を書きます。

▼ 環境情報
二台で構成されており、受注DBとマスターDBがあり、マスターDB側には、商品スキーマとユーザースキーマがあるものと思ってください。

★ 受注データベース
以下の環境構成です

1-1) 受注スキーマ

mysql> show create database sqorder;
+----------+------------------------------------------------------------------+
| Database | Create Database |
+----------+------------------------------------------------------------------+
| sqorder | CREATE DATABASE `sqorder` /*!40100 DEFAULT CHARACTER SET utf8 */ |
+----------+------------------------------------------------------------------+
1 row in set (0.00 sec)

1-2) 受注テーブル

mysql> show tables;
+-------------------+
| Tables_in_sqorder |
+-------------------+
| trn_jyucyu |
+-------------------+
1 row in set (0.00 sec)

CREATE TABLE `trn_jyucyu` (
`id` int(11) unsigned NOT NULL AUTO_INCREMENT,
`j_cd` int(11) NOT NULL COMMENT '受注コード',
`j_date` date NOT NULL COMMENT '受注日',
`s_cd` int(11) NOT NULL COMMENT '商品コード',
`j_price` int(11) NOT NULL COMMENT '受注金額',
`user_id` int(11) NOT NULL COMMENT 'ユーザーコード',
`last_update` datetime NOT NULL COMMENT '最終更新日',
PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=599168 DEFAULT CHARSET=utf8

1-3) データ内容/データ件数

mysql> select count(*) from trn_jyucyu;
+----------+
| count(*) |
+----------+
| 599167 |
+----------+
1 row in set (0.00 sec)

mysql> select * from trn_jyucyu order by id desc limit 10;
+--------+------------+------------+------+---------+---------+---------------------+
| id | j_cd | j_date | s_cd | j_price | user_id | last_update |
+--------+------------+------------+------+---------+---------+---------------------+
| 599167 | 201227638 | 2012-05-25 | 6 | 1027 | 1 | 2012-04-06 22:35:30 |
| 599166 | 201293988 | 2012-05-29 | 10 | 7939 | 1 | 2012-04-06 22:35:30 |
| 599165 | 2147483647 | 2012-04-30 | 3 | 6629 | 2 | 2012-04-06 22:35:30 |
| 599164 | 2012125737 | 2012-01-07 | 6 | 6626 | 4 | 2012-04-06 22:35:30 |
| 599163 | 2147483647 | 2012-02-07 | 9 | 145 | 4 | 2012-04-06 22:35:30 |
| 599162 | 2012521227 | 2012-01-19 | 3 | 2585 | 5 | 2012-04-06 22:35:30 |
| 599161 | 2012526949 | 2012-04-19 | 7 | 6561 | 4 | 2012-04-06 22:35:29 |
| 599160 | 2147483647 | 2012-09-20 | 10 | 1059 | 5 | 2012-04-06 22:35:29 |
| 599159 | 201252333 | 2012-12-14 | 8 | 9579 | 5 | 2012-04-06 22:35:29 |
| 599158 | 2012225273 | 2012-06-20 | 3 | 1436 | 3 | 2012-04-06 22:35:29 |
+--------+------------+------------+------+---------+---------+---------------------+
10 rows in set (0.00 sec)

★マスタデータベース（ユーザー情報）

1-1) ユーザースキーマ

mysql> show create database squser;
+----------+-----------------------------------------------------------------+
| Database | Create Database |
+----------+-----------------------------------------------------------------+
| squser | CREATE DATABASE `squser` /*!40100 DEFAULT CHARACTER SET utf8 */ |
+----------+-----------------------------------------------------------------+
1 row in set (0.00 sec)

1-2) ユーザーテーブル

mysql> show tables;
+--------------------+
| Tables_in_squser |
+--------------------+
| user_address |
| user_bookmarks |
| user_delete |
| user_fav |
| user_login_history |
| users |
+--------------------+
6 rows in set (0.00 sec)

CREATE TABLE `users` (
`id` int(11) unsigned NOT NULL AUTO_INCREMENT,
`user_name` varchar(100) NOT NULL COMMENT 'ユーザー名',
`user_mail` varchar(100) NOT NULL COMMENT 'メールアドレス',
`last_update` datetime NOT NULL COMMENT '最終更新日',
PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8

1-3) データ内容/データ件数

mysql> select * from users;
+----+------------------+----------------------------------+---------------------+
| id | user_name | user_mail | last_update |
+----+------------------+----------------------------------+---------------------+
| 1 | テスト太郎1 | test_taro1@testdomain.test.local | 2012-04-07 01:28:26 |
| 2 | テスト太郎2 | test_taro2@testdomain.test.local | 2012-04-07 01:28:26 |
| 3 | テスト太郎3 | test_taro3@testdomain.test.local | 2012-04-07 01:28:26 |
| 4 | テスト太郎4 | test_taro4@testdomain.test.local | 2012-04-07 01:28:26 |
| 5 | テスト太郎5 | test_taro5@testdomain.test.local | 2012-04-07 01:28:26 |
+----+------------------+----------------------------------+---------------------+
5 rows in set (0.00 sec)

mysql> select count(*) from users;
+----------+
| count(*) |
+----------+
| 5 |
+----------+
1 row in set (0.00 sec)

★マスタデータベース（商品情報）

1-1) 商品スキーマ

mysql> show create database sqitem;
+----------+-----------------------------------------------------------------+
| Database | Create Database |
+----------+-----------------------------------------------------------------+
| sqitem | CREATE DATABASE `sqitem` /*!40100 DEFAULT CHARACTER SET utf8 */ |
+----------+-----------------------------------------------------------------+
1 row in set (0.00 sec)

1-2) ユーザーテーブル

mysql> show tables;
+------------------+
| Tables_in_sqitem |
+------------------+
| item_zaiko |
| mst_item |
| mst_item_spec |
+------------------+
3 rows in set (0.00 sec)

CREATE TABLE `mst_item` (
`id` int(11) unsigned NOT NULL AUTO_INCREMENT,
`item_name` varchar(100) NOT NULL COMMENT '商品名',
`last_update` datetime NOT NULL COMMENT '最終更新日',
PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 ;

1-3) データ内容/データ件数

mysql> select * from mst_item;
+----+-------------+---------------------+
| id | item_name | last_update |
+----+-------------+---------------------+
| 1 | 商品名1 | 2012-04-07 01:45:19 |
| 2 | 商品名2 | 2012-04-07 01:45:19 |
| 3 | 商品名3 | 2012-04-07 01:45:19 |
| 4 | 商品名4 | 2012-04-07 01:45:19 |
| 5 | 商品名5 | 2012-04-07 01:45:19 |
| 6 | 商品名6 | 2012-04-07 01:45:19 |
| 7 | 商品名7 | 2012-04-07 01:45:19 |
| 8 | 商品名8 | 2012-04-07 01:45:19 |
| 9 | 商品名9 | 2012-04-07 01:45:19 |
| 10 | 商品名10 | 2012-04-07 01:45:19 |
+----+-------------+---------------------+
10 rows in set (0.00 sec)

mysql> select count(*) from mst_item;
+----------+
| count(*) |
+----------+
| 10 |
+----------+
1 row in set (0.00 sec)

▼上記をまとめますと、以下のような構成になります。

▼ポイント
・商品スキーマ、受注スキーマ、ユーザースキーマから必要なテーブルのみ抽出してDWHに格納する
・テーブルの連携には、EXPORT/LOAD等の処理は一切使わない
・MySQLのレプリケーションで行う
・DWHは、InfiniDBを利用する。つまりストレージエンジンは、InfiniDBです

上記表中のBLACKBOXの部分は今回は触れません、しかしながら、このBLACKBOXの設定が肝になります。こちらの設定については、次回PART3で触れたいと思います。

結局のところ、複数のデータベースサーバに散在している主要テーブルを一つのDWHサーバに収めJOINクエリーするようにするのが最終形です、しかも、InfiniDBだから、その速度は驚速です。参考までに結果のサンプルクエリーを載せておきます。

▼サンプルクエリーとサンプルの結果
サンプルでは、もっとも注文金額多いユーザー、商品別の一覧を出力しております。以下でJOINして結果を取得しているので、つまりは、ここがテーブルの集約地点（DWH）になっているわけです。

select
usr.id as user_id,
usr.user_name ,
itm.id as s_cd,
itm.item_name,
sum(j_price) as sum_price
from
users usr
inner join
trn_jyucyu trn
on
usr.id = trn.user_id
inner join
mst_item itm
on
itm.id = trn.s_cd
group by
usr.id,
itm.id
order by sum_price desc limit 10;

+---------+------------------+------+------------+-----------+
| user_id | user_name | s_cd | item_name | sum_price |
+---------+------------------+------+------------+-----------+
| 5 | テスト太郎5 | 9 | 商品名9 | 104926456 |
| 5 | テスト太郎5 | 7 | 商品名7 | 102576399 |
| 3 | テスト太郎3 | 9 | 商品名9 | 102194492 |
| 3 | テスト太郎3 | 7 | 商品名7 | 99681643 |
| 4 | テスト太郎4 | 9 | 商品名9 | 98271491 |
| 4 | テスト太郎4 | 7 | 商品名7 | 97877942 |
| 2 | テスト太郎2 | 7 | 商品名7 | 85680747 |
| 1 | テスト太郎1 | 7 | 商品名7 | 84988623 |
| 1 | テスト太郎1 | 9 | 商品名9 | 84576007 |
| 2 | テスト太郎2 | 9 | 商品名9 | 84506047 |
+---------+------------------+------+------------+-----------+
10 rows in set (2.07 sec)

couldn't boot due to problems with the filesystems in /dev/VolGroup00/LogVol00

まあ・・あれです・・ほとんどの場合ブートセクターが破損した場合なので、ハードディスクに障害があるかその類の問題であることはたしかなのですが、なんとか起動までもっていきたい場合など、直る可能性もありますので是非とｋも試してみてください。結果からいうと、fsckかけるだけです。

・上記のエラーを出力後、以下のようなプロンプトが表示されます。あれですね、パスワードを入れるか、CTRL + D で再起動するかどっちかにしろってことだと思いますが、ここで、OSのrootパスワードを入力してENTERキーを押します

*** An error occured during the file system check
*** Dropping you to a shell; the system will reboot when you leave the shell
Give root password for maintenance
(Or type Control-D to continue):

・メンテナンスモードがきっと起動しますので、fsckとタイプします、リペアするセクタの確認画面がでますが、とにかく全部 ENTERキーで進めます。（デフォルトでは、Yesです）

(Repair filesystem) 1 # fsck
fsck 1.38 (30-Jun-2005)
e2fsck 1.38 (30-Jun-2005)
/dev/VolGroup00/LogVol00: contains a file system with errors, check forced.
Inode 2127913 has illegal bloick(s): Clear<y>?

・ひとおりの、fsckが終了したあと、OSを再起動して、うまく動けばラッキーっつうことでｗ

(Repair filesystem) 3 # reboot

あと、特に説明することないのですが、再起動後起動しないのであれば、もうあきらめたほうが良いかも・・

–
前回までのおさらいで結局リアルタイムDWHってな～に？

実は自分もいまだによくわかってないのです。googleで「リアルタイムDWH」検索しても、これか！って思うページが出てきません。
しかし、よく見かけるキーワードが、「10TBのデータロードを高速に実現！」とか「Hadoopを利用したなんとかノードで並列のなんとか」とか、なんだ・・結局DWHとしてはリアルタイムじゃないんじゃん・・とか思っちゃうわけです・・・とか書くと前回の同じ内容になってしまいますのでここでは割愛します。私の実現したいことは

・高速な検索
・複数に散在しているデータの更新をリアルタイムにDWHに集約したい
・なおかつ、サービスで利用しているデータベース群には、分析のためにアクセスさせたくない！

という要件を満たしたいのです。経営ダッシュボード等を含むリアルタイムBIは、今まさに、色々なところで実現されております。しかし、いまだに追い付いていないのは、データ（DWH）のリアルタイム化。これが実現出来れば、業界初の試み！（自分調べ）になるわけです。きっと数あるDWHのベンダーから掲載差し止め要求がくること必至です。

このままですと、前回同様能書きで終わってしまいますので、ある意味、ニーズに沿った環境で、その「リアルタイムDWH」をどう実現するのかを、順序だてて書く関係で、このページだけで書ききるのは困難なため、数回にわけて掲載していきたいと思います。

とりあえず！

こんな環境で、こんなことを結果的に実現したいと思っています。それに行き着くまでの、作業過程は必ず書きますので、期待して待っててくださいね。

▼ 実現したい最終構成
以下のような形にしたいと考えております。キーワードはリアルタイムです。

▼ （自分として）の目標
・商用DB（DWH）は一切使わない、つまりお金はかけない（ハードウェアは例外）
・あくまでもリアルタイム反映が目標なので、データロード等の行為は一切行わない
・アドホッククエリー（ad hoc query）でも充分なレスポンスタイムを実現できること

▼ 環境構成
上記に目標を実現させるための構成としてどれが一番スムーズにそれが実現できるか考えた結果

・MySQL 5.5

・InfiniDB (MySQL 5.1ベースの列指向DWH）

を利用することに決定しました。InfiniDBは、最近国内のサポートも正式に決まり、これから世の中に出回っていくカラムベースのDWHです。これの、フリー版を利用します。あとは、いわずと知れたMySQL、この２つを選択した理由は、一言・・「オール MySQLベースだから」ですｗ ベースが同じものであれば、レプリケーションもきっとできるし、問題がでた場合も、容易に壁を乗り越えれそうだからです。

上記に踏まえ、
・MySQL データベースサーバが３台、
・MySQLデータ連携サーバが３台
・InfiniDB データベースサーバが１台
の合計７台構成で実現します。

MySQL データベースサーバについては、既に構築済みということを前提に次回は掲載します、乞うご期待！！

ここで説明する想定の条件は以下の通りとします。

・MySQLのサーバ数は、20台で、20台それぞれが異なるスキーマである
・MySQLのテーブルはInnoDBテーブルのみ
・MySQLサーバーを止めずにバックアップする
・4重のバックアップ手法をとり、どんなことがあろうと障害復旧時点までリカバリできる構成を作ること

ここでは、有償の製品の話は割愛しますね。MySQLでinnodbのバックアップ方法は2通りあり、一つは、前述の通りなのですが、MySQLサービスを停止して、ディレクトリごと、丸々コピーする方法と、mysqldumpでスキーマのバックアップをとる方法があるのですが、そちらにしてもサービスは止まり、ディレクトリごとバックアップする方法に関しては、そもそもサービスを停止する方法があるのでNGですし、mysqldumpに関しては、mysqldump取得時に、テーブルにロックがかかりますよね。なので、「止めることが許されないサービス」には当てはまらないのです。Oracle社は公式に、バックアップはサービスを止めてディレクトリ毎コピーすることを推奨しております。

・・で以下の４つを中心に考え、サービス無停止バックアップを考えてみます。

▼MySQLのバックアップは、mysqldumpを利用
mysqldumpはmysqldumpであってバックアップではないの理解しつつ、あえてこれを利用します

▼ レプリケーションを利用する
上記方法だけは要件を満たすことができないため、今回はMySQLレプリケーションを応用して検討します

▼ バイナリログのローテートを活用する
バイナリログのローテート先を対象DBサーバとは別の筐体に保存し、ハードディスク障害のリスクを分散します。

▼ バックアップ集中サーバを構築する
潤沢に資金があるのであれば、1サーバ毎に1バックアップサーバでいけるのですが、ただバックアップのためにだけ・・それらのサーバを容易するのは、金銭面で苦労するでしょう。なのでバックアップ集中サーバは一台で回していきます。

今回の検証では、以下のサーバがあると仮定します。

・マスターサーバ
> ブログスキーマ * 1台 : <<host;sqdbm01>>
> ログ * 1台 : <<host:sqdbm03>>

・バックアップサーバ
> バックアップ集中サーバ * 1台 : <<host:sqdbm99>>

・ファイルサーバ
> NFSサーバ * 1台 : <<host:sqnas01>>

というわけで合計 5台です。今回ここで説明するのは、バックアップサーバの話だけです。バックアップサーバ集中サーバ以外のホストにつきましては、別に何も設定は必要ではありません。

—–
▼集中バックアップサーバを構築する
MySQLのインストール手順については割愛します、mysqlはrpmでインストールしております。

・my.cnfの編集
my.cnfの編集をします。図のとおり、複数のDBサーバから一台のバックアップスレーブサーバにデータをレプリケーションする構成のため、MySQLのマルチ起動をする必要があります。mysqlには、mysqld_muiti というユティリティがあるのですが、私的には、my.cnfの管理がしずらく、あまり便利なユティリティにも思えなかったため、mysqld_safe で個々にプロセスを起動する方法をとりました。なので手順は一般的なものと違いますので、mysqld_muitiでやりたい方は、その設定に併せてください。

・ポート毎のディレクトリを作成
ポート毎（socket毎）にデータディレクトリを分けます。

[root@sqdbm99 ~]# su - mysql
-bash-3.2$ mkdir /var/lib/mysql/data1
-bash-3.2$ mkdir /var/lib/mysql/data2
-bash-3.2$ mysql_install_db --datadir=/var/lib/mysql/data1/
-bash-3.2$ mysql_install_db --datadir=/var/lib/mysql/data2/

・my.cnf の編集
バックアップサーバは・・・ここの環境は、あまりスペックの良いPCではありません。なので、my-small.cnfをベースにします。
レプリケーションマスターは二台なので、二台分のmy.cnfを作成します。変更箇所は、server-idとソケットディレクトリ、およびポート番号です

[root@sqdbm99 ~]# cp /usr/share/mysql/my-small.cnf /etc/my.cnf
------------------------------------------------------------------------
[root@sqdbm99 ~]# diff /usr/share/mysql/my-small.cnf /etc/my.cnf
20,21c20,21
< port = 3306
< socket = /var/lib/mysql/mysql.sock
---
> port = 3307
> socket = /var/lib/mysql/data1/mysql.sock
28c28
< socket = /var/lib/mysql/mysql.sock
---
> socket = /var/lib/mysql/data1/mysql.sock
46c46
< server-id = 1
---
> server-id = 1010
------------------------------------------------------------------------
[root@sqdbm99 ~]# cp -arf /etc/my.cnf /etc/my.cnf1
[root@sqdbm99 ~]# cp -arf /etc/my.cnf /etc/my.cnf2
[root@sqdbm99 ~]# vi /etc/my.cnf2
※ディレクトリとポート番号および、サーバIDのみ変更してください

・ポート（ソケット）毎にmysqldを起動する
rpmおよびyumでインストールされた方は。/etc/init.d/mysql startとかやっちゃいがちですが、以下のようなパラメータを添えてポート毎に起動してください

# mysqld_safe --defaults-file=/etc/my.cnf1 --datadir=/var/lib/mysql/data1 &
# mysqld_safe --defaults-file=/etc/my.cnf2 --datadir=/var/lib/mysql/data2 &

・あとはおのおのの、ソケット毎に、レプリケーション設定を入れるだけです。あ、ちなみに、ソケット毎の接続方法は以下の通りです。

・サーバローカルでの接続方法

# mysql -u root -pmypassword -S /var/lib/mysql/data1/mysql.sock
# mysql -u root -pmypassword -S /var/lib/mysql/data2/mysql.sock

・リモートからの接続方法

# mysql -u root -pmypassword -p 3306
# mysql -u root -pmypassword -p 3307

尚、レプリケーションの設定そのものについては、ポートが違おうとデータディレクトリが違おうと、変わりはないので
http://www.s-quad.com/wordpress/?p=1017 あたりを参考にしてください。

▼集中バックアップサーバからバックアップファイルをdumpする
ポート毎にmysqlが起動できた、そしてポート毎にレプリケーションが行えた！からバックアップ環境ができたわけではありません。
より確実にバックアップを行うためには、このバックアップサーバ外の部分にデータを退避する必要があります。手順としては、

・slaveを停止する
・mysqldumpを実行する（ポート毎）
・slaveを再開する

だと思います。以下簡単ですが、バックアップのshellみたいのを作成しました（本当はエラーチェック等もっと細かく書きます）

# cat mysql_backup.sh
#!/bin/bash

# ---------------------------------------------
# MySQL BACKUP
# $1 mysql port no
# ---------------------------------------------

. /usr/local/shell/include/mysql_common_functions.sh

_LOGDIR=/backups/log
_LOGFILE=$_LOGDIR/mysql_dump.log
_DATE=`date +"%Y%m%d"`
# datetime
# _DATE=`date +%Y%m%d%H%M`
_HOSTNAME=`hostname -a`

if [ "$1" != "" ];
then
_SOCK=" -S /var/lib/mysql/$1/mysql.sock"
else
_SOCK=""
fi

_BACKUPDIR="/backups/${_HOSTNAME}/$1"

# ログファイルディレクトリが存在しない場合は新規で作成する
if [ ! -d $_LOGDIR ]; then
mkdir -p $_LOGDIR
chmod 775 $_LOGDIR
fi

# バックアップディレクトリが存在しない場合は新規で作成する
if [ ! -d $_BACKUPDIR ]; then
echo "create directory $_shelldir"
mkdir -p $_BACKUPDIR
chmod 775 $_BACKUPDIR
fi
_NOW=`date`
echo "*** MySQL Backup Start *** ${_NOW}" >> $_LOGFILE

# DB Config
_DBUSER=myuser
_DBPASSWD=mypass

# mysqldump実行
# 1) flush table
# 2) slave stop
# 3) mysqldump (full)
# 4) slave start
mysql -u ${_DBUSER} -p${_DBPASSWD} ${_SOCK} -e "flush tables;"
mysql -u ${_DBUSER} -p${_DBPASSWD} ${_SOCK} -e "stop slave;"
mysqldump -u ${_DBUSER} -p${_DBPASSWD} ${_SOCK} -x --all-databases > ${_BACKUPDIR}/${_DATE}_${_HOSTNAME}_FULL.dump
mysql -u ${_DBUSER} -p${_DBPASSWD} ${_SOCK} -e "start slave;"
mysql -u ${_DBUSER} -p${_DBPASSWD} ${_SOCK} -e "show slave status\G;"

# バックアップファイルを圧縮
cd ${_BACKUPDIR}/
tar cvzf ${_DATE}_${_HOSTNAME}_FULL.dump.tar.gz ${_DATE}_${_HOSTNAME}_FULL.dump
rm -f ${_DATE}_${_HOSTNAME}_FULL.dump

# 7日まえの古いバックアップファイルを削除する
find ${_BACKUPDIR}/ -mtime +7 -exec rm -f {} \;

_NOW=`date`
echo "--backup dir ${_BACKUPDIR}" >> $_LOGFILE
echo "--backup file ${_BACKUPDIR}/${_DATE}_${_HOSTNAME}_FULL.dump.tar.gz" >> $_LOGFILE

echo "*** MySQL Backup End *** ${_NOW}" >> $_LOGFILE

exit 0

ローテートの話にまったく触れてなかったとです・・・。いかがでしょうか？これでサービス無停止バックアップが実現できる状態になったかと思います。

▼ munin とは何？
ここ（http://gigazine.net/news/20060904_munin/）に詳しく書かれておりますが、『簡単に負荷やトラフィックをグラフ化できる』ツールです。プラグインの種類が豊富で、xenやらmysqlやらapacheやら、簡単利用することができます。個人的には、MySQLの計測関連が豊富なのと動作がものすっごく軽いので気に入りました。
▼インストールはどうするの？
インストールは簡単です。簡単ですといいながらも、私はソースをコンパイルしてメイクとかするのすら嫌なのですべてyumでインストルする方法で記載することにしました。

今回の例では

munin サーバ
> ホスト名：muninsrv
mysqlserver
> ホスト名：muninclient

という構成にして設定してみたいと思います。また、クラインアントは、MySQLなので、MySQLを中心としたプラグインで構成していきます。OSは、CENTOS5.7の64bit版で行いました。

でわ早速インストール手順などを書きます。

<<サーバ、クライアント共通手順>>

* epelのインストール
munin自体はCENTOSの標準のyumリポジトリには存在しないので、remiやらepelとかをインストールしてからインストールできるところまで手順で書くことにします。

[root@muninsrv html]# cd /usr/local/src/
[root@muninsrv src]# wget http://ftp-srv2.kddilabs.jp/Linux/distributions/fedora/epel/5/x86_64/epel-release-5-4.noarch.rpm
[root@muninsrv src]# rpm -ivh epel-release-5-4.noarch.rpm
[root@muninsrv src]# cp /etc/yum.repos.d/epel.repo /etc/yum.repos.d/epel.repo.20120304
[root@muninsrv src]# cd /etc/yum.repos.d/
[root@muninsrv yum.repos.d]# diff epel.repo epel.repo.20120304
7d6
< enabled=1

* remiのインストール
[root@muninsrv yum.repos.d]# rpm -import http://rpms.famillecollet.com/RPM-GPG-KEY-remi
[root@muninsrv yum.repos.d]# wget http://rpms.famillecollet.com/remi-enterprise.repo
[root@muninsrv yum.repos.d]# cp /etc/yum.repos.d/remi-enterprise.repo /etc/yum.repos.d/remi-enterprise.repo.20120304
[root@muninsrv yum.repos.d]# vi /etc/yum.repos.d/remi-enterprise.repo
[root@muninsrv yum.repos.d]# diff /etc/yum.repos.d/remi-enterprise.repo /etc/yum.repos.d/remi-enterprise.repo.201203045c5
< enabled=1
---
> enabled=0

<<サーバの設定>>
・前提条件
apacheがインストールされていること

・yumでmuninをインストールします

[root@muninsrv ~]# yum -y install munin

・環境設定ファイルの編集をします

[root@muninsrv ~]# cd /etc/munin/
[root@muninsrv munin]# cp -prf munin.conf munin.conf.20110314
[root@muninsrv munin]# vi munin.conf
--------------------------------------------------------------------------------------------------------------
# 基本的に、ノードの登録のみ行います。
# 形式は、[グループ名;ホスト名（FQDN）]になります。私の場合は、wwwグループとdbmsグループに分けております。
# Drop somejuser@fnord.comm and anotheruser@blibb.comm an email everytime
# something changes (OK -> WARNING, CRITICAL -> OK, etc)
#contact.someuser.command mail -s "Munin notification" somejuser@fnord.comm
#contact.anotheruser.command mail -s "Munin notification" anotheruser@blibb.comm
#
# For those with Nagios, the following might come in handy. In addition,
# the services must be defined in the Nagios server as well.
#contact.nagios.command /usr/bin/send_nsca nagios.host.comm -c /etc/nsca.conf

[dbms;muninclient]
address 192.168.101.41
use_node_name yes
--------------------------------------------------------------------------------------------------------------

* デーモンとかの開始はありません。yumでインストールした場合は、cronに自動登録されます（デフォルトですと５分に一回ですね）

root@muninsrv munin]# cat /etc/cron.d/munin
#
# cron-jobs for munin
#

MAILTO=root

*/5 * * * * munin test -x /usr/bin/munin-cron && /usr/bin/munin-cron

以上、munin-serverの設定は終わりです

<<クライアントの設定>>

* クライアントのインストール

[root@muninclient ~]# yum -y install munin-node

* munin-node.conf の編集

[root@muninclient munin]# cd /etc/munin/
[root@muninclient munin]# cp -p munin-node.conf munin-node.conf.20120314
[root@muninclient munin]# vi munin-node.conf
--------------------------------------------------------------------------
# Set this if the client doesn't report the correct hostname when
# telnetting to localhost, port 4949
# munin サーバのホスト名を指定してください
host_name muninsrv.squad.local

# A list of addresses that are allowed to connect. This must be a
# regular expression, since Net::Server does not understand CIDR-style
# network notation unless the perl module Net::CIDR is installed. You
# may repeat the allow line as many times as you'd like
# munin サーバのホスト名のIPアドレスを指定してください
allow ^192\.168\.101\.34$
--------------------------------------------------------------------------

* mysql plugin関連のモジュールをインストール
基本上記のままの設定ですと、デフォルトでは以下の監視が設定されます。また、プラグインの登録は、シンボリックリンクで

# pwd
/etc/munin/plugins
# ll
合計 0
lrwxrwxrwx 1 root root 28 3月 15 11:18 cpu -> /usr/share/munin/plugins/cpu
lrwxrwxrwx 1 root root 27 3月 15 11:18 df -> /usr/share/munin/plugins/df
lrwxrwxrwx 1 root root 33 3月 15 11:18 df_inode -> /usr/share/munin/plugins/df_inode
lrwxrwxrwx 1 root root 34 3月 15 11:18 diskstats -> /usr/share/munin/plugins/diskstats
lrwxrwxrwx 1 root root 32 3月 15 11:18 if_err_eth0 -> /usr/share/munin/plugins/if_err_
lrwxrwxrwx 1 root root 28 3月 15 11:18 if_eth0 -> /usr/share/munin/plugins/if_
lrwxrwxrwx 1 root root 31 3月 15 11:18 iostat -> /usr/share/munin/plugins/iostat
lrwxrwxrwx 1 root root 35 3月 15 11:18 iostat_ios -> /usr/share/munin/plugins/iostat_ios
lrwxrwxrwx 1 root root 33 3月 15 11:18 irqstats -> /usr/share/munin/plugins/irqstats
lrwxrwxrwx 1 root root 29 3月 15 11:18 load -> /usr/share/munin/plugins/load
lrwxrwxrwx 1 root root 31 3月 15 11:18 memory -> /usr/share/munin/plugins/memory
lrwxrwxrwx 1 root root 32 3月 15 11:18 netstat -> /usr/share/munin/plugins/netstat
※尚、以下の部分は私はリンクをはずしました。除外した理由は監視項目多数ですと、本来、必要なMySQLの監視項目がぼやけるからです。
lrwxrwxrwx 1 root root 30 3月 15 11:18 forks -> /usr/share/munin/plugins/forks
lrwxrwxrwx 1 root root 38 3月 15 11:18 http_loadtime -> /usr/share/munin/plugins/http_loadtime
lrwxrwxrwx 1 root root 32 3月 15 11:18 entropy -> /usr/share/munin/plugins/entropy
lrwxrwxrwx 1 root root 35 3月 15 11:18 fw_packets -> /usr/share/munin/plugins/fw_packets
lrwxrwxrwx 1 root root 35 3月 15 11:18 interrupts -> /usr/share/munin/plugins/interrupts
lrwxrwxrwx 1 root root 31 3月 15 11:18 lpstat -> /usr/share/munin/plugins/lpstat
lrwxrwxrwx 1 root root 36 3月 15 11:18 nfs4_client -> /usr/share/munin/plugins/nfs4_client
lrwxrwxrwx 1 root root 39 3月 15 11:18 ntp_kernel_err -> /usr/share/munin/plugins/ntp_kernel_err
lrwxrwxrwx 1 root root 44 3月 15 11:18 ntp_kernel_pll_freq -> /usr/share/munin/plugins/ntp_kernel_pll_freq
lrwxrwxrwx 1 root root 43 3月 15 11:18 ntp_kernel_pll_off -> /usr/share/munin/plugins/ntp_kernel_pll_off
lrwxrwxrwx 1 root root 35 3月 15 11:18 ntp_offset -> /usr/share/munin/plugins/ntp_offset
lrwxrwxrwx 1 root root 35 3月 15 11:18 open_files -> /usr/share/munin/plugins/open_files
lrwxrwxrwx 1 root root 36 3月 15 11:18 open_inodes -> /usr/share/munin/plugins/open_inodes
lrwxrwxrwx 1 root root 33 3月 15 11:18 proc_pri -> /usr/share/munin/plugins/proc_pri
lrwxrwxrwx 1 root root 34 3月 15 11:18 processes -> /usr/share/munin/plugins/processes
lrwxrwxrwx 1 root root 43 3月 15 11:18 sendmail_mailqueue -> /usr/share/munin/plugins/sendmail_mailqueue
lrwxrwxrwx 1 root root 43 3月 15 11:18 sendmail_mailstats -> /usr/share/munin/plugins/sendmail_mailstats
lrwxrwxrwx 1 root root 45 3月 15 11:18 sendmail_mailtraffic -> /usr/share/munin/plugins/sendmail_mailtraffic
lrwxrwxrwx 1 root root 29 3月 15 11:18 swap -> /usr/share/munin/plugins/swap
lrwxrwxrwx 1 root root 32 3月 15 11:18 threads -> /usr/share/munin/plugins/threads
lrwxrwxrwx 1 root root 31 3月 15 11:18 uptime -> /usr/share/munin/plugins/uptime
lrwxrwxrwx 1 root root 30 3月 15 11:18 users -> /usr/share/munin/plugins/users
lrwxrwxrwx 1 root root 31 3月 15 11:18 vmstat -> /usr/share/munin/plugins/vmstat
lrwxrwxrwx 1 root root 28 3月 15 11:18 yum -> /usr/share/munin/plugins/yum

* MySQLに必要なパッケージをインストールします

yum install --enablerepo=epel perl-IPC-ShareLite perl-Cache-Cache perl-Cache perl-DBD-MySQL

* 現在登録されている、MySQLの監視項目をmunin-node-configure にて確認します

munin-node-configure --suggest|grep -i mysql
mysql_ | yes | yes (commands connections innodb_bpool innodb_io innodb_log innodb_tnx myisam_indexes network_traffic qcache qcache_mem select_types slow table_locks +bin_relay_log +files_tables +innodb_bpool_act +innodb_insert_buf +innodb_io_pend +innodb_rows +innodb_semaphores +replication +sorts +tmp_tables)

* MySQLの監視項目を追加します

cd /etc/munin/plugins
ln -s /usr/share/munin/plugins/mysql_ mysql_commands
ln -s /usr/share/munin/plugins/mysql_ mysql_innodb_bpool
ln -s /usr/share/munin/plugins/mysql_ mysql_innodb_io
ln -s /usr/share/munin/plugins/mysql_ mysql_innodb_log
ln -s /usr/share/munin/plugins/mysql_ mysql_innodb_tnx
ln -s /usr/share/munin/plugins/mysql_ mysql_select_types
ln -s /usr/share/munin/plugins/mysql_ mysql_table_locks
ln -s /usr/share/munin/plugins/mysql_ mysql_connections
ln -s /usr/share/munin/plugins/mysql_ mysql_slow
ln -s /usr/share/munin/plugins/mysql_ mysql_myisam_indexes
ln -s /usr/share/munin/plugins/mysql_ mysql_network_traffic
ln -s /usr/share/munin/plugins/mysql_ mysql_qcache
ln -s /usr/share/munin/plugins/mysql_ mysql_qcache_mem

* 結果以下のプラグインのものを監視するようにしました

lrwxrwxrwx 1 root root 28 3月 14 15:46 cpu -> /usr/share/munin/plugins/cpu
lrwxrwxrwx 1 root root 27 3月 14 15:46 df -> /usr/share/munin/plugins/df
lrwxrwxrwx 1 root root 33 3月 14 15:46 df_inode -> /usr/share/munin/plugins/df_inode
lrwxrwxrwx 1 root root 34 3月 14 15:46 diskstats -> /usr/share/munin/plugins/diskstats
lrwxrwxrwx 1 root root 32 3月 14 15:46 entropy -> /usr/share/munin/plugins/entropy
lrwxrwxrwx 1 root root 30 3月 14 15:46 forks -> /usr/share/munin/plugins/forks
lrwxrwxrwx 1 root root 32 3月 14 15:46 if_err_eth0 -> /usr/share/munin/plugins/if_err_
lrwxrwxrwx 1 root root 28 3月 14 15:46 if_eth0 -> /usr/share/munin/plugins/if_
lrwxrwxrwx 1 root root 35 3月 14 15:46 interrupts -> /usr/share/munin/plugins/interrupts
lrwxrwxrwx 1 root root 31 3月 14 15:46 iostat -> /usr/share/munin/plugins/iostat
lrwxrwxrwx 1 root root 29 3月 14 15:46 load -> /usr/share/munin/plugins/load
lrwxrwxrwx 1 root root 31 3月 14 15:46 memory -> /usr/share/munin/plugins/memory
lrwxrwxrwx 1 root root 31 3月 14 15:57 mysql_commands -> /usr/share/munin/plugins/mysql_
lrwxrwxrwx 1 root root 31 3月 14 21:07 mysql_connections -> /usr/share/munin/plugins/mysql_
lrwxrwxrwx 1 root root 31 3月 14 15:57 mysql_innodb_bpool -> /usr/share/munin/plugins/mysql_
lrwxrwxrwx 1 root root 31 3月 14 15:57 mysql_innodb_io -> /usr/share/munin/plugins/mysql_
lrwxrwxrwx 1 root root 31 3月 14 15:57 mysql_innodb_log -> /usr/share/munin/plugins/mysql_
lrwxrwxrwx 1 root root 31 3月 14 15:57 mysql_innodb_tnx -> /usr/share/munin/plugins/mysql_
lrwxrwxrwx 1 root root 31 3月 14 21:07 mysql_myisam_indexes -> /usr/share/munin/plugins/mysql_
lrwxrwxrwx 1 root root 31 3月 14 21:07 mysql_network_traffic -> /usr/share/munin/plugins/mysql_
lrwxrwxrwx 1 root root 31 3月 14 21:07 mysql_qcache -> /usr/share/munin/plugins/mysql_
lrwxrwxrwx 1 root root 31 3月 14 21:07 mysql_qcache_mem -> /usr/share/munin/plugins/mysql_
lrwxrwxrwx 1 root root 31 3月 14 15:57 mysql_select_types -> /usr/share/munin/plugins/mysql_
lrwxrwxrwx 1 root root 31 3月 14 21:07 mysql_slow -> /usr/share/munin/plugins/mysql_
lrwxrwxrwx 1 root root 31 3月 14 15:57 mysql_table_locks -> /usr/share/munin/plugins/mysql_
lrwxrwxrwx 1 root root 35 3月 14 15:46 open_files -> /usr/share/munin/plugins/open_files
lrwxrwxrwx 1 root root 36 3月 14 15:46 open_inodes -> /usr/share/munin/plugins/open_inodes
lrwxrwxrwx 1 root root 33 3月 14 15:46 proc_pri -> /usr/share/munin/plugins/proc_pri
lrwxrwxrwx 1 root root 34 3月 14 15:46 processes -> /usr/share/munin/plugins/processes
lrwxrwxrwx 1 root root 29 3月 14 15:46 swap -> /usr/share/munin/plugins/swap
lrwxrwxrwx 1 root root 32 3月 14 15:46 threads -> /usr/share/munin/plugins/threads
lrwxrwxrwx 1 root root 31 3月 14 15:46 uptime -> /usr/share/munin/plugins/uptime
lrwxrwxrwx 1 root root 31 3月 14 15:46 vmstat -> /usr/share/munin/plugins/vmstat

*  munin-node（plugin側）内にmysqlの接続設定を追記します

# vi /etc/munin/plugin-conf.d/munin-node

# This file is used to configure how the plugins are invoked.
# Place in /etc/munin/plugin-conf.d/ or corresponding directory.
#
# PLEASE NOTE: Changes in the plugin-conf.d directory are only
# read at munin-node startup, so restart at any changes.
#
# user <user> # Set the user to run the plugin as
# group <group> # Set the group to run the plugin as
# command <command> # Run <command> instead of the plugin. %c
# expands to what would normally be run.
# env.<variable> <value> # Sets <variable> in the plugin's environment, see the
# individual plugins to find out which variables they
# care about.
#
#

[mysql*]
env.mysqlconnection DBI:mysql:mysql;host=192.168.0.49;port=3306
env.mysqluser mysqluserid
env.mysqlpassword mysqlpasswd

[exim*]
group mail

[cps*]
user root

[apt]
user root

[vlan*]
user root

[postfix*]
user root

* munin-node を開始します

[root@muninclient munin]# /etc/init.d/munin-node start
[root@muninclient munin]# /sbin/chkconfig munin-node on

以上でクライアントの設定は終わりです。どうでしょうか？結構簡単に設定できたのではないでしょうか？ここがmuninをお勧めする理由の一つです。20台、30台のPCであれば、zabbixなりでやったほうが管理しやすいかと思いますが、これが数百台規模になってきますと、このmuninのような監視ツールの方が設定が高速で且つ、動作が軽いのでないかと思っております。

最後に、上記にて設定を行うと、WEB上ではどのようなイメージで表示できるかを掲載したいと思います。どうでしょうか？個人的には見やすくて好きです

▼パーミッションがおかしいの何がどうなるのか？
・こんなエラーが出たりします

InnoDB: The error means mysqld does not have the access rights to
InnoDB: the directory.
InnoDB: Error: could not open single-table tablespace file
InnoDB: ./crmdb/vv_mysql_indexes.ibd!
InnoDB: We do not continue the crash recovery, because the table may become
InnoDB: corrupt if we cannot apply the log records in the InnoDB log to it.
InnoDB: To fix the problem and start mysqld:
InnoDB: 1) If there is a permission problem in the file and mysqld cannot
InnoDB: open the file, you should modify the permissions.
InnoDB: 2) If the table is not needed, or you can restore it from a backup,
InnoDB: then you can remove the .ibd file, and InnoDB will do a normal
InnoDB: crash recovery and ignore that table.
InnoDB: 3) If the file system or the disk is broken, and you cannot remove
InnoDB: the .ibd file, you can set innodb_force_recovery > 0 in my.cnf
InnoDB: and force InnoDB to continue crash recovery here.
120313 12:22:50 mysqld_safe mysqld from pid file /var/lib/mysql/dbcrmh01..pid ended

・あと、仮にサービスが再開できたとしても・・
テーブルがあるのに、存在しないとかわけのわからんエラーがでます（not exist!）

▼作業の前提とか・・
・サーバを停止できるものであれば・・・
例えばサーバを停止できるのであれば、やっぱりとめちゃったほうが安全かと思うのです。今回の例では、マスターデータベース停止した際のデータディレクトリをまんまるスレーブサーバに転送してレプリケーションを構築する例です。。あ・・レプリケーションの話にはまったく触れません。。

▼ オーナ・パーミッションの変更作業
下記例では、MySQL5.5のrpm版をベースに書いてます。またデータディレクトリは、/var/lib/mysql です。
・サービスの停止
mysqlサービスはとめておいてください。

[root@db1 mysql]# /etc/init.d/mysql stop

・オーナーの変更
オーナーは、全て mysql グループも mysql でかまいません

[root@db1mysql]# chown -Rf mysql:mysql /var/lib/mysql

・不要なファイルを削除します

[root@db1 mysql]# cd /var/lib/mysql
[root@db1 mysql]# rm -f mysql-bin.*
[root@db1mysql]# rm -f mysqld-slow*
[root@db1 mysql]# rm -f *.err
[root@db1 mysql]# rm -f query.log

・パーミッションの変更
今回の例では、スキーマ名にmyschema1,myschema2というものが存在しております。スキーマにつきましては、データディレクトリ内のサブディレクトリとして作成されます。なので、複数スキーマを構築している場合は、全てのスキーマのパーミッションを変更する必要がございます。

chmod -Rf 600 mysql/
chmod 711 mysql/

chmod -Rf 660 performance_schema/
chmod 700 performance_schema/

chmod -Rf 660 myschema1/
chmod -Rf 660 myschema2

chmod 700 myschema1/
chmod 700 myschema2/

・サービスの再開をします

[root@dbcrmh01 mysql]# /etc/init.d/mysql start

以上、やることはきまっているのでたいした話ではないのですが、突然このような状態になった場合、結構パニックになるので注意が必要です。