ITお絵かき修行

3歩歩いても忘れないために

Oracle Certified Expert, Java Platform, EE 6 Web Component Developerうかった

Oracle Certified Expert, Java Platform, EE 6 Web Component Developer(OCJ-WC)に合格した。
受験動機としては、生のサーブレットを触ったり、アプリケーションサーバにデプロイする資産構成をまとめたりする機会があり、体系的な知識を得るために勉強しておきたかった為。


【試験名】
Java EE 6 Web Component Developer Certified Expert Exam
Java EE 6 Web Component Developer Certified Expert | Oracle Certification Exam


【勉強方法】
JavaEE6の資格に対応した日本語の問題集がないので、英語の問題集をメインに使用し、その他書籍やWeb上の情報を使いながら勉強した。
問題集を1~2周する中で、都度JavaDocを確認したり、サンプルアプリを作ったりし、問題集の各単元ごとに出てくるコードや設定を確認する、という学習方法をとった。
また不安に感じた部分は検証し、ブログの記事として書いた。
http-method-omissionを試す - ITお絵かき修行
サーブレット3.0のセキュリティ系アノテーションを試す - ITお絵かき修行


【使用した教材 書籍】
1.『Ocejwcd Study Companion: Certified Expert Java Ee 6 Web Component Developer (Oracle Exam 1z0-899)』

Ocejwcd Study Companion: Certified Expert Java Ee 6 Web Component Developer (Oracle Exam 1z0-899)

Ocejwcd Study Companion: Certified Expert Java Ee 6 Web Component Developer (Oracle Exam 1z0-899)

■使用感
ゴツくて重い。確実に力がつく*1
全22章、666ページあるので1周するのが非常にしんどい。
ただこの1冊を理解できたらサーブレット3.0の仕様はマスターした、といっても過言ではないと思う。そのくらい仕様を細かく解説している。
問題の精度はそこそこ。若干細かすぎる感がある。レベル感は少し難しめ(と感じた)。
章ごとの構成は「解説+問題」というオーソドックスな構成。自分は問題のみ使用して、解説は都度読んだ。
誤植が少なからず存在するので、詰まったときは早めに回答を見たほうが精神衛生上良い。

■総評
後で紹介するSJC-WC用の紫本のほうがオススメ。ただし、万全を期したいのであれば買ったほうがいいかも。
自分はこの機会に英語の問題文に慣れる、という気持ち込みで買った。今となっては買ってよかったと思っている。


2.『SUN教科書 Webコンポーネントディベロッパ(SJC-WC) 試験番号:310-083』

SUN教科書 Webコンポーネントディベロッパ(SJC-WC) 試験番号:310-083

SUN教科書 Webコンポーネントディベロッパ(SJC-WC) 試験番号:310-083

■使用感
JavaGoldの紫本より少し薄く、少し重い。
内容自体はJavaEE5時代の試験に対応した内容だが、十分対応できる。
ただしサーブレット2.5と3.0とで仕様が変わってる部分がたくさんあるので、サーブレット3.0に関する情報は別途自分で集めなければならない。
本番の試験でも「ここ紫本でやったところだ…!」的な問題が少なからずあった。レベル感は本番の試験と似ている。(問題によっては若干易しいかも)

■総評
合格したいなら絶対に買うべき。書籍はこれ一冊でもいいかも。


3.『Beginning Java EE 6 GlassFish 3で始めるエンタープライズJava (Programmer’s SELECTION)』

Beginning Java EE 6 GlassFish 3で始めるエンタープライズJava (Programmer’s SELECTION)

Beginning Java EE 6 GlassFish 3で始めるエンタープライズJava (Programmer’s SELECTION)

■使用感
重い。詰まってる感がある。1.の問題集と同時に持ち運ぶのはかなり厳しい。

■総評
試験勉強ではほとんど使わなかった。ただしRESTful Webサービスに関する説明は参考になった。


【使用した教材 Web】
1.サーブレット仕様書、第 3.0 最終版
http://www.cresc.co.jp/tech/java/Servlet_Specifications/Servlet_Specification_3_0_Japanese.pdf

2.Java EE | TECHSCORE(テックスコア)
Java EE | TECHSCORE(テックスコア)

3.サーブレット3.0の新機能(1/5):CodeZine
サーブレット3.0の新機能 (1/5):CodeZine

4.Servlet 3.0 の新機能概要 | 寺田 佳央 - Yoshio Terada
Servlet 3.0 の新機能概要 | 寺田 佳央 - Yoshio Terada

1.2.は初めて勉強する際に一通り目を通した。
3.4.は都度確認する際に使用した。受験直前までお世話になった。


【試験の感想】
・JavaSEの試験のようにコードを追いかけていく試験ではなく、基本的に暗記モノの試験なので時間が足りないと感じることは無かった。
JSP、カスタムタグ、JSTL、EL式、デプロイメント記述子(web.xml)のタグ情報や組み合わせ、設定可能な属性を執拗に聞かれる。なので、その他の部分の割とわかりやすい部分(「Java サーブレットの概要」など)で点を落とさないようにするべき。
・合格ライン61%に対して、正解率71%だった。自分はセキュリティに関するアノテーションが苦手だった。

*1:B5サイズで厚みが3.9cmある。Amazonの配送情報によると1.2kgらしい・・・

