SeaTunnelを使用したOceanBaseデータの読み取りと同期

SeaTunnelのJDBC OceanBase Source ConnectorとJDBC OceanBase Sink Connectorを使用してデータを同期する方法について説明します。JDBC OceanBase Source Connectorは、OceanBaseの単一テーブルデータのフルロード読み取りと書き込みをサポートします。詳細については、JDBC OceanBase Source Connectorを参照してください。JDBC OceanBase Sink Connectorは、OceanBaseの複数テーブルデータに対するフルロード読み取りと書き込みをサポートします。詳細については、JDBC OceanBase Sink Connectorを参照してください。

操作手順

以下の手順に従って、OceanBaseデータベースのMySQLテナント間でのデータ同期を実行する：

1. SeaTunnelユーザーを作成します。

    CREATE USER 'ユーザー名'@'%' IDENTIFIED BY 'パスワード';
    GRANT SELECT, INSERT, UPDATE, DELETE ON *.* TO 'ユーザー名';
   

2. config/plugin_config を設定します。

3. OceanBase JDBCドライバーを lib ディレクトリにダウンロードします。詳細については、OceanBase Clientを参照してください。

4. SeaTunnelを設定します。

   設定ファイル config/ob_to_ob を修正します：

   env {
   parallelism = 1
   job.mode = "BATCH"
   }
   
   source {
   # This is a example source plugin **only for test and demonstrate the feature source plugin**
   Jdbc {
       driver = com.oceanbase.jdbc.Driver
       url = "jdbc:oceanbase://e2e_oceanbase_mysql:2881/seatunnel?useUnicode=true&characterEncoding=UTF-8&rewriteBatchedStatements=true&serverTimezone=UTC"
       user = "ユーザー名"
       password = "パスワード"
       query = "SELECT c_bit_1, c_bit_8 FROM source"
       compatible_mode = "mysql"
   }
   
   # If you would like to get more information about how to configure seatunnel and see full list of source plugins,
   # please go to https://seatunnel.apache.org/docs/connector-v2/source/FakeSource
   }
   
   sink {
   Jdbc {
       driver = com.oceanbase.jdbc.Driver
       url = "jdbc:oceanbase://e2e_oceanbase_mysql:2881/seatunnel?useUnicode=true&characterEncoding=UTF-8&rewriteBatchedStatements=true&serverTimezone=UTC"
       user = "ユーザー名"
       password = "パスワード"
       query = "insert into sink(c_bit_1, c_bit_8) values (?, ?);"
       compatible_mode = "mysql"
   }
   # If you would like to get more information about how to configure seatunnel and see full list of sink plugins,
   # please go to https://seatunnel.apache.org/docs/connector-v2/sink
   } 
   

5. SeaTunnelを起動します。

   以下のコマンドを実行して、SeaTunnelを起動します：

   ./bin/seatunnel.sh --config ./config/ob_to_ob -e local