第21章 SQL データベースへの接続

手順

1. 接続するデータベースの JDBC ドライバーがクラスパスにあるようにしてください。プロプライエタリーデータベースに接続するために JDBC ドライバーライブラリーエクステンションをアップロードした場合、ドライバーはアップロードプロセスによってクラスパス上に置かれます。「JDBC ドライバーライブラリーエクステンションの作成」を参照してください。
2. Fuse Online の左パネルで Connections をクリックし、利用可能なコネクションを表示します。
3. 右上にある Create Connection をクリックし、Fuse Online コネクターを表示します。
4. Database コネクターをクリックします。

5. 以下を入力してコネクションを設定します。

   1. Connection URL フィールドに、接続するデータベースの JDBC URL を入力します。たとえば、jdbc:postgresql://ignite-db1234/sampledb を入力します。
   2. Username フィールドに、データベースのアクセスに使用するアカウントの名前を入力します。同じアカウントのパスワードとユーザー名を指定するようにしてください。
   3. Password フィールドに、データベースのアクセスに使用する、ユーザーアカウントに関連するパスワードを入力します。
   4. Schema フィールドにデータベースのスキーマの名前を入力します。コネクション URL がスキーマを指定する場合、このフィールドがコネクション URL と同じスキーマを示すようにしてください。たとえば、sampledb を入力します。
6. Validate をクリックします。Fuse Online はコネクションの検証を試み、検証の成功または失敗を示すメッセージを表示します。検証に失敗した場合は、必要に応じて設定の詳細を修正し、再度検証を行います。
7. 検証に成功した場合は Next をクリックします。
8. Name フィールドに、このコネクションを別のコネクションと区別するために使用する名前を入力します。たとえば、PostgreSQL DB 1 を入力します。
9. Description は任意のフィールドで、このコネクションに関する便利な情報を入力します。たとえば、Sample PostgreSQL connection that uses my login credentials. を入力します。
10. Save をクリックし、作成したコネクションが利用可能になったことを確認します。上記の例の名前を入力した場合は、インテグレーションに追加できるコネクションとして PostgreSQL DB 1 が表示されます。

手順

1. Fuse Online パネルの左側にある Integrations をクリックします。
2. Create Integration をクリックします。
3. Choose a connection ページで、インテグレーションを開始するために使用するデータベースコネクションをクリックします。

4. Choose an action ページで、以下の 1 つを選択します。

   • Periodic SQL invocation は、指定した SQL ステートメントを定期的に呼び出して、データを取得します。
   • Periodic stored procedure invocation は、選択または指定したストアドプロシージャーを定期的に呼び出して、データを取得します。

5. Periodic SQL invocation を選択した場合、Query フィールドに SQL SELECT ステートメントまたは 1 つ以上のレコードを取得する他の標準の SQL ステートメントを入力します。例: SELECT * from my_db_table必要なデータが含まれるデータベーステーブルが存在する必要があります。

   Periodic stored procedure invocation を選択した場合、Procedure name フィールドに必要なデータを取得するために呼び出すストアドプロシージャーを選択または入力します。指定するストアドプロシージャーが存在する必要があります。データベース管理者は、インテグレーションで使用する必要があるストアドプロシージャーを作成しておく必要があります。

6. Period フィールドに整数を入力し、単位がミリ秒、秒、分、時間、または日であるかを示します。たとえば、5 minutes を指定した場合、コネクションは指定のステートメントまたはストアドプロシージャーを 5 分間隔で呼び出します。
7. Next をクリックします。

手順

1. Add to Integration ページで、コネクションの追加先のプラス記号をクリックします。Fuse Online が最後のコネクションを選択するよう要求する場合は、このステップをスキップします。
2. アクセスするデータベースのデータベースコネクションをクリックします。

3. Choose an action ページで、以下の 1 つを選択します。

   • Invoke SQL は、指定の SQL ステートメントを実行してデータを操作します。
   • Invoke stored procedure は指定または選択したストアドプロシージャーを呼び出してデータを操作します。

4. Invoke SQL を選択した場合、SQL Statement フィールドで以下を行います。

   • 途中のコネクションでは、1 つ以上のレコードを取得する SQL SELECT ステートメントを入力するか、1 つ以上のレコードを操作する SQL INSERT、UPDATE、または DELETE ステートメントを入力します。データが含まれるデータベースが存在する必要があります。
   • 最後のコネクションでは、SQL INSERT、UPDATE、または DELETE ステートメントを入力し、1 つ以上のレコードを操作します。

   • Batch update フィールドで、デフォルトの No を使用するか、Yes を選択します。

     Batch update の設定は、このアクションへの入力がコレクションで、SQL ステートメントがレコードを挿入、削除、または更新する場合にコネクションの動作に影響します。デフォルトの動作 (Batch update が No の場合) では、コネクションは個別のオブジェクトのみを受け入れ、各オブジェクトに対して 1 度 SQL ステートメントを実行します。Batch update が Yes の場合、コネクションはコレクションをアクションへの入力として受け入れます。コネクションは SQL ステートメントを 1 度実行し、すべてのコレクションアイテムをバッチ更新操作への入力として使用します。

   Invoke stored procedure を選択した場合、Procedure name フィールドに必要なデータを操作するために呼び出すストアドプロシージャーの名前を選択または入力します。指定するストアドプロシージャーが存在する必要があります。データベース管理者は、インテグレーションで使用する必要があるストアドプロシージャーを作成しておく必要があります。

5. Next をクリックします。

1. 開発者は、インテグレーションで接続するデータベースの JDBC ドライバーが含まれるライブラリーエクステンションを作成します。「JDBC ドライバーライブラリーエクステンションの作成」を参照してください。
2. 開発者はライブラリーエクステンションが含まれる .jar ファイルを提供します。
3. その .jar ファイルを Fuse Online にアップロードします。「カスタム機能の使用」を参照してください。
4. Fuse Online の Database コネクターを選択し、データベースのコネクション URL を指定して、データベースへのコネクションを作成します。「データベースコネクションの作成」を参照してください。
5. インテグレーションで、コネクションをデータベースに追加します。「データベースレコードを取得してインテグレーションの実行をトリガー」または「インテグレーションの途中またはインテグレーションを完了するためにデータベースにアクセス」を参照してください。