    001/*
    002 * Copyright (c) 2009 The openGion Project.
    003 *
    004 * Licensed under the Apache License, Version 2.0 (the "License");
    005 * you may not use this file except in compliance with the License.
    006 * You may obtain a copy of the License at
    007 *
    008 *     http://www.apache.org/licenses/LICENSE-2.0
    009 *
    010 * Unless required by applicable law or agreed to in writing, software
    011 * distributed under the License is distributed on an "AS IS" BASIS,
    012 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND,
    013 * either express or implied. See the License for the specific language
    014 * governing permissions and limitations under the License.
    015 */
    016package org.opengion.hayabusa.resource;
    017
    018import org.opengion.hayabusa.common.HybsSystem;
    019import org.opengion.fukurou.util.ApplicationInfo;
    020import org.opengion.fukurou.db.DBUtil;
    021
    022import java.util.Map;
    023import java.util.WeakHashMap;
    024import java.util.Collections ;
    025
    026/**
    027 * systemId に対応したカラムデータを作成するデータロードクラスです。
    028 *
    029 * カラムデータは、項目(CLM)に対して、各種カラム情報を持っています。
    030 * エンジン内部で使用している DBColumn オブジェクトは、RENDERER や EDITOR など
    031 * 実際にはオブジェクトで管理していますが、この ColumnData では、それらのキーとなる
    032 * 文字列を持っています。実際に DBColumn オブジェクトの構築時に、各属性オブジェクトを
    033 * 生成(または、キャッシュから取り出し)ます。
    034 *
    035 * カラムデータを作成する場合は、同一カラムで、作成区分(KBSAKU)違いの場合は、
    036 * 最も大きな作成区分を持つコードを使用します。
    037 * 作成区分(KBSAKU)='0' のデータは、マスタリソースとして、エンジンとともに
    038 * 配布されるリソースになります。
    039 *
    040 * カラムデータには、３つのレベルのオブジェクト作成方法が適用されます。
    041 * エンジン内部のカラムリソースファイル(org.opengion.hayabusa.common.data.ColumnResource)は、
    042 * 初期作成されるカラムリソースです。エンジンの更新に対応して、このリソースも同時に
    043 * 更新されます。このカラムは、最も優先順位の低いリソースで、同一キー情報で他の形式の
    044 * カラムがあれば、そちらが使用されます。
    045 *
    046 * 読込フラグ(FGLOAD)='1'のカラムリソースは、すべて初期起動時に一括読み込みされます。
    047 * 読込フラグが、'1' 以外のデータは、初期起動時には、メモリにキャッシュされず
    048 * 実際に使用されるまで、オブジェクトが作成されません。
    049 * これは、使用されるかどうか判らないカラムデータを、予め作成しないことで、メモリの
    050 * 節約を図っています。
    051 *
    052 * SYSTEM_ID='**' は、共通リソースです。
    053 * これは、システム間で共通に使用されるリソース情報を登録しておきます。
    054 *
    055 * @og.rev 4.0.0.0 (2004/12/31) 新規作成
    056 * @og.group リソース管理
    057 *
    058 * @version  4.0
    059 * @author   Kazuhiko Hasegawa
    060 * @since    JDK5.0,
    061 */
    062final class ColumnDataLoader {
    063        // リソースの接続先を、取得します。
    064        private final String DBID = HybsSystem.sys( "RESOURCE_DBID" );
    065
    066        // ＤＢリソースの初期一括読込のクエリー
    067 //private static final String QUERY = "select CLM,CLS_NAME,USE_LENGTH,VIEW_LENGTH,"
    068 //                                                                     + "RENDERER,EDITOR,DBTYPE,DATA_DEFAULT,LABEL_CLM,CODE_CLM,"
    069 //                                                                     + "CLM_PARAM,RENDERER_PARAM,EDITOR_PARAM,TYPE_PARAM,ROLES"
    070 //                                                                     + " from GEA03 where SYSTEM_ID in ( ?,'**')"
    071 //                                                                     + " and FGJ='1' and FGLOAD = '1'"
    072 //                                                                     + " order by SYSTEM_ID,CLM,KBSAKU" ;
    073
    074        // 4.3.5.7 (2009/03/22) FGLOADの影響で個別システムのリソースが読まれない問題の対応
    075        private static final String QUERY = "select CLM,CLS_NAME,USE_LENGTH,VIEW_LENGTH,"
    076                                                                        + "RENDERER,EDITOR,DBTYPE,DATA_DEFAULT,LABEL_CLM,CODE_CLM,"
    077                                                                        + "CLM_PARAM,RENDERER_PARAM,EDITOR_PARAM,TYPE_PARAM,ROLES,"
    078                                                                        + "FGLOAD"
    079                                                                        + " from GEA03 where SYSTEM_ID in ( ?,'**')"
    080                                                                        + " and FGJ='1'"
    081                                                                        + " order by SYSTEM_ID,CLM,KBSAKU" ;
    082
    083        // ＤＢリソースの個別読込時のクエリー
    084        private static final String QUERY2 = "select CLM,CLS_NAME,USE_LENGTH,VIEW_LENGTH,"
    085                                                                        + "RENDERER,EDITOR,DBTYPE,DATA_DEFAULT,LABEL_CLM,CODE_CLM,"
    086                                                                        + "CLM_PARAM,RENDERER_PARAM,EDITOR_PARAM,TYPE_PARAM,ROLES"
    087                                                                        + " from GEA03 where SYSTEM_ID in ( ?,'**')"
    088                                                                        + " and CLM=? and FGJ='1'"
    089                                                                        + " order by SYSTEM_ID,KBSAKU" ;
    090
    091        private final Map<String,ColumnData> pool = Collections.synchronizedMap( new WeakHashMap<String,ColumnData>() );    // キャッシュ用プール
    092        private final String  SYSTEM_ID ;               // システムID
    093
    094        /** コネクションにアプリケーション情報を追記するかどうか指定 */
    095        public static final boolean USE_DB_APPLICATION_INFO  = HybsSystem.sysBool( "USE_DB_APPLICATION_INFO" ) ;
    096
    097        // 3.8.7.0 (2006/12/15) アクセスログ取得の為,ApplicationInfoオブジェクトを設定
    098        private final ApplicationInfo appInfo;
    099
    100        /**
    101         *  SystemId 毎に ファクトリオブジェクトを作成します。
    102         *
    103         * @og.rev 3.8.7.0 (2006/12/15) アクセスログ取得の為,ApplicationInfoオブジェクトを設定
    104         *
    105         * @param systemId システムID
    106         * @param initLoad リソースデータの先読み可否(true:先読みする)
    107         */
    108        ColumnDataLoader( final String systemId,final boolean initLoad ) {
    109                SYSTEM_ID = systemId;
    110
    111                // 3.8.7.0 (2006/12/15) アクセスログ取得の為,ApplicationInfoオブジェクトを設定
    112                if( USE_DB_APPLICATION_INFO ) {
    113                        appInfo = new ApplicationInfo();
    114                        // ユーザーID,IPアドレス,ホスト名
    115                        appInfo.setClientInfo( SYSTEM_ID,HybsSystem.HOST_ADRS,HybsSystem.HOST_NAME );
    116                        // 画面ID,操作,プログラムID
    117                        appInfo.setModuleInfo( "ColumnDataLoader",null,null );
    118                }
    119                else {
    120                        appInfo = null;
    121                }
    122
    123                // ApplicationInfo の設定が終わってから実行します。
    124                if( initLoad ) { loadDBResource(); }
    125        }
    126
    127        /**
    128         * ＤＢリソースより カラムデータを取得、設定します。
    129         * 同一キー(CLM)に対して、複数の作成区分(KBSAKU)を持つデータが
    130         * 検索される場合は、作成区分(KBSAKU)の大きな値が使用されます。
    131         * つまり、より、ローカライズなキーほど、作成区分(KBSAKU)に大きな値を
    132         * 使用するようにします。
    133         *
    134         * @og.rev 3.8.7.0 (2006/12/15) アクセスログ取得の為,ApplicationInfoオブジェクトを設定
    135         * @og.rev 4.3.5.7 (2009/03/22) FGLOADの影響でシステム個別リソースが読まれない問題対応
    136         *
    137         */
    138        private void loadDBResource() {
    139                String[] args = new String[] { SYSTEM_ID };
    140
    141                String[][] vals = DBUtil.dbExecute( QUERY,args,appInfo,DBID );
    142
    143                int len = vals.length;
    144                for( int i=0; i<len; i++ ) {
    145                        if( "1".equals( vals[i][ColumnData.FG_LOAD] ) ) { // 4.3.5.7 (2009/03/22)
    146                                pool.put( vals[i][0],new ColumnData( vals[i] ) );
    147                        }
    148                        // より上の作成区分で、FGLOAD='0'(個別読込)が来た場合は、下位のFGLOAD='1'(一括読込)を破棄
    149                        else if( pool.get( vals[i][0]) != null ){
    150                                pool.remove( vals[i][0] );
    151                        }
    152                }
    153
    154                System.out.println( "  ColumnDataLoader [" + len + "] loaded" );
    155        }
    156
    157        /**
    158         * ColumnData オブジェクトを取得します。
    159         * 作成したColumnDataオブジェクトは，内部にプールしておき，同じリソース要求が
    160         * あったときは，プールの ColumnDataを返します。
    161         * 読込フラグ(FGLOAD)が '1' のデータは、起動時に先読みします。
    162         * それ以外のデータは、ここでキー要求が発生した時点で読み込みます。
    163         * 読込フラグ(FGLOAD) のマーカー設定モード(useAutoSetting)を使用する(true)場合は、
    164         * 追加読み込み(先読みされていないカラム)に対して、読込フラグ(FGLOAD)を '2' に
    165         * 自動設定します。(次回起動時の、初期読み込みは行いません。)
    166         *
    167         * @og.rev 3.8.7.0 (2006/12/15) アクセスログ取得の為,ApplicationInfoオブジェクトを設定
    168         *
    169         * @param   key         カラムのキー
    170         *
    171         * @return  ColumnData  カラムオブジェクト
    172         */
    173        public ColumnData getColumnData( final String key ) {
    174                ColumnData column = pool.get( key ) ;
    175                if( column == null ) {
    176                        String[] args = new String[] { SYSTEM_ID,key };
    177                        String[][] vals = DBUtil.dbExecute( QUERY2,args,appInfo,DBID );         // 個別検索
    178
    179                        if( vals.length > 0 ) {
    180                                column = new ColumnData( vals[vals.length-1] );         // 最後の検索結果が有効
    181                                pool.put( key,column );
    182                        }
    183                }
    184
    185                return column ;
    186        }
    187
    188        /**
    189         * ColumnData オブジェクトのキャッシュを個別にクリアします。
    190         * リソースデータの更新など、一部分の更新時に、すべてのキャッシュを
    191         * 破棄するのではなく、指定の分のみ破棄できる機能です。
    192         *
    193         * @param   key         カラムのキー
    194         */
    195        public void clear( final String key ) {
    196                pool.remove( key );
    197        }
    198
    199        /**
    200         * ColumnData オブジェクトのキャッシュをクリアします。
    201         *
    202         */
    203        public void clear() {
    204                pool.clear();
    205        }
    206}