Snowflakeのレプリケーショングループで異なるクラウド間のデータベースレプリケーションを試してみた

-- インターバル指定（10分ごと）
REPLICATION_SCHEDULE = '10 MINUTE'

-- Cron式（毎時0分にUTCで実行）
REPLICATION_SCHEDULE = 'USING CRON 0 * * * * UTC'

-- ORGADMIN ロールで実行
USE ROLE ORGADMIN;

-- ソースアカウントのレプリケーションを有効化
SELECT SYSTEM$GLOBAL_ACCOUNT_SET_PARAMETER(
  '<org_name>.<source_account>',
  'ENABLE_ACCOUNT_DATABASE_REPLICATION',
  'true'
);

-- ターゲットアカウントのレプリケーションを有効化
SELECT SYSTEM$GLOBAL_ACCOUNT_SET_PARAMETER(
  '<org_name>.<target_account>',
  'ENABLE_ACCOUNT_DATABASE_REPLICATION',
  'true'
);

-- ソースアカウントで実行
USE ROLE ACCOUNTADMIN;

-- テスト用データベース作成
CREATE OR REPLACE DATABASE REPLICATION_TEST_DB;

-- テスト用テーブル作成
CREATE OR REPLACE TABLE REPLICATION_TEST_DB.PUBLIC.SAMPLE_ORDERS (
    ORDER_ID INT,
    CUSTOMER_NAME VARCHAR(100),
    ORDER_DATE DATE,
    AMOUNT DECIMAL(10, 2)
);

-- テストデータ挿入
INSERT INTO REPLICATION_TEST_DB.PUBLIC.SAMPLE_ORDERS VALUES
    (1, 'Tanaka', '2026-04-01', 1500.00),
    (2, 'Suzuki', '2026-04-02', 2300.00),
    (3, 'Yamada', '2026-04-03', 800.00),
    (4, 'Sato',   '2026-04-04', 4200.00),
    (5, 'Ito',    '2026-04-05', 1100.00);

-- データ確認
SELECT * FROM REPLICATION_TEST_DB.PUBLIC.SAMPLE_ORDERS;

-- ソースアカウントで実行
USE ROLE ACCOUNTADMIN;

CREATE REPLICATION GROUP my_replication_group
  OBJECT_TYPES = DATABASES
  ALLOWED_DATABASES = REPLICATION_TEST_DB
  ALLOWED_ACCOUNTS = <org_name>.<target_account>
  REPLICATION_SCHEDULE = '10 MINUTE';

SHOW REPLICATION GROUPS;

-- ターゲットアカウントで実行
USE ROLE ACCOUNTADMIN;

CREATE REPLICATION GROUP my_replication_group
  AS REPLICA OF <org_name>.<source_account>.my_replication_group;

-- ターゲットアカウントで実行

-- 手動リフレッシュ
ALTER REPLICATION GROUP my_replication_group REFRESH;

-- レプリケートされたデータを確認
SELECT * FROM REPLICATION_TEST_DB.PUBLIC.SAMPLE_ORDERS;

-- ===========================
-- ソースアカウントで実行
-- ===========================

-- 追加データを挿入
INSERT INTO REPLICATION_TEST_DB.PUBLIC.SAMPLE_ORDERS VALUES
    (6, 'Watanabe', '2026-04-10', 3500.00),
    (7, 'Takahashi', '2026-04-11', 900.00),
    (8, 'Kobayashi', '2026-04-12', 6100.00);

-- ソース側の件数確認
SELECT COUNT(*) AS SOURCE_ROW_COUNT FROM REPLICATION_TEST_DB.PUBLIC.SAMPLE_ORDERS;
-- → 8件

-- ===========================
-- ターゲットアカウントで実行
-- ===========================

-- リフレッシュ前の件数確認
SELECT COUNT(*) AS TARGET_ROW_COUNT_BEFORE FROM REPLICATION_TEST_DB.PUBLIC.SAMPLE_ORDERS;
-- → 5件（まだ同期されていない）

-- 手動リフレッシュ実行
ALTER REPLICATION GROUP my_replication_group REFRESH;

-- リフレッシュ後の件数確認
SELECT COUNT(*) AS TARGET_ROW_COUNT_AFTER FROM REPLICATION_TEST_DB.PUBLIC.SAMPLE_ORDERS;
-- → 8件（+3件反映）

-- 追加データの確認
SELECT * FROM REPLICATION_TEST_DB.PUBLIC.SAMPLE_ORDERS WHERE ORDER_ID >= 6;

-- ターゲットアカウントで実行

-- 書き込みを試みる → エラーになるはず
INSERT INTO REPLICATION_TEST_DB.PUBLIC.SAMPLE_ORDERS VALUES
    (99, 'Test', '2026-04-20', 100.00);

-- ターゲットアカウントで実行
SELECT phase_name, start_time, end_time,
       total_bytes, object_count, error
FROM SNOWFLAKE.ACCOUNT_USAGE.REPLICATION_GROUP_REFRESH_HISTORY
WHERE REPLICATION_GROUP_NAME = 'MY_REPLICATION_GROUP'
ORDER BY start_time DESC;

-- ターゲットアカウントで実行
SELECT START_TIME, END_TIME, REPLICATION_GROUP_NAME, CREDITS_USED, BYTES_TRANSFERRED
FROM TABLE(SNOWFLAKE.INFORMATION_SCHEMA.REPLICATION_GROUP_USAGE_HISTORY(
  DATE_RANGE_START => DATEADD('day', -7, CURRENT_DATE())
))
ORDER BY START_TIME DESC;