```
### スキーマダンプをターゲットデータベースに適用する
スキーマダンプファイルを整理したら、`psql` で[接続](/ja/products/managed-postgres/connection)し、スキーマダンプファイルを実行して、ターゲットの ClickHouse Managed Postgres データベースに適用できます。
```shell theme={null}
psql -h -p -U -d -f source_schema.sql
```
ターゲット側では、外部キー制約によって PeerDB のインジェストが妨げられないようにします。そのため、ターゲットのロール (上記でターゲットピアに使用したもの) を変更して、`session_replication_role` を `replica` に設定できます。
```sql theme={null}
ALTER ROLE SET session_replication_role = replica;
```
## ミラーを作成する
次に、ソースピアとターゲットピア間のデータ移行プロセスを定義するため、ミラーを作成します。PeerDB UI で、サイドバーの "Mirrors" をクリックして "Mirrors" セクションに移動します。新しいミラーを作成するには、`+ New mirror` ボタンをクリックします。
1. 移行内容が分かる名前をミラーに付けます。
2. ドロップダウンメニューから、先ほど作成したソースピアとターゲットピアを選択します。
3. 次のことを確認します。
* Soft delete が OFF になっていること。
* `Advanced settings` を展開し、**Postgres type system が有効**で、**PeerDB columns が無効**になっていることを確認します。
4. 移行するテーブルを選択します。特定のテーブルを選ぶことも、ソースデータベース内のすべてのテーブルを選ぶこともできます。
**テーブルの選択**
前の手順でスキーマをそのまま移行しているため、ターゲットデータベース内の宛先テーブル名がソーステーブル名と同じであることを確認してください。
5. ミラーの設定が完了したら、`Create mirror` ボタンをクリックします。
"Mirrors" セクションに、新しく作成したミラーが表示されます。
## 初期ロードを待つ
ミラーを作成すると、PeerDB はソースからターゲットデータベースへの初期データロードを開始します。ミラーをクリックし、**初期ロード** タブを開くと、初期データ移行の進捗を確認できます。
初期ロードが完了すると、移行が完了したことを示すステータスが表示されます。
## 初期ロードとレプリケーションの監視
ソースピアをクリックすると、PeerDB が実行中のコマンド一覧を確認できます。たとえば、次のとおりです。
1. まず、各テーブルの行数を見積もるために COUNT クエリを実行します。
2. 次に、NTILE を使用したパーティション化クエリを実行し、大きなテーブルを効率的に転送できるよう、より小さな chunk に分割します。
3. その後、FETCH コマンドを実行してソースデータベースからデータを取得し、PeerDB がそれらをターゲットデータベースに同期します。
## 移行後の作業
これらの手順は、具体的なユースケースやアプリケーション要件によって異なる場合があります。重要なのは、新しいシステムへ完全に切り替える前に、データの整合性を確保し、ダウンタイムを最小限に抑え、移行したデータに問題がないことを検証することです。
移行が完了したら、次の作業を実施します。
* **カットオーバー前の検証を実行する**
トラフィックを切り替える前に、ソース側とターゲット側の主要なテーブルを比較します。
```sql theme={null}
-- 重要なテーブルの行数比較
SELECT 'public.orders' AS table_name, COUNT(*) AS row_count FROM public.orders;
SELECT 'public.customers' AS table_name, COUNT(*) AS row_count FROM public.customers;
-- 高頻度テーブルの最新レコードの抜き取り確認
SELECT MAX(updated_at) FROM public.orders;
SELECT MAX(id) FROM public.orders;
```
* **ソースシステムでの書き込みを停止する**
まず、アプリケーションからの書き込みを一時停止します。さらに安全性を高めるため、切り替え時にはソースデータベースを読み取り専用に設定します。
```sql theme={null}
ALTER DATABASE SET default_transaction_read_only = on;
```
ロールバックが必要な場合は、書き込みを再度有効化できます。
```sql theme={null}
ALTER DATABASE SET default_transaction_read_only = off;
```
* **レプリケーションが完全に追いついていることを確認する**
書き込み頻度の高い1つ以上のテーブルについて、最新の行が移行元と移行先で一致していることを確認します。
```sql theme={null}
-- ソースとターゲットの両方で実行し、結果を比較する
SELECT MAX(id) AS latest_id, MAX(updated_at) AS latest_ts FROM public.orders;
```
* **制約、索引、トリガーを再作成して有効にする**
インジェストのために制約や索引を削除したり適用を保留したりしていた場合は、ここで再度適用します。また、以前にターゲット側のレプリケーションロールを `replica` に設定していた場合は、それもリセットしてください。
```sql theme={null}
ALTER ROLE SET session_replication_role = origin;
```
```shell theme={null}
# 例: 制約/索引/トリガーを含むSQLファイルを適用する
psql -h -p -U -d -f post_migration_objects.sql
```
* **ターゲットテーブルのシーケンスをリセットする**
データの読み込み後、シーケンスをテーブルの現在の値に合わせます。
```sql theme={null}
-- システムスキーマ以外の全シリアル/IDカラムに対する汎用シーケンスリセット
DO $$
DECLARE r RECORD;
BEGIN
FOR r IN
SELECT
n.nspname AS schema_name,
c.relname AS table_name,
a.attname AS column_name,
pg_get_serial_sequence(format('%I.%I', n.nspname, c.relname), a.attname) AS seq_name
FROM pg_class c
JOIN pg_namespace n ON n.oid = c.relnamespace
JOIN pg_attribute a ON a.attrelid = c.oid
WHERE c.relkind = 'r'
AND a.attnum > 0
AND NOT a.attisdropped
AND n.nspname NOT IN ('pg_catalog', 'information_schema')
LOOP
IF r.seq_name IS NOT NULL THEN
EXECUTE format(
'SELECT setval(%L, COALESCE((SELECT MAX(%I) FROM %I.%I), 0) + 1, false)',
r.seq_name, r.column_name, r.schema_name, r.table_name
);
END IF;
END LOOP;
END $$;
```
* **アプリケーショントラフィックを切り替える**
検証が完了し、シーケンスと制約の設定が済んだら:
1. 読み取りトラフィックの送信先を ClickHouse Managed Postgres に切り替えます。
2. 書き込みトラフィックの送信先を ClickHouse Managed Postgres に切り替えます。
3. アプリケーションエラー、制約違反、データベースの健全性を監視します。
* **リソースをクリーンアップする**
移行に問題がないことを確認し、アプリケーションの切り替え先を ClickHouse Managed Postgres に変更したら、PeerDB のミラーとピアを削除できます。
**レプリケーションスロット**
継続的レプリケーションを有効にしている場合、PeerDB は移行元の PostgreSQL データベースに **レプリケーションスロット** を作成します。不要なリソース消費を避けるため、移行が完了したら、移行元データベースからレプリケーションスロットを手動で削除してください。
## 参考資料
* [ClickHouse Managed Postgres ドキュメント](/ja/products/managed-postgres/overview)
* [CDC 作成に関する PeerDB ガイド](https://docs.peerdb.io/mirror/cdc-pg-pg)
* [Postgres ClickPipe よくある質問 (PeerDB にも同様に当てはまります) ](/ja/integrations/clickpipes/postgres/faq)
## 次のステップ
おめでとうございます。pg\_dump と pg\_restore を使用して、PostgreSQL データベースを ClickHouse Managed Postgres に正常に移行できました。これで、Managed Postgres の機能や ClickHouse とのインテグレーションを確認する準備は万全です。使い始めるには、以下の 10 分で読めるクイックスタートをご覧ください。
* [Managed Postgres クイックスタートガイド](/ja/products/managed-postgres/quickstart)