Ceylon でのRDB連携

今アプリを作るならDB連携は当然使いますよね？
ということで、今回はDBのアクセスしてみようと思います。

#DBアクセスモジュールの追加

いつものようにmodule.ceylonファイルに追記します。
今回追加するモジュールはこれ。

import ceylon.dbc "1.0.0";

#DBアクセスクラス

ceylon.dbcでは
Sqlクラスが用意されていて
DBにアクセスすることが出来ます！

しかし・・・
Sqlクラスのコンストラクタには
javax.sql.DataSourceの名前が・・・。

Java連携が必須のようです。。

#DB周りの設定

DBと合わせてjavaのDataSourceも必要なので
今回はこちらのDBを使おうと思います。
http://www.h2database.com/html/main.html
オンメモリなDBも使うことも出来て手軽に使えます。

ここでダウンロードしてきたzipを解凍して出てきたjarファイルを
前回 のようにjarファイルを登録します。

ceylon import-jar org/h2 h2-1.3.174.jar

そしてmodule.ceylonファイルにもモジュールを追記します。

import java.base "7";
import org.hsqldb.hsqldb "2.3.1";

これで準備OKです。
それではコードに行ってみましょう。

#コード

import ceylon.dbc { Sql }
import org.hsqldb.jdbc { JDBCPool }

void dbAccess() {
	value ds = JDBCPool();
	ds.url = "jdbc:hsqldb:mem:db";
	ds.user = "sa";
	ds.setPassword("sa");

	value sql = Sql(ds);
	sql.execute("create table messages (id integer, text varchar(20))");
	
	value count = sql.queryForInteger("SELECT count(*) FROM messages");
	print(count);
	
	sql.transaction(() { 
		sql.execute("insert into messages (id, text) values (?, ?)", 
		0, "hello world"); 
		sql.execute("insert into messages (id, text) values (?, ?)", 
		1, "goodbye world"); 
		return true; 
	}); 
	
	value count2 = sql.queryForInteger("SELECT count(*) FROM messages");
	print(count2);
	
	sql.eachRow { 
		sql = "select id, text from messages"; 
		void body(Map<String,Object> row) {
			print("{");
			for (key->item in row) {
				print("\t``key``: ``item``");
			}
			print("}");
		} 
	}; 
}

Sqlクラスを生成するためにDataSourceを生成します。
オンメモリでDBを立ち上げ、テーブルを作って
クエリ実行、インサートなどをしています。

見ただけで何となく分かりますよね。
トランザクションやパラメータ置き換えも良さげです。

Javaのデータソースが必須なのを除けば。。。
実際の業務ロジックでは
基盤部分のみが参照で隠蔽出来る部分かもしれないですけどね。

#まとめ

残念ながら現状ではJava連携必須。
しばらくしたらCeylonモジュールだけで動かせるようになるのかなぁ。