H2 Database Engineに関する技術・製品の概要

JavaプログラムからH2 を組み込み(Embedded)モードで使用するため
「jdbc:h2:[file:][<path>]<databaseName>」形式の接続文字列を生成しています。
GroupSessionでは接続文字列と設定ファイル(dataSource.xml、connectOption.properties)を元にデータソースを生成しています。
※詳細はGroupSession Version3のソースを参照ください。

JavaプログラムからH2を組み込みモードで使用する例

//データベースコネクションを取得するサンプルクラス
public static void main(String[] args) throws Exception {
	Class.forName("org.h2.Driver");
	Connection conn = DriverManager.
		getConnection(
		    "jdbc:h2:file:C:\GS2DATA\db\gs2db\gs2db;",
		    "username",
		    "password");
	//
	// プログラムコード
	//
}
    

GroupSessionでのコーディング(DataSource使用)

//データベースコネクションを取得するサンプルクラス
public static void main(String[] args) {
/** データソース */
    private static DataSource ds__ = null;

    GSH2Util dbUtil = new GSH2Util();
    String dbPath = "C:\GS2DATA\db\gs2db";

    DataSourceModel dsModel = new DataSourceModel();
    dsModel.setUrl(dbUtil.createUrl(dbPath));
    //セッター部分省略---------------//

    DataSource ds__ = createDataSource(dsModel);
    Connection con = ds.getConnection();
}
    

    /** ロギングクラス */
    private static Log log__ = LogFactory.getLog(GSH2Util.class);
    /** DB PORT */
    private static final int DB_PORT__ = 9092;
    /** DB名 */
    private static final String DB_NAME__ = "gs2db";

    /** 接続文字列オプション */
    private static String jdbcUrlOption__ = null;

    static {

        //H2Database 接続オプションを取得する
        try {
            ResourceBundle optionResource = ResourceBundle.getBundle("connectOption");

            Enumeration keys = optionResource.getKeys();
            StringBuffer sb = new StringBuffer("");
            while (keys.hasMoreElements()) {
                String key = keys.nextElement();
                String value = optionResource.getString(key);

                if (!StringUtil.isNullZeroString(value)) {
                    sb.append(";").append(key).append("=").append(value);
                }
            }

            jdbcUrlOption__ = sb.toString();

        } catch (Exception e) {
            log__.info("H2 Database 接続オプションなし", e);
        }
    }

    /**
     * DB接続文字列を作成する
     * @param rootPath アプリケーションのルートパス
     * @return db url
     */
    public String createUrl(String rootPath) {
        String dbDir = GsDataSourceFactory.getDbDir(rootPath);
        String url = "jdbc:h2:" + dbDir + DB_NAME__ + File.separator + DB_NAME__;

        //接続文字列にオプションを追加
        url += jdbcUrlOption__;

        log__.debug("db_url==>" + url);
        return url;
    }
    

    //データソースを生成します
    public static DataSource createDataSource(DataSourceModel dsModel) {
        BasicDataSource bds = new BasicDataSource();
        bds.setDriverClassName(dsModel.getDriverClassName());
        bds.setUrl(dsModel.getUrl());
        bds.setUsername(dsModel.getUser());
        bds.setPassword(dsModel.getPass());
        bds.setValidationQuery(dsModel.getValidationQuery());
        bds.setDefaultReadOnly(dsModel.isDefaultReadOnly());
        bds.setDefaultAutoCommit(dsModel.isDefaultAutoCommit());
        bds.setMaxIdle(dsModel.getMaxIdle());
        bds.setMaxActive(dsModel.getMaxActive());
        bds.setMaxWait(dsModel.getMaxWait());

        bds.setRemoveAbandoned(true);
        bds.setRemoveAbandonedTimeout(600);
        return bds;
    }