RedmineのREST APIを使ってチケット登録・参照

RedmineにはRESTのAPIが用意されており、HTTPボディ部にJSON or xml形式のデータを指定してリクエストを送信することで、チケットに対するCRUD操作ができる。
今回はRedmine公式が配布している「Redmine Java API library」*1というライブラリを使ってチケット登録してみた。


【すること】
RedmineREST APIを使ってチケット登録・参照
→登録は1件単位で、参照は1件単位およびプロジェクトに含まれる全てのチケット情報単位で実行できるようにする。

【環境】
●OS
Windows7 64bit

Redmine
- Redmine 2.6.2
- Apache 2.4.12
- MySQL 5.5.42
- Ruby 2.0.0-p594-i386-mingw32
- Rails 4.2.0
- RubyGems 1.8.12
Redmine Cloud Hosting, Redmine Hosting - Installers and VM
※インストールが面倒だったので上記のオールインワンパッケージを入れた。
ソースコード管理は別立てのGitで行うので入れなかった。

Redmine操作用ライブラリ
Redmine Java API library 2.1.0
taskadapter/redmine-java-api · GitHub

Java
jdk1.8.0_25


Redmine Java API libraryのコンパイルに必要なライブラリ】
ソースをGithubから取得するため、依存関係にあるライブラリは別途取得する必要がある。
Gradleのビルドスクリプトが同梱されているので、実行することで実行資産を作成可能(のはず)。
# Gradleの使い方がわからなかったので、スクリプトを読んでググって人力で集めたorz

1.HttpClient
httpclient-4.4.jar
httpcore-4.4.jar

2.CommonsCodec
commons-codec-1.10.jar

3.fest ※テスティングフレームワーク
fest-assert-1.4.jar

4.SLF4J
slf4j-api-1.6.6.jar
slf4j-log4j12-1.6.6.jar

5.Log4J
log4j-1.2.17.jar

6.org-json-java ※jsonパーサ
org.json-20120521.jar


【事前準備】
1.Redmine側で、管理 → 設定 → 認証 の順で設定ページを表示した後、
[REST による Web サービスを有効にする] にチェックを入れる必要がある。
2.自分のユーザのアクセスキー(APIキー)を確認する。
⇒ 個人設定 ページの右側(デフォルトテーマの場合)に表示されている。


【処理】
1.TicketClient クラス
⇒チケット発行&取得する。
⇒チケット発行においては「題名」が重複する場合はチケットを発行しない仕様としている。発行が目的なので・・・

package sample.redmine;

import java.util.List;
import java.util.Optional;

import com.taskadapter.redmineapi.IssueManager;
import com.taskadapter.redmineapi.RedmineException;
import com.taskadapter.redmineapi.RedmineManager;
import com.taskadapter.redmineapi.RedmineManagerFactory;
import com.taskadapter.redmineapi.bean.Issue;
import com.taskadapter.redmineapi.bean.IssueFactory;
import com.taskadapter.redmineapi.bean.Project;
import com.taskadapter.redmineapi.bean.ProjectFactory;
import com.taskadapter.redmineapi.bean.Tracker;
import com.taskadapter.redmineapi.bean.TrackerFactory;
import com.taskadapter.redmineapi.bean.User;

public class TicketClient {

	private static final String BUG = "バグ";
	private static final String FUNCTION = "機能";
	private static final String SUPPORT = "サポート";

	private RedmineManager redmineMgr = null;
	private IssueManager issueMgr = null;
	private List<User> userList = null;

	private boolean flg = false;

	public void setup(String url, String apiAccessKey) throws Throwable {
		System.out.println("【接続先】" + url);
		redmineMgr = RedmineManagerFactory.createWithApiKey(url, apiAccessKey);
		issueMgr = redmineMgr.getIssueManager();
		userList = redmineMgr.getUserManager().getUsers();
		flg = true;
	}

	private void flgChk() {
		if (!flg) {
			System.err.println("TicketClient#setup(String, String)を先に実行してください。");
			System.exit(1);
		}
	}

	public void putIssue(String projectKey, String trackerName, String subject,
			String description) throws RedmineException {
		flgChk();
		System.out.println("■■■チケットを1件登録します。■■■");
		// チケット名重複チェック
		if(chkSubject(projectKey, subject)){
			System.out.println("題名が重複する場合、チケットは発行しません。題名 :" + subject);
		}else {
			
			// Issue(1チケット)生成
			Issue issue = IssueFactory.create(null);
			// プロジェクト
			setProjectInfo(issue, projectKey);
			
			// 題名
			issue.setSubject(subject);
			// 説明
			issue.setDescription(description);
			// トラッカー
			setTrackerInfo(issue, trackerName);

			// 1チケット登録
			Issue newIssue = issueMgr.createIssue(issue);
			issueMgr.update(newIssue);
			System.out.println("チケットを登録しました。題名 :" + subject);
		}

	}

	private void setProjectInfo(Issue issue, String projectKey) throws RedmineException {
		int intProjectKey = redmineMgr.getProjectManager().getProjectByKey(projectKey).getId();
		Project project = ProjectFactory.create(intProjectKey);
		issue.setProject(project);		
	}

