Choreo でSybase とデータ連携するアプリを作成

こんにちは！リードエンジニアの杉本です。

Choreo は、ローコードおよびクラウドネイティブなSaaS 開発のための多機能かつ包括的なプラットフォームです。 開発者は、高度なコーディングスキルがなくても、Choreo のローコード環境を利用することで簡単にアプリケーションを構築することができます。 さらにCData Connect Server と連携することで、アプリケーションにSybase のデータへのクラウドベースのアクセスを即座に追加できます。 この記事では、Connect Server からSybase に接続し、Choreo からリアルタイムSybase のデータにアクセスするアプリケーションを作成する方法を紹介します。

CData Connect Server は、Sybase にクラウドベースのインターフェースを提供し、ネイティブにサポートされているデータベースにデータを複製することなくChoreo でリアルタイムSybase のデータを使用するアプリケーションを構築できるようにします。 CData Connect Server は最適化されたデータ処理により、サポートされているすべてのSQL 操作（フィルタ、JOIN など）をSybase に直接発行し、サーバー側の処理を利用して要求されたSybase のデータを高速で返します。

Sybase のデータの仮想データベースを作成する

CData Connect Server は、シンプルなポイントアンドクリックインターフェースを使用してデータソースに接続し、データを取得します。まずは、右側のサイドバーのリンクからConnect Server をインストールしてください。

1. Connect Server にログインし、「CONNECTIONS」をクリックします。
2. 一覧から「Sybase」を選択します。
3. Sybase に接続するために必要な認証プロパティを入力します。

   Sybase は、Basic 認証、Kerberos 認証、LDAP 認証などの認証方法をいくつかサポートしています。

   Basic 認証を使用した接続

   次を設定してデータを認証し接続します。User およびPassword を設定してSybaseIQ 認証を使用します。

   • User：認証Sybase ユーザーのユーザー名に設定。
   • Password：認証Sybase ユーザーのパスワードに設定。
   • Server：SybaseIQ またはSAP SQL Anywhere データベースインスタンスの名前またはネットワークアドレスに設定。
   • Database：指定されたサーバーで実行されているSybaseIQ またはSAP SQL Anywhere データベースの名前に設定。

   オプションで、UseSSL をtrue に設定することにより、TLS/SSL で接続を保護できます。

   Note： 上記のCData 製品 設定でSAP SQL Anywhere のインスタンスに接続することもできます。

   Kerberos 認証を使用した接続

   Kerberos 認証を活用するには、次の接続プロパティを使用してそれを有効にすることから始めます。

   • AuthScheme：Kerberos に設定すると、Sybase への認証に使用されます。

   Kerberos 認証用に設定する必要がある接続プロパティに関しては、Kerberos の使用 情報を参照してください。

   以下は接続文字列の例です。 Server=MyServer;Port=MyPort;User=SampleUser;Password=SamplePassword;Database=MyDB;Kerberos=true;KerberosKDC=MyKDC;KerberosRealm=MYREALM.COM;KerberosSPN=server-name

   LDAP 認証を使用した接続

   LDAP 認証で接続するには、LDAP 認証メカニズムを使用するようにSybase サーバーサイドを設定する必要があります。

   LDAP 用にSybase を設定したら、Basic 認証と同じクレデンシャルを使用して接続できます。

4. 「 Test Connection」をクリックします。
5. 「Permission」->「 Add」とクリックし、適切な権限を持つ新しいユーザー(または既存のユーザー) を追加します。

仮想データベースが作成されたら、Choreo を含むお好みのクライアントからSybase に接続できるようになります。

Choreo からSybase への接続

以下のステップでは、Choreo からCData Connect Server に接続し、リアルタイムSybase のデータにアクセスできる新しいアプリケーションを作成する方法を紹介します。

コンストラクトを作成する

1. Choreo プラットフォームにサインインします。Note：この記事は、Anonymously を選択した場合について説明しています。
2. 左サイドバーからComponents を選択し、+Create をクリックします。次に、Manual Trigger を選択し、続けてStart from scratch を選択します。
3. マニュアルトリガーのName とDescription を入力し、Create をクリックします。
4. トリガーが作成されたら、Edit Code をクリックします。
5. Ballerina Low-Code IDE が表示されます。Choreo は、ローコードダイアグラムビューでコンストラクトを自動生成します。 このコンストラクトをハイライトしてゴミ箱アイコンをクリックし、削除します。
6. 画面上部の + アイコンをクリックし、右サイドのAdd Constructs ツールバーにあるMain を選択します。 続けてFunction Configuration フォームでSave をクリックします。

CData Connect Server コネクタを追加する

1. 楕円形のSTART とEND の間にある + アイコンをクリックして、Connector をクリックします。

2. 右サイドバーのConnectors で「CData」を検索します。CData Connect をクリックしてConnector 設定ペインを開きます。

3. Connector 設定ペインで、構成の設定を入力します。
   • 使用するEndpoint Name を入力します。例では「connectEndpoint」を使用しています。
   • User フィールドに、CData Connect Server ユーザーのE メールアドレスを引用符で囲んで入力します（例："[email protected]"）。
   • Password フィールドにConnect Server のパスワードを引用符で囲んで入力します（例："SampleToken"）。

4. Save をクリックすると、CData Connect Server のロゴがついたローコードエディタが表示されます。

クエリのアクションを追加する

1. new とend の間の + アイコンをクリックし、Action を選択して既存のコネクタエンドポイントを選択します。

2. connector Operation クエリを選択します。右側にAction ペインが表示されます。

3. Sybase のデータを取得するためのSQL クエリを、query のsqlQuery パラメータとして入力します。次に例を示します。 SELECT * FROM Sybase1.Sybase.Products LIMIT 10
   • クエリを入力する際、カタログにConnection Name を、スキーマにData Source Name を必ず指定してください。例えば、Sybase1.Sybase です。
   • これらのパラメータはCData Connect Server のConnections ページに表示されます。

Sybase のデータを反復処理する

1. コードエディタの右上にあるShow Source アイコンをクリックします。
2. ballerina/io ライブラリをインポートするimport 文を追加します。

   		
   		import ballerina/io;
   	

3. 次に、SQL クエリの結果を繰り返し処理するために、query アクションの後にfrom 文を追加します。

		
		check from record{} result in resultStream
		do {
			io:println("Full Products details: ", result);
		};
	

4. コンストラクトのコードは次のようになります。

			
			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 Sybase1.Sybase.Products LIMIT 10`);

				check from record{} result in resultStream
				do {
					io:println("Full Products details: ", result);
				};
			}
		

5. Save をクリックしてアクションを保存します。次のようなダイアグラムになります。

プログラムをデプロイする

必要とするアクションをすべてプログラムに追加したら、次のステップに進みます。

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

Choreo でリアルタイムSybase のデータにアクセスできるアプリケーションを作成できました。

CData Connect Server の入手

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