Parquet のデータをFastAPPに連携して活用

Parquet をクラウドプラットフォームのFastAPP からデータ連携して、データソースとする方法。

加藤龍彦
デジタルマーケティング
最終更新日：2022-03-01

CData

こんにちは！ウェブ担当の加藤です。マーケ関連のデータ分析や整備もやっています。

CData JDBC Driver for Parquet は、JDBC 標準をインプリメントし、BI ツールからIDE まで幅広いアプリケーションでParquet のデータへの接続を提供します。この記事では、クラウドプラットフォームのFastAPP からParquet に接続し、一覧表示する方法を説明します。

完成イメージ

以下のようにFastAPPの一覧画面でParquetから取得したデータを表示するPluginを作成します。

FastAPP 用Plugin 作成

まず、FastAPP へ追加するPlugin プログラムを作成します

Eclipse を立ち上げ、FastAPP 用Plugin プログラムを記述します。

データ一覧を表示するためのサンプルコードは以下の通りです。必要に応じて取得・表示項目などを変更します。FastAPP 用Plugin の詳しい作成方法は、以下のHPから問い合わせにて確認できます。

https://www.scsk.jp/product/contact/index.html?sname=FastAPP



package jp.plugin.demo;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;

import jp.scsk.fastapp.core.addon.support.CommandProcessor;
import jp.scsk.fastapp.core.addon.support.CommandValues;
import jp.scsk.fastapp.core.addon.support.ValidationException;

public class ListUpDynamicsData implements CommandProcessor {

	private static final String[] ARGNAMES = {"プラグイン引数文字列サンプル"};

	@Override
	public String[] getArguments() {
		// TODO 自動生成されたメソッド・スタブ
		return ARGNAMES;
	}

	@Override
	public String getProcessName() {
		// TODO 自動生成されたメソッド・スタブ
		return "一覧取得Plugin";
	}

	@Override
	public String[] getTargetVersion() {
		// TODO 自動生成されたメソッド・スタブ
		return new String[] {"3.0.0","3.*.*"};
	}

	@Override
	public void process(CommandValues arg0) throws ValidationException {
		// TODO 自動生成されたメソッド・スタブ

		try {
			Class.forName("cdata.jdbc.parquet.ParquetDriver");

			Connection conn = DriverManager.getConnection("jdbc:parquet:URI=C:/folder/table.parquet;");

			java.sql.Statement stat = conn.createStatement();

			stat.execute("select id,name,telephone1,address1_city,websiteurl from Account");
			ResultSet rs = stat.getResultSet();

			while(rs.next())
			{
				arg0.setFormValue("DetailData1", "id", rs.getRow(),rs.getString("id"));
				arg0.setFormValue("DetailData1", "name", rs.getRow(),rs.getString("name"));
				arg0.setFormValue("DetailData1", "telephone1", rs.getRow(),rs.getString("telephone1"));
				arg0.setFormValue("DetailData1", "address1_city", rs.getRow(),rs.getString("address1_city"));
				arg0.setFormValue("DetailData1", "websiteurl", rs.getRow(),rs.getString("websiteurl"));
			}

		}catch(Exception ex)
		{
			// Error Handling
		}

	}
}

クラス名および接続文字列は以下を参考に記述します。
ドライバ：cdata.jdbc.parquet.ParquetDriver
URL: jdbc:parquet: に続けてセミコロン区切りで接続プロパティを入力します。
一般的なJDBC URL は次の通りです。
jdbc:parquet:URI=C:/folder/table.parquet;
プログラム記述後、ビルドを実行します。

Plugin の配置

続いて作成したPlugin アセンブリをFastAPPサーバー上に配置します。本記事ではLinux サーバへのSSH接続をベースに記述します

Teraterm 等任意のSSH接続用ツールを立ち上げて、FastAPP のサーバへ接続します
FastAPP を配置しているWebサイトのライブラリフォルダ「例：/opt/tomee/webapps/fastapp-web/WEB-INF/lib」にビルドファイルおよびCData Driver ファイル「cdata.jdbc.dynamicscrm.jar」とライセンスファイル「cdata.jdbc.dynamicscrm.lic」、以上3種類のファイルを配置します。
ファイルを配置後、FastAPP のWebサーバを再起動すると対象のPlugin がFastAPP 上で参照可能となります。