	private void setTrackerInfo(Issue issue, String trackerName) {
		int trackerId = getTrackerId(trackerName);
		Tracker tracker = TrackerFactory.create(trackerId, null); // 第二引数はなくてもよい
		issue.setTracker(tracker);		
	}

	private boolean chkSubject(String projectKey, String subject) throws RedmineException {
		
		List<Issue> issues = issueMgr.getIssues(projectKey, null); // 第二引数はなくてもよい?
		boolean contains = issues.stream().anyMatch(a -> {
			if(subject.equals(a.getSubject())){
				return true;
			}
			return false;
		});
		return contains;
	}

	private int getTrackerId(String trackerName) {
		switch (trackerName) {
		case BUG:
			return 1;
		case FUNCTION:
			return 2;
		case SUPPORT:
			return 3;
		default:
			return 1;
		}
	}

	public List<Issue> getAllIssues(String projectKey) throws RedmineException {
		flgChk();

		System.out.println("■■■チケットを全件取得します。■■■");
		List<Issue> issues = issueMgr.getIssues(projectKey, null); // 第二引数はなくてもよい?
		
		System.out.println("チケットの件数 : " + issues.size());
		issues.stream().forEach(is -> {
			System.out.println("【題名】" + is.getSubject());
		});
		return issues;
	}
	
	public Issue getOneIssue(String projectKey, String subject) throws RedmineException {
		flgChk();
		System.out.println("■■■チケットを1件取得します。■■■");
		List<Issue> issues = issueMgr.getIssues(projectKey, null); // 第二引数はなくてもよい?

		// チケットの探索(無かったらnull)
		Optional<Issue> is = issues.stream().filter(i ->(i.getSubject().equals(subject))).findAny();
		if(is.isPresent()){
			System.out.println("【題名】" + is.get().getSubject());
			return is.get();		
		}
		System.out.println("チケットは取得できませんでした。" );
		return null;	 
	}
}


2.TicketClientTest クラス
⇒TicketClientクラスの各操作メソッドを実行する。

package sample.redmine;

import java.util.List;

import com.taskadapter.redmineapi.RedmineException;
import com.taskadapter.redmineapi.bean.Issue;

public class TicketClientTest {

	/**
	 * mainメソッド
	 * 
	 * @param args
	 */
	public static void main(String[] args) {

		TicketClient client = new TicketClient();
		try {
			client.setup("(RedmineのトップページURL)", "(アクセスキー)");

			// 全件取得
			List<Issue> allIssues = client.getAllIssues("(プロジェクトの識別名)");
			// 1件登録
			client.putIssue("(プロジェクトの識別名)", "バグ", "題名題名題名題名題名題名", "説明説明説明説明説明説明説明説明説明説明");
			// 1件取得
			Issue issue = client.getOneIssue("(プロジェクトの識別名)", "題名題名題名題名題名題名");

		} catch (RedmineException e) {
			e.printStackTrace();
		} catch (Throwable th) {
			th.printStackTrace();
		}
	}
}


【実行結果】
●実行前
f:id:hhhhhskw:20150411180844p:plain
※実行前に「前もってきっておいたチケット」というチケットを作成済。

●実行後
f:id:hhhhhskw:20150411180851p:plain


【実行ログ ※標準出力】

【接続先】(RedmineのトップページURL)
■■■チケットを全件取得します。■■■
チケットの件数 : 1
【題名】前もってきっておいたチケット
■■■チケットを1件登録します。■■■
チケットを登録しました。題名 :題名題名題名題名題名題名
■■■チケットを1件取得します。■■■
【題名】題名題名題名題名題名題名


【感想】
Redmine Java API libraryはJSON or XMLデータの取り回しやHttp通信時の例外処理を隠蔽し、1チケット分の情報を取り回すBeanと操作メソッドを用意しているため、かゆいところにだいたい手が届くライブラリだった。
⇒カスタムフィールドの操作も簡単だった。履歴情報が操作できるかは要検証。
 ※JSON or XMLデータをいじって実装していたときは、名前空間やタグに関するドキュメントが少なくよく迷ったので、かなり楽になった。
・チケットを削除する場合はIssueManager#deleteIssueを実行する。
・今回作ったクラスでは、操作側にRedmine Java API libraryのクラスが見えてるので、見えないようにする必要がある。


【参考文献】
Rest api - Redmine
Rest api with java - Redmine
いぬこいのこや Redmineのチケット登録をRedmine REST APIを使ってやってみる
RedmineのREST APIを使ってみる | 世界はどこまでもシンプルである
Redmine(オールインワンパッケージ)のWindowsへの導入メモ - Qiita


Gradle徹底入門 次世代ビルドツールによる自動化基盤の構築

Gradle徹底入門 次世代ビルドツールによる自動化基盤の構築

*1:Apache License 2.0らしい。

StreamAPIのおさらい - java.util.stream.Collector

JavaSE8で導入されたStreamAPIを使用してできる処理のうち、java.util.stream.Collectorクラスの機能を利用してできる処理を書いてみた。

