各製品の資料を入手。
詳細はこちら →Choreo でDB2 とデータ連携するアプリを作成
CData Connect Server を使ってChoreo からDB2 に接続し、リアルタイムDB2 のデータと連携するカスタムアプリを構築します。
最終更新日:2022-11-20
こんにちは!リードエンジニアの杉本です。
Choreo は、ローコードおよびクラウドネイティブなSaaS 開発のための多機能かつ包括的なプラットフォームです。 開発者は、高度なコーディングスキルがなくても、Choreo のローコード環境を利用することで簡単にアプリケーションを構築することができます。 さらにCData Connect Server と連携することで、アプリケーションにDB2 のデータへのクラウドベースのアクセスを即座に追加できます。 この記事では、Connect Server からDB2 に接続し、Choreo からリアルタイムDB2 のデータにアクセスするアプリケーションを作成する方法を紹介します。
CData Connect Server は、DB2 にクラウドベースのインターフェースを提供し、ネイティブにサポートされているデータベースにデータを複製することなくChoreo でリアルタイムDB2 のデータを使用するアプリケーションを構築できるようにします。 CData Connect Server は最適化されたデータ処理により、サポートされているすべてのSQL 操作(フィルタ、JOIN など)をDB2 に直接発行し、サーバー側の処理を利用して要求されたDB2 のデータを高速で返します。
ホスティングについて
Choreo からCData Connect Server に接続するには、利用するConnect Server インスタンスをネットワーク経由での接続が可能なサーバーにホスティングして、URL での接続を設定する必要があります。CData Connect がローカルでホスティングされており、localhost アドレス(localhost:8080 など)またはローカルネットワークのIP アドレス(192.168.1.x など)からしか接続できない場合、Choreo はCData Connect Server に接続することができません。
クラウドホスティングでの利用をご希望の方は、AWS Marketplace やGCP Marketplace で設定済みのインスタンスを提供しています。
DB2 のデータの仮想データベースを作成する
CData Connect Server は、シンプルなポイントアンドクリックインターフェースを使用してデータソースに接続し、データを取得します。まずは、右側のサイドバーのリンクからConnect Server をインストールしてください。
- Connect Server にログインし、「CONNECTIONS」をクリックします。
- 一覧から「DB2」を選択します。
-
DB2 に接続するために必要な認証プロパティを入力します。
DB2 への接続には以下を入力します:
- Server: DB2 が稼働しているサーバー。
- Port: DB2 サーバーのポート。
- Database: DB2 のデータベース。
- User: DB にアクセスする権限のあるユーザー名。
- Password: DB にアクセスする権限のあるユーザーのパスワード。
対応するDB2 のドライバーをインストールする必要があります。
- Windows: IBM Data Server Provider for .NET
Windows では、IBM Data Server Provider をインストールするだけで十分です。インストールがmachine.config への書き込みを行います。
- Java: IBM Data Server Driver for JDBC
Java では、IBM Data Server Driver JAR をアプリケーションのwww\WEB-INF\lib\ フォルダに配置する必要があります。
パスワード方式によるSSH 接続
パスワード方式によるSSH接続時に必要なプロパティ一覧を以下に示します。
- User: DB2 のユーザ
- Password: DB2 のパスワード
- Database: DB2 の接続先データベース
- Server: DB2 のサーバー
- Port: DB2 のポート
- UserSSH: "true"
- SSHAuthMode: "Password"
- SSHPort: SSH のポート
- SSHServer: SSH サーバー
- SSHUser: SSH ユーザー
- SSHPassword: SSH パスワード
接続文字列形式では以下のようになります。
Server=10.0.1.2;Port=50000;User=admin;Password=admin;Database=testUseSSH=true;SSHAuthMode=Password;SSHPort=22;SSHServer=ssh-server;SSHUser=root;SSHPassword=sshpasswd;
公開鍵認証方式方式によるSSH 接続
公開鍵認証によるSSH接続時に必要なプロパティ一覧を以下に示します。
- User: DB2 のユーザ
- Password: DB2 のパスワード
- Database: DB2 の接続先データベース
- Server: DB2 のサーバー
- Port: DB2 のポート
- UserSSH: "true"
- SSHAuthMode: "Public_Key"
- SSHClientCertType: キーストアの種類
- SSHPort: SSH のポート
- SSHServer: SSH サーバー
- SSHUser: SSH ユーザー
- SSHClientCert: 秘密鍵ファイルのパス
接続文字列形式では以下のようになります。
Server=10.0.1.2;Port=50000;User=admin;Password=admin;Database=test;UseSSH=true;SSHAuthMode=Public_Key;SSHClientCertType=PUBLIC_KEY_FILE;SSHPort=22;SSHServer=ssh-server;SSHUser=root;SSHClientCert=C:\Keys\key.pem;
- 「 Test Connection」をクリックします。
- 「Permission」->「 Add」とクリックし、適切な権限を持つ新しいユーザー(または既存のユーザー) を追加します。
仮想データベースが作成されたら、Choreo を含むお好みのクライアントからDB2 に接続できるようになります。
Choreo からDB2 への接続
以下のステップでは、Choreo からCData Connect Server に接続し、リアルタイムDB2 のデータにアクセスできる新しいアプリケーションを作成する方法を紹介します。
コンストラクトを作成する
-
Choreo プラットフォームにサインインします。Note:この記事は、Anonymously を選択した場合について説明しています。
-
左サイドバーからComponents を選択し、+Create をクリックします。次に、Manual Trigger を選択し、続けてStart from scratch を選択します。
-
マニュアルトリガーのName とDescription を入力し、Create をクリックします。
-
トリガーが作成されたら、Edit Code をクリックします。
-
Ballerina Low-Code IDE が表示されます。Choreo は、ローコードダイアグラムビューでコンストラクトを自動生成します。
このコンストラクトをハイライトしてゴミ箱アイコンをクリックし、削除します。
-
画面上部の + アイコンをクリックし、右サイドのAdd Constructs ツールバーにあるMain を選択します。
続けてFunction Configuration フォームでSave をクリックします。
CData Connect Server コネクタを追加する
- 楕円形のSTART とEND の間にある + アイコンをクリックして、Connector をクリックします。
- 右サイドバーのConnectors で「CData」を検索します。CData Connect をクリックしてConnector 設定ペインを開きます。
-
Connector 設定ペインで、構成の設定を入力します。
- 使用するEndpoint Name を入力します。例では「connectEndpoint」を使用しています。
- User フィールドに、CData Connect Server ユーザーのE メールアドレスを引用符で囲んで入力します(例:"[email protected]")。
- Password フィールドにConnect Server のパスワードを引用符で囲んで入力します(例:"SampleToken")。
- Save をクリックすると、CData Connect Server のロゴがついたローコードエディタが表示されます。




