MySQL Shellで作るInnoDB ReplicaSet

本記事は Create an InnoDB Replica Set With MySQL Shell の翻訳版です。

MySQL Shellを使うことで、InnoDB ReplicaSetを簡単に短時間で作成できます。複数のコマンドを実行するだけで、ReplicaSetの作成からセカンダリ・インスタンスの追加、プライマリ・インスタンスからセカンダリ・インスタンスへのデータのクローンまで行うことができます。本記事ではそのやり方をご紹介します。

前提条件

本実施例では、ポート5555と5556をMySQL Sandboxインスタンスに割り当て、ポート5555で実行するインスタンスをプライマリ・インスタンス、ポート5556で実行するインスタンスをセカンダリ・インスタンスとします。ポート5555のプライマリ・インスタンスにmysql_shortsというスキーマを用意しこのデータをレプリケートします。

MySQL Sandboxインスタンスについては、関連ブログおよび公式Webマニュアルをご覧下さい。

プライマリ・インスタンス(ポート5555)のスキーマは下記です。

show schemas;

セカンダリ・インスタンス(ポート5556)のスキーマは下記です。

show schemas;

上記で表示した通り本実施例においてReplicaSet作成前の段階では、プライマリ・インスタンス(ポート5555)に存在するスキーマmysql_shortsが、セカンダリ・インスタンス(ポート5556)にはありません。

InnoDB ReplicaSet の作成

InnoDB ReplicaSet作成するにはまず、MySQL Shellを使用してプライマリ・インスタンスに接続し、JavaScriptモードで次のコマンドを実行します。

\c root@localhost:5555

var rs = dba.createReplicaSet("demo_set")

上記のコマンドによって作成する新しいInnoDB ReplicaSetを rs と設定します。ReplicaSetの作成を実行すると以下の様なテキストが出力されます。

ステータスの確認

下記のコマンドを実行すると、新しく作成したInnoDB ReplicaSetのステータスを確認できます。

rs.status()

実行すると、InnoDB ReplicaSetのステータスがJSONオブジェクトとして表示されます。下記の表示例では、demo_setという名前のInnoDB ReplicaSetにプライマリ・インスタンス(ポート5555)があることを示しています。

セカンダリ・インスタンスの追加

InnoDB ReplicaSetには1個以上のセカンダリ・インスタンスが必要です。本実行例では、MySQL Shellをプライマリ・インスタンスに接続した状態から、下記コマンドでセカンダリ・インスタンス(ポート5556)を1個追加します。

rs.addInstance('root@localhost:5556')

上記コマンドはReplicaSet・オブジェクト rs の addInstance() メソッドを呼び出します。このメソッドを呼び出すときは、追加するインスタンスの接続文字列を引数として渡します。上の実行例ではrootユーザを使用して、ポート5556のローカル・システムのインスタンスに接続します。

注: 上記では実行例として分かりやすいように、rootユーザーを使用しています。実際の運用システムでは、レプリケーションなどの全てのプロセスでrootを使用するのは、必要に応じて避けて下さい。

途中でリカバリ・メソッドを選択するように求められます。本実行例ではプライマリ・インスタンスからセカンダリ・インスタンスへ最も簡単にデータ移行できる、Clone を選択します。出力は下のようになります。

出力されるメッセージにはレプリケーションの進行状況と、ポート5556のインスタンスがReplicaSetに追加され、ポート5556のインスタンスからレプリケーションが実行されていることが表示されます。

ステータスの確認

追加したセカンダリ・ノードに関する情報が、ReplicaSetステータスの表示にも追加されます。

rs.status()

ReplicaSetのステータスに先ほど追加したセカンダリ・インスタンスの情報が含まれます。

ReplicaSetの動作確認

ここまでの作業でReplicaSetが動いている状態なので、正しく動作していることを確認します。

セカンダリ・スキーマ

セカンダリ・インスタンス(ポート5556)の現在のスキーマを確認するには、MySQL Shellを使用してインスタンスに接続し、次のコマンドを実行します。

show schemas;

下記はこのコマンドの出力例です。

ReplicaSet作成後に新しいスキーマが追加されたことが分かります。

• mysql_shorts -プライマリ・インスタンスからコピーされたスキーマ
• mysql_innodb_cluster_metadata – レプリケーションの管理に使用されるスキーマ
   

プライマリ・インスタンスに行追加

mysql_shortsスキーマのuserテーブルに行を挿入します。このテーブルには下記の4つの列があります。

• id – テーブルのプライマリ・キー
• first_name – ユーザーの名
• last_name – ユーザーの姓
• email – ユーザーのメール・アドレス

MySQL Shell を使用してプライマリ・インスタンス(ポート5555) に接続し、次のクエリを実行します。

insert into
    mysql_shorts.user(
    first_name,
    last_name,
    email
    )
values (
    'Skippy',
    'Dinglehoffer',
    'skip@dingle.com'
       );

次のクエリを実行して、行が正しく追加されていることを確認します。

select * from mysql_shorts.user order by id desc limit 5;

下記は出力例です。

先ほどプライマリ・インスタンスに追加した、Skippy Dinglehofferの行が表示されていることを確認します。

レプリカの確認

レプリケーションの動作確認には、MySQL Shellを使用してセカンダリ・インスタンス(ポート5556)に接続し、上記と同じクエリを実行します。

select * from mysql_shorts.user order by id desc limit 5;

出力結果がプライマリ・インスタンスで実行したものと一致するか確認します。

プライマリ・インスタンスに追加したユーザの行が、セカンダリ・インスタンスにも存在していれば、レプリケーションは正常に動作しています。

読み取り専用の確認

本記事でご紹介した手順でReplicaSetを作成すると、全てのセカンダリ・インスタンスが読み取り専用として動作します。つまり、セカンダリ インスタンスに直接データを挿入することはできません。

mysql_shorts.user テーブルにデータ行を挿入するクエリを、セカンダリ・インスタンスで実行することで確認します。

insert into
    mysql_shorts.user(
    first_name,
    last_name,
    email
    )
values (
    'Asmine',
    'Ono',
    'asmine@chikuwabu.com'
       );

実行すると下のように、セカンダリ・インスタンスが読み取り専用であることを知らせるメッセージが表示されます。

まとめ

MySQL Shellを使用すると、InnoDB ReplicaSetを短時間で且つ簡単に作成できます。複数のコマンドを実行するだけで、InnoDB ReplicaSetの作成からセカンダリ・インスタンスの追加まで完了します。本記事ではInnoDB ReplicaSet作成の検証を、MySQL SandboxインスタンスとMySQL Shellを使用して行いました。InnoDB ReplicaSetについて詳しくは、公式Webマニュアルをご覧下さい。