【やること】
java.util.stream.Collector系クラスのメソッドを使ってできる処理をさらう。
Java Collectorメモ(Hishidama's Java8 Collector Memo) で紹介されているメソッドを全部書いてみる。
・分類分けに関しては蒐集してやんよ java.util.stream.Collectors クラス (1) - Map 以外を返す Collector - - 倭マン's BLOG を参考にさせていただいた。


【環境】
Java
・jdk1.8.0_25
IDE
Eclipse Luna SR1 (4.4.1)


【資産】
具体的な使い方はソースを参照。

1.汎用的なCollector

(1)Collectors#mapping・・・値の変換
(2)Collectors#reducing・・・値の集約
StreamSample/GeneralCollector.java at master · hhhhhskw/StreamSample · GitHub

2.文字列に関するCollector

(1)Collectors#joining・・・文字列の結合
StreamSample/StringCollector.java at master · hhhhhskw/StreamSample · GitHub

3.StreamからCollectionへ変換するCollector

(1)Collectors#toCollection・・・Collectionクラスへ変換
(2)Collection#toList・・・Listクラスへ変換
(3)Collection#toSet・・・Setクラスへ変換
StreamSample/StreamToCollectionCollector.java at master · hhhhhskw/StreamSample · GitHub

4.StreamからMapへ変換するCollectior

(1)Collections#toMap・・・Mapクラスへ変換
(2)Collection#toConcurrentHashMap・・・ConcurrentHashMapへ変換
StreamSample/StreamToMapCollector.java at master · hhhhhskw/StreamSample · GitHub

5.Streamの統計に関するCollector

(1)Collectors#counting・・・Streamの要素数
(2)Collection#min・・・Stream内の最小値
(3)Collectors#max・・・Stream内の最大値
(4)Collectors#summingInt・・・Stream(int)の総和
(5)Collectors#summingLong・・・Stream(long)の総和
(6)Collectors#summingDouble・・・Stream(double)の総和
(7)Collectors#averagingInt・・・Stream(int)の平均
(8)Collectors#averagingLong・・・Stream(long)の平均
(9)Collectors#averagingDouble・・・Stream(double)の平均
(10)Collectors#summarizingInt・・・Stream(int)の統計情報
(11)Collectors#summarizingLong・・・Stream(long)の統計情報
(12)Collectors#summarizingDouble・・・Stream(double)の統計情報
StreamSample/SummaryCollector.java at master · hhhhhskw/StreamSample · GitHub

6.Streamに対して条件判定を適用するCollector

(1)Collectors#partitioningBy・・・指定した条件判定を適用する
(2)Collectors#partitioningByRule・・・指定した条件判定を適用する(返却する値の形式は別に指定する)
StreamSample/PartitioningCollector.java at master · hhhhhskw/StreamSample · GitHub

7.Streamに対してグループ分け

(1)Collectors#groupingBy()・・・グルーピング
(2)Collectors#groupingByConcurrent()・・・グルーピング(戻り値がConcurrentHashMap)
StreamSample/GroupingCollector.java at master · hhhhhskw/StreamSample · GitHub


全てをまとめたクラスは以下
StreamSample/CollectorSample.java at master · hhhhhskw/StreamSample · GitHub


【感想】
・数値系の操作はsummarizingInt等で大体こと足りそう。
→StreamAPI側の実装で詳しく書きすぎると可読性が落ちるので、機能が足りないときは別メソッドに委譲するべき?オレオレCollectorで対応する?
・CollectionsクラスのJavaDoc無いと実装できない・・・
ラムダ式内での型変換で何回かハマった。
ラムダ式で使用する関数インタフェースクラス(Predicateクラス、Functionクラス等)のメソッド仕様を理解してないとハマる。


【参考文献・URL】
Collectors (Java Platform SE 8 )
Collector (Java Platform SE 8 )
Java Collectorメモ(Hishidama's Java8 Collector Memo)
蒐集してやんよ java.util.stream.Collectors クラス (1) - Map 以外を返す Collector - - 倭マン's BLOG

Javaによる関数型プログラミング ―Java 8ラムダ式とStream

Javaによる関数型プログラミング ―Java 8ラムダ式とStream

StreamAPIのおさらい - java.util.stream.Stream

JavaSE8で導入されたStreamAPIを使用してできる処理のうち、java.util.stream.Streamクラスの機能を利用してできる処理を書いてみた。

【やること】
java.util.stream.Stream系クラスのメソッドを使ってできる処理をさらう。
Java Streamメモ(Hishidama's Java8 Stream Memo) で紹介されているメソッド+αを書いてみる。


【環境】
Java
・jdk1.8.0_25
IDE
Eclipse Luna SR1 (4.4.1)


【資産】
具体的な使い方はソースを参照。

1.Stream内の単一の値に対する順次処理

(1)Stream#map・・・Streamの要素を取り出して変換を行う
(2)Stream#mapToDouble・・・Streamの要素を取り出してdoubleへの変換を行う
(3)Stream#mapToInt・・・Streamの要素を取り出してintへの変換を行う
(4)Stream#mapToLong・・・Streamの要素を取り出してlongへの変換を行う
(5)Stream#floatMap・・・Streamの要素を取り出してStreamへの変換を行う
(6)Stream#flatMapToDouble・・・Streamの要素を取り出してDoubleStreamへの変換を行う
(7)Stream#flatMapToInt・・・Streamの要素を取り出してIntStreamへの変換を行う
(8)Stream#flatMapToLong・・・Streamの要素を取り出してLongStreamへの変換を行う
(9)Stream#forEach・・・Stream内各要素に対して処理を適用する(※処理順の指定なし)
(10)Stream#forEachOrdered・・・Stream内各要素に対して処理を適用する(※処理順の指定あり)
StreamSample/OperateSingleElementStreams.java at master · hhhhhskw/StreamSample · GitHub

2.Streamの内の複数の値に対する順次処理

(1)Stream#reduce・・・Stream内の複数の要素を取り出して処理を行い、単一の結果(戻り値は入力値による)として出力する
(2)Stream#collect・・・Stream内の複数の要素を取り出して処理を行い、コレクション(CollectionやStringBuilderなど)として出力する
(3)Stream#concat・・・Stream同士の連結を行う
StreamSample/OpetrateMultiElementStreams.java at master · hhhhhskw/StreamSample · GitHub

3.Stream内の値に対するソート処理

(1)Stream#sort・・・Streamに含まれる値をソートする
StreamSample/SortStreams.java at master · hhhhhskw/StreamSample · GitHub

4.Stream内の値に対するフィルタリング処理

(1)Stream#filter・・・Streamに含まれる値のフィルタリング
(2)Stream#min・・・Streamに含まれる値のうち、最小値を返却する
(3)Stream#max・・・Streamに含まれる値のうち、最大値を返却する
(4)Stream#count・・・Streamに含まれる要素の数を返却する
(5)Stream#anyMatch・・・Streamに含まれる要素に対して、条件検索(条件に1要素でも合致すればtrue)を行う
(6)Stream#allMatch・・・Streamに含まれる要素に対して、条件検索(条件に完全に一致する場合はtrue)を行う
(7)Stream#noneMatch・・・Streamに含まれる要素に対して、条件検索(条件一致する値がなけれはtrue)を行う
(8)Stream#findFirst・・・Streamに含まれる要素の先頭の値を返却する
(9)Stream#findAny・・・Streamに含まれる要素のいずれかの値を返却する(※並列処理用)
(10)Stream#distinct・・・Streamに含まれる値の重複を排除する
StreamSample/FilteringStreams.java at master · hhhhhskw/StreamSample · GitHub

5.Streamに対する各種操作

(1)Stream#limit・・・Streamに含まれる値の個数を制限(limit)し、Streamを返却する
(2)Stream#skip・・・Streamに含まれる値の開始位置を変更(skip)し、Streamを返却する
StreamSample/OperateStreams.java at master · hhhhhskw/StreamSample · GitHub

6.Streamを生成する

(1)Stream#of・・・指定された値を含むStreamを返却する。
(2)Stream#empty・・・空のStreamを返却する
(3)Stream#generate・・・第一引数で渡された要素を含むStreamを返却する
(4)Stream#iterate・・・第一引数で渡された初期要素に対し、第二引数で指定されたを関数を適用した要素の集合を含むStreamを返却する
StreamSample/CreateStreams.java at master · hhhhhskw/StreamSample · GitHub

7.Streamの形式変更操作

(1)Stream#toArray・・・Straemを配列に変換する ※終端操作
(2)Stream#builder・・・Streamのbuilderを取得する
StreamSample/ChangeTypeStream.java at master · hhhhhskw/StreamSample · GitHub

jBatch(Batchlet & Chunk)+JPA2.1(Entity & JPQL)でデータ読み書き

JavaEE7で追加されたjBatch(JSR-352)とJPA2.1(JSR-338)を使用して、DBのデータを読み書きする。

【やること】
・jBatchのBatchlet方式とChunk方式を両方使ってバッチジョブを実行する。
JPAのうち、SELECTはJPQL、INSERT,UPDATE,DELETEはEntity方式を使用してデータの読み書きをする。
処理概要は下図の通り。
f:id:hhhhhskw:20150128203403p:plain


【環境】
Java
 ・jdk1.8.0_25
 ・Oracle Enterprise Pack for Eclipse (12.1.3.3.1) ※中身はLuna SR1 (4.4.1)
 ・GlassFish Server Open Source Edition 4.1
JPA
 ・Eclipselink 2.5.2-RC1 ※GlassFish組み込み
●DB・JDBC
 ・PostgreSQL 9.0
 ・JDBC41 Postgresql Driver, Version 9.3-1102
ツール
 ・pgAdminⅢ


【準備】
JDBCGlassfishのクラスパスが通る場所(libフォルダ)に置いた。
・srcフォルダ配下にMETA-INFフォルダを作り、その中に「batch-jobs」フォルダを作った。
GlassfishにてJNDIデータソースを設定済。
 [参考]GlassfishでJNDIデータソースの設定方法その1 - しんさんの出張所 はてな編
・データ読み書き用のテーブルを作成済。

CREATE TABLE employees
(
  empno integer NOT NULL,
  ename character varying(10),
  yomi character varying(20),
  job character varying(8),
  mgr integer,
  hiredate date,
  sal character varying(7),
  comm character varying(7),
  deptno integer,
  CONSTRAINT pk_emp PRIMARY KEY (empno)
)
WITH (
  OIDS=FALSE
);



【資産 - 定義体
1.emp-batch.xml
・バッチジョブの実行順序を記述

2.persistence.xml
JPA定義+DB接続先情報
・"eclipselink.logging.level.sql"を"FINE"とすると生成されたSQLが見える


【資産 - ソースファイル】
1.InsertEmpInfoBatchlet.java
・データ入力役
・従業員番号2001番・太郎くんの情報をINSERTする。 ※入力データはハードコーディングした。

2.EmpInfoReader.java
・データ読み込み役
・従業員番号2001番・太郎くんの情報をSELECTする。
・1件取得する場合はTypedQuery#getSingleResultを使用する。

3.EmpInfoProcessor.java
・データ加工役
・SELECTしたデータに数値を設定する。入力データに意味はない

4.EmpInfoWriter.java
・データ書き込み役
・EmpInfoProcessorで加工したデータを適用し、UPDATEする。

5.DeleteEmpInfoBatchlet.java
・データ消去役
・従業員番号2001番・太郎くんの情報をDELETEする。

6.BatchServlet.java
・バッチジョブを実行する。


作成したプロジェクトのトップページは以下。
hhhhhskw/EmpInfoBatch · GitHub


【実行ログ】

2015-02-11T15:07:09.847+0900|情報: EmpInfoBatch was successfully deployed in 5,035 milliseconds.
2015-02-11T15:07:26.098+0900|情報: id = 50
2015-02-11T15:07:26.271+0900|情報: InsertEmpInfoBatchlet#process
2015-02-11T15:07:26.393+0900|普通: INSERT INTO employee (empno, comm, deptno, ename, hiredate, job, mgr, sal, yomi) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)
	bind => [9 parameters bound]
2015-02-11T15:07:26.493+0900|情報: JTS5014: Recoverable JTS instance, serverId = [100]
2015-02-11T15:07:26.572+0900|情報: EmpInfoReader#open
2015-02-11T15:07:26.574+0900|情報: EmpInfoWriter#open
2015-02-11T15:07:26.578+0900|情報: EmpInfoReader#readItem
2015-02-11T15:07:26.770+0900|情報: EmpInfoProcessor#processItem
2015-02-11T15:07:26.772+0900|情報: EmpInfoWriter#writeItems
2015-02-11T15:07:26.772+0900|情報: persistEmployee
2015-02-11T15:07:26.772+0900|情報: EmpInfoReader#checkpointInfo
2015-02-11T15:07:26.783+0900|情報: EmpInfoWriter#checkpointInfo
2015-02-11T15:07:26.791+0900|普通: UPDATE employee SET comm = ? WHERE (empno = ?)
	bind => [2 parameters bound]
2015-02-11T15:07:26.823+0900|情報: EmpInfoReader#readItem
2015-02-11T15:07:26.824+0900|情報: EmpInfoReader#checkpointInfo
2015-02-11T15:07:26.835+0900|情報: EmpInfoWriter#checkpointInfo
2015-02-11T15:07:26.842+0900|情報: EmpInfoReader#close
2015-02-11T15:07:26.843+0900|情報: EmpInfoWriter#close
2015-02-11T15:07:26.886+0900|情報: DeleteEmpInfoBatchlet#process#begin
2015-02-11T15:07:26.906+0900|普通: UPDATE employee SET comm = ?, deptno = ?, ename = ?, hiredate = ?, job = ?, mgr = ?, sal = ?, yomi = ? WHERE (empno = ?)
	bind => [9 parameters bound]
2015-02-11T15:07:26.926+0900|普通: DELETE FROM employee WHERE (empno = ?)
	bind => [1 parameter bound]
2015-02-11T15:07:26.926+0900|情報: DeleteEmpInfoBatchlet#process#commit




【つまったところなど】
バッチ処理で無限ループした時はItemReaderの実装をまず疑う。
→readItemメソッドの戻り値にnullが設定されるコードになってるか、チェックポイントをカウントする実装はおかしくないかetc
・JPQL使用時のコードでPSQLExceptionが発生する場合は、9割方文法が間違っている(体感)。
→SELECT句のカラム名に「*」を設定していないか、FROM句にEntityクラス名を指定しているかetc
EclipseからGlassfishへ資産をデプロイできない場合は、EclipseからGlassfishサーバーを一旦削除して、Glassfishサーバーを再度作成する。もしくはドメインフォルダ配下に生成された一時フォルダ・ファイルを削除する。
・それでもデプロイできないときは、Eclipseと端末の再起動
Glassfish起動時にポート1527が開いていません的例外が出たら、JDK付属のJavaDBを起動したうえで、Glassfishを起動する。

[2015-01-27T23:52:11.436+0900] [glassfish 4.1] [WARNING] [poolmgr.create_resource_error] [javax.enterprise.resource.resourceadapter.com.sun.enterprise.resource.allocator] [tid: _ThreadID=47 _ThreadName=admin-listener(5)] [timeMillis: 1422370331436] [levelValue: 900] [[
  RAR5038:Unexpected exception while creating resource for pool DerbyPool. Exception : javax.resource.spi.ResourceAllocationException: Connection could not be allocated because: java.net.ConnectException: ポート1527のサーバーlocalhostへの接続中にメッセージConnection refused: connectでエラーが発生しました。]]



【参考文献・URL】
The Java EE 7 TutorialのjBatchの章をテキトーに訳した - kagamihogeの日記
jBatchでデータロードしてみる - kagamihogeの日記
jbatch (JSR352) - Chunk方式のStepを使ってみる - @lbtc_xxx lab
Java EE6を使う
GitHubに間違ってあげてしまった過去のコミットを削除してみる|めっとぼ

Beginning Java EE 6 GlassFish 3で始めるエンタープライズJava (Programmer’s SELECTION)

Beginning Java EE 6 GlassFish 3で始めるエンタープライズJava (Programmer’s SELECTION)


aptを使ったアノテーション処理

apt(Annotation Processing Tools)を使用してソースコード内のアノテーションを読み込む。
JSR-175に準拠したcom.sun.*パッケージのMirrorAPIではなく、JSR-269に準拠したaptを使用する。

JEP-117にて、aptが内部で使用するクラスが、JavaSE6より追加されたjavax.annotation.processingもしくはjarax.lang.modelパッケージに含まれるクラスになった。
※MirrorAPIを使用したaptはJavaSE8より削除対象となった。

「参考」
JEP 117: Remove the Annotation-Processing Tool (apt)
Oracle Blogs 日本語のまとめ: [Java] Java 8's new Type Annotations


javax.annotation.processing インタフェース Processor

Java Platform SE 6

ツールは、「検出処理」を使って注釈プロセッサを見つけ出し、それらを実行すべきかどうかを決定します。ツールを構成することで、可能性のあるプロセッサのセットを制御できます。たとえば、JavaCompiler の場合、実行候補プロセッサのリストは、直接設定 することも、サービススタイル の検索で使用される検索パス を使って制御することもできます。

実際に注釈プロセッサを作ってみた。
javac呼び出し時に、作成した注釈プロセッサを指定し実行する。
実装自体はアノテーションが設定可能な場所に設定されているアノテーション名を出力するだけ。

【実行環境】
jdk1.7.0_60

【実装】

package annotation;


import java.util.Set;

import javax.annotation.processing.AbstractProcessor;
import javax.annotation.processing.RoundEnvironment;
import javax.annotation.processing.SupportedAnnotationTypes;
import javax.annotation.processing.SupportedSourceVersion;
import javax.lang.model.SourceVersion;
import javax.lang.model.element.TypeElement;

@SupportedSourceVersion(SourceVersion.RELEASE_7) // Javaのバージョン
@SupportedAnnotationTypes({ "*" }) // 抽出対象とするアノテーションクラスの指定
public class SampleProcessor extends AbstractProcessor{

	@Override
	public boolean process(Set<? extends TypeElement> annotations, RoundEnvironment roundEnv) {
        for( TypeElement element : annotations ) { // TypeElementクラスがアノテーションの要素にあたる
            System.out.println( element.toString() );
        }
        return true;
	}
}


【実行コマンド】

javac -cp (クラスパス) -proc:only -processor (プロセッサのクラス名(完全修飾)) (javaファイル)

D:\workspace\workspace_annotation_20141120\ProcessorProject>set CP=./bin

D:\workspace\workspace_annotation_20141120\ProcessorProject>javac -cp %CP% -proc:only -processor processor.SampleProcessor src\annotation\SampleAnnotated.java
Sample

D:\workspace\workspace_annotation_20141120\ProcessorProject>tree /f

D:.
│
├─bin
│  ├─annotation
│  │      Sample.class
│  │      SampleAnnotated.class
│  │
│  └─processor
│          SampleProcessor.class
│
└─src
    ├─annotation
    │      Sample.java
    │      SampleAnnotated.java
    │
    └─processor
            SampleProcessor.java

D:\workspace\workspace_annotation_20141120\ProcessorProject>

今度は取得するアノテーションの種類、取得対象のソースファイルの指定など、入出力の
仕様を柔軟にしてみる。


【参考】
JDK 6 Java Compiler (javac)-related APIs & Developer Guides
javac - Java programming language compiler
Java SE 6 and JWSDP 2.0:6


「追記 2015/01/09」
Java8でも上記プログラムは正常に動作した。
※ただし@SupportedSourceVersionで指定するバージョンは「8」へ変更した。
ゆえにapt自体はJavaSE8であっても動作する。

サーブレット3.0のセキュリティ系アノテーションを試す

色々試してみたのでまとめる。試したのは以下のアノテーション

@ServletSecurity
@HttpConstraint
@HttpMethodConstraint


【検証環境】
Tomcat7.0.56

【パターン1】特定ロールのユーザのみアクセスを許す場合

※ロール「admin-role」にアクセス許可を与える


1.適当なサーブレットクラスに以下のアノテーションを設定

@ServletSecurity(value=@HttpConstraint(rolesAllowed={"admin-role"}))
@WebServlet(name="hogehoge", urlPatterns="/hogehoge")
public class TestServlet extends HttpServlet {
  ・・・(中略)・・・
}


2.コンテナ側で認証の設定
「設定内容」
・全てのURLにBASIC認証を適用する。
・ユーザ「admin」と「sub」を用意。

・web.xml

<security-constraint>
  <web-resource-collection>
    <web-resource-name>admin page</web-resource-name>
    <url-pattern>/*</url-pattern>
  </web-resource-collection>

  <auth-constraint>
    <role-name>admin-role</role-name>
  </auth-constraint>
    <auth-constraint>
    <role-name>sub-role</role-name>
  </auth-constraint>

  <user-data-constraint>
    <transport-guarantee>NONE</transport-guarantee>
  </user-data-constraint>
</security-constraint>

<security-role>
  <role-name>admin-role</role-name>
</security-role>
<security-role>
  <role-name>sub-role</role-name>
</security-role>

<login-config>
  <auth-method>BASIC</auth-method>
  <realm-name>admin page</realm-name>
</login-config>



tomcat-user.xml ※ルートタグ配下

  <role rolename="admin-role"/>
  <role rolename="sub-role"/>

  <user username="admin" password="password" roles="admin-role"/>
  <user username="sub" password="password" roles="sub-role"/>


3.デプロイ&起動後、ブラウザで「http://localhost:8080/TestServlet/hogehoge」へアクセス。
  結果は以下の通り。
●ユーザ「admin」でアクセス : アクセス可能 (HTTPステータスコード:200)
●ユーザ「sub」でアクセス  : アクセス拒否 (HTTPステータスコード:403)


【パターン2】特定メソッドは認証処理なし、その他のメソッドを使ったアクセスは特定ロールのユーザのみ可能

※GETメソッドは認証処理なし、その他のメソッドを使ったアクセスはロール「admin-role」に属するユーザのみ可能、とする。


1.適当なサーブレットクラスに以下のアノテーションを設定

@ServletSecurity(value=@HttpConstraint(rolesAllowed={"admin-role"}), httpMethodConstraints = {@HttpMethodConstraint("GET")})
@WebServlet(name="hogehoge", urlPatterns="/hogehoge")
public class TestServlet extends HttpServlet {
  ・・・(中略)・・・
}


2.コンテナ側の設定はパターン1の時と同じ

3.デプロイ&起動後、ブラウザで「http://localhost:8080/TestServlet/hogehoge」へアクセス。
  結果は以下の通り。

「結果」
●アクセス可能 (HTTPステータスコード:200) ※ユーザ認証なし


4.認証処理の対象をPOSTメソッドへ変更する。

@ServletSecurity(value=@HttpConstraint(rolesAllowed={"admin-role"}), httpMethodConstraints = {@HttpMethodConstraint("POST")})
@WebServlet(name="hogehoge", urlPatterns="/hogehoge")
public class TestServlet extends HttpServlet {
  ・・・(中略)・・・
}


5.デプロイ&起動後、ブラウザで「http://localhost:8080/TestServlet/hogehoge」へアクセス。
  結果は以下の通り。

「結果」
●ユーザ「admin」でアクセス : アクセス可能 (HTTPステータスコード:200)
●ユーザ「sub」でアクセス  : アクセス拒否 (HTTPステータスコード:403)


【パターン3】特定メソッドは認証処理なし、その他のメソッドを使ったアクセスは特定ロールのユーザのみ可能。ただし特定メソッドはアクセス不可とする
※POSTメソッドは認証処理なし、その他のメソッドを使ったアクセスはロール「admin-role」に属するユーザのみ可能、ただしHEADメソッドはアクセス不可となる。

1.適当なサーブレットクラスに以下のアノテーションを設定

@ServletSecurity(value=@HttpConstraint(rolesAllowed={"admin-role"}),
httpMethodConstraints = {@HttpMethodConstraint("POST"), @HttpMethodConstraint(emptyRoleSemantic
 = javax.servlet.annotation.ServletSecurity.EmptyRoleSemantic.DENY, value = "HEAD")})
@WebServlet(name="hogehoge", urlPatterns="/hogehoge")
public class TestServlet extends HttpServlet {
  ・・・(中略)・・・
}


2.コンテナ側の設定はパターン1の時と同じ

3.デプロイ&起動後、「http://localhost:8080/TestServlet/hogehoge」へアクセス。
  結果は以下の通り。

「結果」
●[HEAD]アクセス拒否 (HTTPステータスコード:503 ※エラーメッセージ:Duplicate method name: HEAD)
●[POST]アクセス可能 (HTTPステータスコード:200)※ユーザ認証なし
●[GET・ロール:admin]アクセス可能 (HTTPステータスコード:200)※ユーザ認証あり(認証失敗すると401)
●[GET・ロール:sub] アクセス拒否 (HTTPステータスコード:403)※ユーザ認証あり(認証失敗すると401)


[備考]ちなみに「@HttpMethodConstraint」におけるアクセス許可の設定については、
   「javax.servlet.annotation.ServletSecurity.EmptyRoleSemantic」の設定が優先される。
   よって、下記の設定においてGETメソッドはアクセス拒否となる。

@ServletSecurity(value=@HttpConstraint(rolesAllowed={"admin-role"}),
httpMethodConstraints = {@HttpMethodConstraint("GET"), @HttpMethodConstraint(emptyRoleSemantic
 = javax.servlet.annotation.ServletSecurity.EmptyRoleSemantic.DENY, value = "GET")})
@WebServlet(name="hogehoge", urlPatterns="/hogehoge")
public class TestServlet extends HttpServlet {
  ・・・(中略)・・・
}


サーブレット&JSPエッセンシャル逆引き大全500の極意

サーブレット&JSPエッセンシャル逆引き大全500の極意