クエリのアクションを追加する
- new とend の間の + アイコンをクリックし、Action を選択して既存のコネクタエンドポイントを選択します。
- connector Operation クエリを選択します。右側にAction ペインが表示されます。
- DB2 のデータを取得するためのSQL クエリを、query のsqlQuery パラメータとして入力します。次に例を示します。
SELECT * FROM DB21.DB2.Orders LIMIT 10
- クエリを入力する際、カタログにConnection Name を、スキーマにData Source Name を必ず指定してください。例えば、DB21.DB2 です。
- これらのパラメータはCData Connect Server のConnections ページに表示されます。


DB2 のデータを反復処理する
- コードエディタの右上にあるShow Source アイコンをクリックします。
- ballerina/io ライブラリをインポートするimport 文を追加します。
import ballerina/io;
- 次に、SQL クエリの結果を繰り返し処理するために、query アクションの後にfrom 文を追加します。
- コンストラクトのコードは次のようになります。
- Save をクリックしてアクションを保存します。次のようなダイアグラムになります。
check from record{} result in resultStream do { io:println("Full Orders details: ", result); };
import ballerinax/cdata.connect; import ballerinax/cdata.connect.driver as _; import ballerina/io; public function main() returns error? { connect:Client connectEp = check new (user = "connect_cloud_username", password="connect_cloud_pat"); stream<record {}, error=""?> resultStream = connectEp->query(sqlQuery = `SELECT * FROM DB21.DB2.Orders LIMIT 10`); check from record{} result in resultStream do { io:println("Full Orders details: ", result); }; }

プログラムをデプロイする
必要とするアクションをすべてプログラムに追加したら、次のステップに進みます。
- Web エディタで最終的なソースコードをコミットしてプッシュし、その変更をChoreo プラットフォームに同期します。
- Choreo Console の左ナビゲーションバーでDeploy をクリックします。
- Build Area でConfigure & Deploy をクリックし、プログラムをデプロイします。
- プロンプトが表示されたら、先ほど使用したCData Connect Server のユーザー名とパスワードを入力し、Deploy をクリックします。

Choreo でリアルタイムDB2 のデータにアクセスできるアプリケーションを作成できました。
CData Connect Server の入手
Choreo をCData Connect Server で連携するための詳細は、CData Connect Ballerina Guide を参照してください。 CData Connect Server の30日間無償トライアルを利用して、クラウドアプリケーションから100を超えるSaaS、ビッグデータ、NoSQL データソースへのダイレクトなSQL アクセスをお試しください!