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     */
016    package org.opengion.hayabusa.taglib;
017    
018    import org.opengion.hayabusa.common.HybsSystem;
019    import org.opengion.hayabusa.common.HybsSystemException;
020    import org.opengion.hayabusa.resource.ResourceManager;
021    import org.opengion.hayabusa.resource.GUIInfo;
022    import org.opengion.hayabusa.db.DBColumn;
023    import org.opengion.fukurou.db.Transaction;
024    import org.opengion.fukurou.db.TransactionReal;
025    import org.opengion.fukurou.util.FileUtil;
026    import org.opengion.fukurou.util.ErrorMessage;
027    import org.opengion.fukurou.util.StringUtil;
028    import org.opengion.fukurou.util.Closer ;
029    import org.opengion.fukurou.model.Formatter;
030    import org.opengion.fukurou.model.ArrayDataModel;
031    
032    import static org.opengion.fukurou.util.StringUtil.nval ;
033    
034    import java.sql.Connection;
035    import java.sql.PreparedStatement;
036    import java.sql.SQLException;
037    
038    import java.io.File;
039    import java.io.BufferedReader;
040    import java.io.IOException;
041    
042    /**
043     * 謖?ｮ壹?繝輔ぃ繧､繝ｫ繧堤峩謗･繝??繧ｿ繝吶?繧ｹ縺ｫ逋ｻ骭ｲ縺吶ｋ繝??繧ｿ蜈･蜉帙ち繧ｰ縺ｧ縺吶?
044     *
045     * 騾壼ｸｸ縺ｮ readTable 縺ｪ縺ｩ縺ｯ縲．BTableModel繧ｪ繝悶ず繧ｧ繧ｯ繝医ｒ莉九＠縺ｦ蜈ｨ莉ｶ繝｡繝｢繝ｪ縺ｫ
046     * 繝ｭ繝ｼ繝峨＠縺ｦ縺九ｉ陦ｨ遉ｺ縺輔○繧狗ぜ縲∝､ｧ驥上ョ繝ｼ繧ｿ蜃ｦ逅?′縺ｧ縺阪∪縺帙ｓ縲?
047     * 縺薙?繧ｿ繧ｰ縺ｧ縺ｯ縲∫峩謗･繝輔ぃ繧､繝ｫ繧定ｪｭ縺ｿ蜿悶ｊ縺ｪ縺後ｉ繝??繧ｿ繝吶?繧ｹ逋ｻ骭ｲ縺吶ｋ縺ｮ縺ｧ
048     * 螟ｧ驥上ョ繝ｼ繧ｿ繧偵ヰ繝?メ逧?↓逋ｻ骭ｲ縺吶ｋ蝣ｴ蜷医↓菴ｿ逕ｨ縺励∪縺吶?
049     *
050     * 隱ｭ縺ｿ蜿悶ｋ繝輔ぃ繧､繝ｫ縺ｯ縲∝?鬆ｭ(縺ｾ縺溘?螳溘ョ繝ｼ繧ｿ縺檎樟繧後ｋ縺ｾ縺ｧ縺ｫ) #NAME 陦後′蠢?ｦ√〒縺吶?
051     * 縺薙ｌ縺ｯ縲√ヵ繧｡繧､繝ｫ繝??繧ｿ縺ｮ繧ｫ繝ｩ繝?錐繧呈欠螳壹＠縺ｦ縺?∪縺吶?縺ｾ縺溘?columns 螻樊?繧剃ｽｿ逕ｨ縺吶ｌ縺ｰ縲?
052     * 繝輔ぃ繧､繝ｫ縺ｮ#NAME 陦後ｈ繧雁━蜈医＠縺ｦ(縺､縺ｾ繧雁ｭ伜惠縺励※縺?↑縺上※繧り憶縺?繝??繧ｿ縺ｮ繧ｫ繝ｩ繝?錐繧?
053     * 謖?ｮ壹☆繧九％縺ｨ縺悟?譚･縺ｾ縺吶?
054     * 縺薙?#NAME 陦後?縲√ヵ繧｡繧､繝ｫ縺ｮ繧ｻ繝代Ξ繝ｼ繧ｿ縺ｨ辟｡髢｢菫ゅ↓蠢?★繧ｿ繝門玄蛻?ｊ縺ｧ逕ｨ諢上＆繧後※縺?∪縺吶?
055     * 繧ｿ繧ｰ縺ｮBODY驛ｨ縺ｫ縲∝ｮ溯｡後☆繧鬼QL譁?ｒ險倩ｿｰ縺励∪縺吶?
056     * 縺薙?SQL譁??縲?
057     * INSERT INTO GE41 (CLM,NAME_JA,SYSTEM_ID,FGJ,DYSET)
058     * VALUES ([CLM],[NAME_JA],[SYSTEM_ID],'1','{&#064;USER.YMDH}')
059     * 縺ｨ縲√＞縺?─縺倥〒縲√ヵ繧｡繧､繝ｫ縺九ｉ隱ｭ縺ｿ霎ｼ繧薙□蛟､縺ｯ縲ー繧ｫ繝ｩ繝?錐]縺ｫ蜑ｲ繧雁ｽ薙※繧峨ｌ縺ｾ縺吶?
060     * 繧ゅ■繧阪ｓ縲??蟶ｸ縺ｮ蝗ｺ螳壼?(FGJ縺ｫ'1'繧偵そ繝?ヨ)繧??繝ｪ繧ｯ繧ｨ繧ｹ繝亥､画焚(DYSET縺ｮ{&#064;USER.YMDH})
061     * 縺ｪ縺ｩ繧ゆｽｿ逕ｨ縺ｧ縺阪∪縺吶?
062     *
063     * 窶ｻ 縺薙?繧ｿ繧ｰ縺ｯ縲ゝransaction 繧ｿ繧ｰ縺ｮ蟇ｾ雎｡縺ｧ縺吶?
064     *
065     * @og.formSample
066     * 笳丞ｽ｢蠑擾ｼ?lt;og:directTableInsert filename="[?･?･?･]" ?･?･?･ &gt;INSERT INTO ?･?･?･ &lt;/og:directTableInsert &gt;
067     * 笳獣ody?壹≠繧?EVAL_BODY_BUFFERED:BODY繧定ｩ穂ｾ｡縺励?{&#064;XXXX} 繧定ｧ｣譫舌＠縺ｾ縺?
068     *
069     * 笳週ag螳夂ｾｩ??
070     *   &lt;og:directTableInsert
071     *       fileURL            縲慎AG縲題ｪｭ縺ｿ蜿悶ｊ蜈?ョ繧｣繝ｬ繧ｯ繝医Μ蜷阪ｒ謖?ｮ壹＠縺ｾ縺?(蛻晄悄蛟､:FILE_URL[=filetemp/])
072     *       filename           縲慎AG縲代ヵ繧｡繧､繝ｫ繧剃ｽ懈?縺吶ｋ縺ｨ縺阪?繝輔ぃ繧､繝ｫ蜷阪ｒ繧ｻ繝?ヨ縺励∪縺?(蛻晄悄蛟､:FILE_FILENAME[=file.xls])
073     *       encode             縲慎AG縲代ヵ繧｡繧､繝ｫ繧剃ｽ懈?縺吶ｋ縺ｨ縺阪?繝輔ぃ繧､繝ｫ繧ｨ繝ｳ繧ｳ繝ｼ繝?ぅ繝ｳ繧ｰ蜷阪ｒ繧ｻ繝?ヨ縺励∪縺?(蛻晄悄蛟､:FILE_ENCODE[=UnicodeLittle])
074     *       separator          縲慎AG縲大庄螟蛾聞繝輔ぃ繧､繝ｫ繧剃ｽ懈?縺吶ｋ縺ｨ縺阪?鬆?岼蛹ｺ蛻?ｊ譁?ｭ励ｒ繧ｻ繝?ヨ縺励∪縺?蛻晄悄蛟､:繧ｿ繝?
075     *       displayMsg         縲慎AG縲倉uery 縺ｮ邨先棡繧堤判髱｢荳翫↓陦ｨ遉ｺ縺吶ｋ繝｡繝?そ繝ｼ繧ｸID繧呈欠螳壹＠縺ｾ縺?蛻晄悄蛟､:MSG0040[縲?ｻｶ逋ｻ骭ｲ縺励∪縺励◆])
076     *       columns            縲慎AG縲?NAME 螻樊?縺ｮ莉｣繧上ｊ縺ｨ縺ｪ繧九ヵ繧｡繧､繝ｫ縺ｮ繧ｫ繝ｩ繝?錐繧?CSV蠖｢蠑上〒謖?ｮ壹＠縺ｾ縺?
077     *       commitBatch        縲慎AG縲第欠螳壽焚豈弱↓繧ｳ繝溘ャ繝医ｒ逋ｺ陦後＠縺ｾ縺?蛻晄悄蛟､:0 邨ゆｺ?∪縺ｧ繧ｳ繝溘ャ繝医＠縺ｾ縺帙ｓ)
078     *       useColumnAdjust    縲慎AG縲代き繝ｩ繝?､画鋤(DBType螟画鋤)繧定｡後≧縺九←縺?°繧定ｨｭ螳壹＠縺ｾ縺?蛻晄悄蛟､:false)
079     *       useColumnCheck     縲慎AG縲代き繝ｩ繝?メ繧ｧ繝?け(DBType繝√ぉ繝?け)繧定｡後≧縺九←縺?°繧定ｨｭ螳壹＠縺ｾ縺?蛻晄悄蛟､:false)
080     *       nullCheck          縲慎AG縲鮮ULL 繝√ぉ繝?け縺吶∋縺阪き繝ｩ繝??繧偵き繝ｳ繝槫玄蛻?ｊ(CSV蠖｢蠑?縺ｧ謖?ｮ壹＠縺ｾ縺?
081     *       dbid               縲慎AG縲?騾壼ｸｸ縺ｯ菴ｿ縺?∪縺帙ｓ)讀懃ｴ｢譎ゅ?DB謗･邯唔D繧呈欠螳壹＠縺ｾ縺?蛻晄悄蛟､:DEFAULT)
082     *       skipRowCount       縲慎AG縲代ョ繝ｼ繧ｿ縺ｮ隱ｭ縺ｿ鬟帙?縺嶺ｻｶ謨ｰ繧定ｨｭ螳壹＠縺ｾ縺?蛻晄悄蛟､:0)
083     *       stopZero           縲慎AG縲第､懃ｴ｢邨先棡縺鯉ｼ蝉ｻｶ縺ｮ縺ｨ縺榊?逅?ｒ邯夊｡後☆繧九°縺ｩ縺?°[true/false]繧呈欠螳壹＠縺ｾ縺?蛻晄悄蛟､:false[邯夊｡後☆繧犠)
084     *       debug              縲慎AG縲代ョ繝舌ャ繧ｰ諠??繧貞?蜉帙☆繧九°縺ｩ縺?°[true/false]繧呈欠螳壹＠縺ｾ縺?蛻晄悄蛟､:false)
085     *   &gt;   ... Body ...
086     *   &lt;/og:directTableInsert&gt;
087     *
088     * 笳丈ｽｿ逕ｨ萓?
089     *     &lt;og:directTableInsert
090     *         dbid         = "ORCL"                謗･邯壹ョ繝ｼ繧ｿ繝吶?繧ｹID(蛻晄悄蛟､:DEFAULT)
091     *         separator    = ","                   繝輔ぃ繧､繝ｫ縺ｮ蛹ｺ蛻?ｊ譁?ｭ?蛻晄悄蛟､:繧ｿ繝?
092     *         fileURL      = "{&#064;USER.ID}"     隱ｭ縺ｿ蜿悶ｊ蜈?ョ繧｣繝ｬ繧ｯ繝医Μ蜷?
093     *         filename     = "{&#064;filename}"    隱ｭ縺ｿ蜿悶ｊ蜈?ヵ繧｡繧､繝ｫ蜷?
094     *         encode       = "Shift_JIS"           隱ｭ縺ｿ蜿悶ｊ蜈?ヵ繧｡繧､繝ｫ繧ｨ繝ｳ繧ｳ繝ｼ繝牙錐
095     *         displayMsg   = "MSG0040"             逋ｻ骭ｲ螳御ｺ?ｾ後?繝｡繝?そ繝ｼ繧ｸ
096     *         columns      = "CLM,NAME_JA,LABEL_NAME,KBSAKU,SYSTEM_ID,LANG"
097     *                                              #NAME 縺ｮ莉｣繧上ｊ縺ｫ菴ｿ逕ｨ縺吶ｋ繧ｫ繝ｩ繝??蜷?
098     *         commitBatch  = "100"                 縺薙?莉ｶ謨ｰ縺壹▽繧ｳ繝溘ャ繝医ｒ逋ｺ陦?蛻晄悄蛟､:辟｡蛻ｶ髯?
099     *         useColumnCheck  = "true"             繧ｫ繝ｩ繝?メ繧ｧ繝?け繧定｡後≧縺九←縺?°(蛻晄悄蛟､:false)
100     *         useColumnAdjust = "true"             繧ｫ繝ｩ繝?､画鋤繧定｡後≧縺九←縺?°(蛻晄悄蛟､:false)
101     *         nullCheck       = "CLM,SYSTEM_ID"    NULL繝√ぉ繝?け繧貞ｮ溯｡後＠縺ｾ縺吶?
102     *     &gt;
103     *          INSERT INTO GE41
104     *              (CLM,NAME_JA,LABEL_NAME,KBSAKU,SYSTEM_ID,LANG,
105     *                 FGJ,DYSET,DYUPD,USRSET,USRUPD,PGUPD)
106     *          VALUES
107     *              ([CLM],[NAME_JA],[LABEL_NAME],[KBSAKU],[SYSTEM_ID],[LANG],
108     *                '1','{&#064;USER.YMDH}','{&#064;USER.YMDH}','{&#064;USER.ID}','{&#064;USER.ID}','{&#064;GUI.KEY}')
109     *     &lt;/og:directTableInsert &gt;
110     *
111     * @og.group 繝輔ぃ繧､繝ｫ蜈･蜉?
112     *
113     * @version  4.0
114     * @author   Kazuhiko Hasegawa
115     * @since    JDK5.0,
116     */
117    public class DirectTableInsertTag extends CommonTagSupport {
118            //* 縺薙?繝励Ο繧ｰ繝ｩ繝??VERSION譁?ｭ怜?繧定ｨｭ螳壹＠縺ｾ縺吶?       {@value} */
119            private static final String VERSION = "5.7.6.2 (2014/05/16)" ;
120    
121            private static final long serialVersionUID = 576220140516L ;
122    
123            private static final String TAB_SEPARATOR = "\t" ;
124    
125            // 4.0.0.0 (2007/10/10) dbid 縺ｮ蛻晄悄蛟､繧偵?"DEFAULT" 縺九ｉ null 縺ｫ螟画峩
126            private String          dbid            = null;
127            private String          separator       = TAB_SEPARATOR;   // 鬆?岼蛹ｺ蛻?ｊ譁?ｭ?
128            private String          fileURL         = HybsSystem.sys( "FILE_URL" );                 // 4.0.0 (2005/01/31)
129            private String          filename        = HybsSystem.sys( "FILE_FILENAME" );    // 繝輔ぃ繧､繝ｫ蜷?
130            private String          encode          = HybsSystem.sys( "FILE_ENCODE"   );    // 繝輔ぃ繧､繝ｫ繧ｨ繝ｳ繧ｳ繝ｼ繝?ぅ繝ｳ繧ｰ  "JISAutoDetect" ,"JIS", "EUC_JP", "MS932", "SJIS" , "Windows-31J" , "Shift_JIS"
131            private String          displayMsg      = "MSG0040";    // 縲?ｻｶ逋ｻ骭ｲ縺励∪縺励◆縲?
132            private String[]        columns         = null;
133            private String[]        clmKeys         = null;                 // SQL譁??[繧ｫ繝ｩ繝?錐]驟榊?
134            private String          sql                     = null;
135            private int                     commitBatch     = 0;                    // 繧ｳ繝溘ャ繝医☆繧九∪縺ｨ繧∽ｻｶ謨ｰ
136            private boolean         useColumnCheck  = false;        // 3.6.0.2 (2004/10/04)
137            private boolean         useColumnAdjust = false;        // 3.6.0.2 (2004/10/04)
138            private String[]        nullCheck       = null;                 // 3.8.0.2 (2005/06/30) null繝√ぉ繝?け遒ｺ隱?
139            private long            dyStart         = 0;                    // 螳溯｡梧凾髢捺ｸｬ螳夂畑縺ｮDIV隕∫ｴ?ｒ蜃ｺ蜉帙＠縺ｾ縺吶?
140            private int                     skipRowCount= 0;                        // 5.5.7.1 (2012/10/01)
141            private boolean         stopZero        = false;                // 5.7.6.2 (2014/05/16) stopZero螻樊?霑ｽ蜉?
142    
143            /**
144             * Taglib縺ｮ髢句ｧ九ち繧ｰ縺瑚ｦ九▽縺九▲縺溘→縺阪↓蜃ｦ逅?☆繧?doStartTag() 繧?繧ｪ繝ｼ繝舌?繝ｩ繧､繝峨＠縺ｾ縺吶?
145             *
146             * @return      蠕檎ｶ壼?逅??謖?､ｺ( EVAL_BODY_BUFFERED )
147             */
148            @Override
149            public int doStartTag() {
150                    dyStart = System.currentTimeMillis();           // 譎る俣貂ｬ螳夂畑
151                    return EVAL_BODY_BUFFERED ;     // Body 繧定ｩ穂ｾ｡縺吶ｋ縲? extends BodyTagSupport 譎?
152            }
153    
154            /**
155             * Taglib縺ｮ繧ｿ繧ｰ譛ｬ菴薙ｒ蜃ｦ逅?☆繧?doAfterBody() 繧?繧ｪ繝ｼ繝舌?繝ｩ繧､繝峨＠縺ｾ縺吶?
156             *
157             * @og.rev 3.6.0.2 (2004/10/04) SQL譁?? [繧ｫ繝ｩ繝? 蟇ｾ蠢懊→繝代?繧ｵ繝ｼ讖溯?霑ｽ蜉?
158             * @og.rev 3.8.6.3 (2006/11/30) SQL 譁??蜑榊ｾ後?繧ｹ繝壹?繧ｹ繧貞叙繧企勁縺阪∪縺吶?
159             *
160             * @return      蠕檎ｶ壼?逅??謖?､ｺ(SKIP_BODY)
161             */
162            @Override
163            public int doAfterBody() {
164                    sql = getBodyString();
165                    if( sql == null || sql.length() == 0 ) {
166                            String errMsg = "BODY 驛ｨ縺ｮ逋ｻ骭ｲ逕ｨ Insert/Update譁??縲∝ｿ??縺ｧ縺吶?";
167                            throw new HybsSystemException( errMsg );
168                    }
169    
170                    return SKIP_BODY ;                              // Body 繧定ｩ穂ｾ｡縺励↑縺?
171            }
172    
173            /**
174             * Taglib縺ｮ邨ゆｺ?ち繧ｰ縺瑚ｦ九▽縺九▲縺溘→縺阪↓蜃ｦ逅?☆繧?doEndTag() 繧?繧ｪ繝ｼ繝舌?繝ｩ繧､繝峨＠縺ｾ縺吶?
175             *
176             * @og.rev 4.0.0.0 (2007/10/18) 繝｡繝?そ繝ｼ繧ｸ繝ｪ繧ｽ繝ｼ繧ｹ邨ｱ蜷? getResource().getMessage 竍?getResource().getLabel )
177             * @og.rev 5.7.0.3 (2013/11/22) BufferedReader縺ｮclose繧団reate蜀?〒陦後≧繧医≧縺ｫ螟画峩
178             * @og.rev 5.7.6.2 (2014/05/16) stopZero螻樊?縲．B.COUNT 繧ｭ繝ｼ縺ｧ讀懃ｴ｢莉ｶ謨ｰ繧偵Μ繧ｯ繧ｨ繧ｹ繝医↓繧ｻ繝?ヨ縺吶ｋ縲?
179             *
180             * @return      蠕檎ｶ壼?逅??謖?､ｺ
181             */
182            @Override
183            public int doEndTag() {
184                    debugPrint();           // 4.0.0 (2005/02/28)
185    
186                    BufferedReader pw = getBufferedReader();
187                    int executeCount = create( pw );
188    
189                    // 螳溯｡御ｻｶ謨ｰ縺ｮ陦ｨ遉ｺ
190                    // 4.0.0 (2005/11/30) 蜃ｺ蜉幃?縺ｮ螟画峩縲ゆｸ?分譛??縺ｫ蜃ｺ蜉帙＠縺ｾ縺吶?
191                    if( displayMsg != null && displayMsg.length() > 0 ) {
192                            String status = executeCount + getResource().getLabel( displayMsg ) ;
193                            jspPrint( status + HybsSystem.BR );
194                    }
195    
196                    // 5.7.6.2 (2014/05/16) 讀懃ｴ｢邨先棡縺ｮ莉ｶ謨ｰ繧偵?"DB.COUNT" 繧ｭ繝ｼ縺ｧ繝ｪ繧ｯ繧ｨ繧ｹ繝医↓繧ｻ繝?ヨ縺吶ｋ縲?
197                    setRequestAttribute( "DB.COUNT" , String.valueOf( executeCount ) );
198    
199                    // 5.7.6.2 (2014/05/16) 莉ｶ謨ｰ?蝉ｻｶ縺九▽ stopZero = true
200                    if( executeCount == 0 && stopZero ) { return SKIP_PAGE; }
201    
202                    // 譎る俣貂ｬ螳夂畑縺ｮ DIV 隕∫ｴ?ｒ蜃ｺ蜉?
203                    long dyTime = System.currentTimeMillis()-dyStart;
204                    jspPrint( "<div id=\"queryTime\" value=\"" + (dyTime) + "\"></div>" );      // 3.5.6.3 (2004/07/12)
205    
206                    // 4.0.0 (2005/01/31) 繧ｻ繧ｭ繝･繝ｪ繝?ぅ繝√ぉ繝?け(繝??繧ｿ繧｢繧ｯ繧ｻ繧ｹ莉ｶ謨ｰ逋ｻ骭ｲ)
207                    GUIInfo guiInfo = (GUIInfo)getSessionAttribute( HybsSystem.GUIINFO_KEY );
208                    if( guiInfo != null ) { guiInfo.addWriteCount( executeCount,dyTime,sql ); }
209    
210                    return EVAL_PAGE ;
211            }
212    
213            /**
214             * 繧ｿ繧ｰ繝ｪ繝悶が繝悶ず繧ｧ繧ｯ繝医ｒ繝ｪ繝ｪ繝ｼ繧ｹ縺励∪縺吶?
215             * 繧ｭ繝｣繝?す繝･縺輔ｌ縺ｦ蜀榊茜逕ｨ縺輔ｌ繧九?縺ｧ縲√ヵ繧｣繝ｼ繝ｫ繝峨?蛻晄悄險ｭ螳壹ｒ陦後＞縺ｾ縺吶?
216             *
217             * @og.rev 3.6.0.2 (2004/10/04) useColumnCheck,useColumnAdjust 螻樊?霑ｽ蜉?
218             * @og.rev 3.8.0.2 (2005/06/30) nullCheck 螻樊?霑ｽ蜉?
219             * @og.rev 4.0.0.0 (2007/10/10) dbid 縺ｮ蛻晄悄蛟､繧偵?"DEFAULT" 縺九ｉ null 縺ｫ螟画峩
220             * @og.rev 5.5.7.1 (2012/10/05) skipRowCount霑ｽ蜉?
221             * @og.rev 5.7.6.2 (2014/05/16) stopZero螻樊?霑ｽ蜉?
222             */
223            @Override
224            protected void release2() {
225                    super.release2();
226                    dbid                    = null;
227                    separator               = TAB_SEPARATOR;   // 鬆?岼蛹ｺ蛻?ｊ譁?ｭ?
228                    fileURL                 = HybsSystem.sys( "FILE_URL" );         // 4.0.0 (2005/01/31)
229                    filename                = HybsSystem.sys( "FILE_FILENAME"        );   // 繝輔ぃ繧､繝ｫ蜷?
230                    encode                  = HybsSystem.sys( "FILE_ENCODE"          );   // 繝輔ぃ繧､繝ｫ繧ｨ繝ｳ繧ｳ繝ｼ繝?ぅ繝ｳ繧ｰ  "JISAutoDetect" ,"JIS", "EUC_JP", "MS932", "SJIS" , "Windows-31J" , "Shift_JIS"
231                    displayMsg              = "MSG0040";    // 縲?ｻｶ逋ｻ骭ｲ縺励∪縺励◆縲?
232                    columns                 = null;         // 3.5.4.5 (2004/01/23)
233                    useColumnCheck  = false;        // 3.6.0.2 (2004/10/04)
234                    useColumnAdjust = false;        // 3.6.0.2 (2004/10/04)
235                    nullCheck               = null;         // 3.8.0.2 (2005/06/30)
236                    skipRowCount    = 0;            // 5.5.7.1 (2012/10/05)
237                    stopZero                = false;        // 5.7.6.2 (2014/05/16) stopZero螻樊?霑ｽ蜉?
238            }
239    
240            /**
241             * BufferedReader 繧医ｊ隱ｭ縺ｿ霎ｼ縺ｿ縲√ョ繝ｼ繧ｿ繝吶?繧ｹ縺ｫ譖ｸ縺崎ｾｼ縺ｿ縺ｾ縺吶?
242             *
243             * @og.rev 3.6.0.2 (2004/10/04) 繧ｫ繝ｩ繝?が繝悶ず繧ｧ繧ｯ繝医?DBType螻樊?縺ｮ謨ｴ蜷域?繝√ぉ繝?け
244             * @og.rev 3.8.0.2 (2005/06/30) null繝√ぉ繝?け遒ｺ隱?
245             * @og.rev 3.8.5.1 (2006/05/08) 蜿冶ｾｼ繝??繧ｿ縺?name 蛻励ｈ繧雁ｰ代↑縺??蜷医?蟇ｾ蠢懊ｒ霑ｽ蜉?
246             * @og.rev 3.8.7.0 (2006/12/15) 繧｢繧ｯ繧ｻ繧ｹ繝ｭ繧ｰ蜿門ｾ励?轤ｺ,ApplicationInfo繧ｪ繝悶ず繧ｧ繧ｯ繝医ｒ險ｭ螳?
247             * @og.rev 4.0.0.0 (2005/01/31) CheckColumnData繧ｯ繝ｩ繧ｹ static 蛹悶?蠑墓焚縺ｫResourceManager霑ｽ蜉?
248             * @og.rev 4.0.0.1 (2007/12/03) try ??catch ??finally 繧偵″縺｡繧薙→陦後≧縲?
249             * @og.rev 5.1.9.0 (2010/08/01) Transaction 蟇ｾ蠢?
250             * @og.rev 5.2.2.0 (2010/11/01)) ""縺ｧ蝗ｲ繧上ｌ縺ｦ縺?ｋ繝??繧ｿ縺ｫ謾ｹ陦後′蜈･縺｣縺ｦ縺?◆蝣ｴ蜷医?蟇ｾ蠢?
251             * @og.rev 5.3.7.0 (2011/07/01) TransactionReal 縺ｮ蠑墓焚螟画峩
252             * @og.rev 5.3.8.0 (2011/08/01) pstmt.setObject 縺ｧ縲「seParamMetaData 縺ｮ蛻､螳壹ｒ驕ｿ縺代ｋ縺溘ａ縲｝stmt.setString 縺ｧ莉｣逕ｨ(PostgreSQL蟇ｾ蠢?
253             * @og.rev 5.5.7.1 (2012/10/05) omitFirstLine蟇ｾ蠢?
254             * @og.rev 5.7.0.3 (2013/11/22) BufferedReader縺ｮclose蜃ｦ逅?ｒ縺薙?繝｡繧ｽ繝?ラ蜀??finally縺ｧ陦後≧
255             *
256             * @param   reader BufferedReader繧ｪ繝悶ず繧ｧ繧ｯ繝?
257             *
258             * @return  蜿悶ｊ霎ｼ縺ｿ莉ｶ謨ｰ
259             */
260            private int create( final BufferedReader reader )  {
261    
262                    String[] names = readName( reader );    // 繝輔ぃ繧､繝ｫ縺ｮ繧ｫ繝ｩ繝?錐
263                    int   nameLen = names.length ;                  // 3.8.5.1 (2006/05/08) 霑ｽ蜉?
264    
265                    ArrayDataModel nmdata = new ArrayDataModel( names );
266                    Formatter format = new Formatter( nmdata );
267                    format.setFormat( sql.trim() );
268                    sql = format.getQueryFormatString();
269                    int[] clmNos = format.getClmNos();
270                    int   clmNosLen = clmNos.length ;
271                    clmKeys = format.getClmKeys();
272    
273                    CheckColumnData checkClass = new CheckColumnData( clmNos,clmKeys,getResource() );
274    
275                    ArrayDataModel nullData = new ArrayDataModel( names );
276                    int[] nullClmNos = nullData.getColumnNos( nullCheck );  // 繝舌う繝ｳ繝牙､画焚縺ｮ繧｢繝峨Ξ繧ｹ豎ゅａ
277    
278                    // 3.8.0.2 (2005/06/30) null繝√ぉ繝?け遒ｺ隱?
279                    int   nullClmNosLen = nullClmNos.length ;
280    
281                    int    executeCount = 0;
282                    int    commitCount  = 0;
283                    char   sep  = separator.charAt(0);
284                    boolean errFlag  = true;
285                    Transaction tran = null;        // 5.1.9.0 (2010/08/01) Transaction 蟇ｾ蠢?
286                    PreparedStatement pstmt = null ;
287                    String[] data   = null ;
288                    int skip = skipRowCount; // 5.5.7.1 (2012/10/05)
289                    try {
290                            // 5.1.9.0 (2010/08/01) Transaction 蟇ｾ蠢?
291                            TransactionTag tranTag = (TransactionTag)findAncestorWithClass( this,TransactionTag.class );
292                            if( tranTag == null ) {
293                                    tran = new TransactionReal( getApplicationInfo() );             // 5.3.7.0 (2011/07/01) 蠑墓焚螟画峩
294                            }
295                            else {
296                                    tran = tranTag.getTransaction();
297                            }
298    
299                            Connection conn = tran.getConnection( dbid );           // 5.1.9.0 (2010/08/01) Transaction 蟇ｾ蠢?
300                            pstmt = conn.prepareStatement( sql );
301                            String line ;
302                            while((line = reader.readLine()) != null) {
303                                    if( line.length() == 0 || line.charAt( 0 ) == '#' ) { continue; }
304                                    else if( skip > 0 ){ skip--; continue;} // 5.5.7.1 (2012/10/05) 
305                                    else {
306                                            // 5.2.2.0 (2010/11/01) ""縺ｧ蝗ｲ繧上ｌ縺ｦ縺?ｋ繝??繧ｿ縺ｫ謾ｹ陦後′蜈･縺｣縺ｦ縺?◆蝣ｴ蜷医?蟇ｾ蠢?
307                                            int quotCount = StringUtil.countChar( line, '"' );
308                                            if( quotCount % 2 != 0 ) {
309                                                    String addLine = null;
310                                                    StringBuilder buf = new StringBuilder( line );
311                                                    while(quotCount % 2 != 0 && (addLine = reader.readLine()) != null) {
312                                                            if( line.length() == 0 || line.charAt( 0 ) == '#' ) { continue; }
313                                                            buf.append( HybsSystem.CR ).append( addLine );
314                                                            quotCount += StringUtil.countChar( addLine, '"' );
315                                                    }
316                                                    line = buf.toString();
317                                            }
318    
319                                            // 3.8.5.1 (2006/05/08) 蜿冶ｾｼ繝??繧ｿ縺?name 蛻励ｈ繧雁ｰ代↑縺??蜷医?蟇ｾ蠢懊ｒ霑ｽ蜉?
320                                            data = StringUtil.csv2Array( line , sep , nameLen );
321    
322                                            // 3.6.0.2 (2004/10/04) 繧ｫ繝ｩ繝?､画鋤
323                                            if( useColumnAdjust ) {
324                                                    data = checkClass.adjustData( data );
325                                            }
326    
327                                            // 3.6.0.2 (2004/10/04) 繧ｫ繝ｩ繝?メ繧ｧ繝?け
328                                            if( useColumnCheck ) {
329                                                    ErrorMessage errMsg = checkClass.checkData( executeCount, data );
330                                                    if( !errMsg.isOK() ) {
331                                                            tran.rollback();                        // 5.1.9.0 (2010/08/01) Transaction 蟇ｾ蠢?
332                                                            jspPrint( TaglibUtil.makeHTMLErrorTable( errMsg,getResource() ) );
333                                                            return commitCount;
334                                                    }
335                                            }
336    
337                                            // 3.8.0.2 (2005/06/30) null繝√ぉ繝?け遒ｺ隱?
338                                            if( nullClmNosLen > 0 ) {
339                                                    ErrorMessage errMsg = new ErrorMessage( "Null Check Columns Error!" );
340    
341                                                    for( int i=0; i<nullClmNosLen; i++ ) {
342                                                            int clm = nullClmNos[i];
343                                                            if( data[clm] == null || data[clm].length() == 0 ) {
344                                                                    String label = getResource().getLabel( nullCheck[i] );
345                                                                    // ERR0012 : 謖?ｮ壹?繝??繧ｿ縺後そ繝?ヨ縺輔ｌ縺ｦ縺?∪縺帙ｓ縲?NULL繧ｨ繝ｩ繝ｼ)縲Ｌey={0}
346                                                                    errMsg.addMessage( executeCount+1,ErrorMessage.NG,"ERR0012",label );
347                                                            }
348                                                    }
349                                                    if( !errMsg.isOK() ) {
350                                                            tran.rollback();                        // 5.1.9.0 (2010/08/01) Transaction 蟇ｾ蠢?
351                                                            jspPrint( TaglibUtil.makeHTMLErrorTable( errMsg,getResource() ) );
352                                                            return commitCount;
353                                                    }
354                                            }
355    
356                                            for( int i=0; i<clmNosLen; i++ ) {
357                                                    String val = data[clmNos[i]];
358                                                    if( val != null && val.startsWith( "'0" ) ) {
359                                                            val = val.substring( 1 );
360                                                    }
361                                                    pstmt.setString( i+1,val );
362                                            }
363    
364                                            pstmt.execute();
365                                            if( commitBatch > 0 && ( executeCount%commitBatch == 0 ) ) {
366                                                    tran.commit();                  // 5.1.9.0 (2010/08/01) Transaction 蟇ｾ蠢?
367                                                    commitCount = executeCount;
368                                            }
369                                            executeCount++ ;
370                                    }
371                            }
372                            tran.commit();                  // 5.1.9.0 (2010/08/01) Transaction 蟇ｾ蠢?
373                            commitCount = executeCount ;
374                            errFlag = false;                // 繧ｨ繝ｩ繝ｼ縺ｧ縺ｯ縺ｪ縺?
375                    }
376                    catch (IOException ex) {
377                            String errMsg = "繝輔ぃ繧､繝ｫ隱ｭ霎ｼ縺ｿ繧ｨ繝ｩ繝ｼ[" + reader.toString() + "]"
378                                                    + " 陦檎分蜿ｷ=[" + executeCount +"]"
379                                                    + " 逋ｻ骭ｲ莉ｶ謨ｰ=[" + commitCount + "]"  ;
380                            throw new HybsSystemException( errMsg,ex );
381                    }
382                    catch (SQLException ex) {
383                            String errMsg = "sql=[" + sql + "]" + HybsSystem.CR
384                                                    +       "names=[" + StringUtil.array2csv( names ) + "]" + HybsSystem.CR
385                                                    +       "vals =[" + StringUtil.array2csv( data ) + "]" + HybsSystem.CR
386                                                    + " 陦檎分蜿ｷ=[" + executeCount +"]"
387                                                    + " 逋ｻ骭ｲ莉ｶ謨ｰ=[" + commitCount + "]"  + HybsSystem.CR
388                                                    + " errorCode=[" + ex.getErrorCode() + "] State=[" +
389                                                    ex.getSQLState() + "]" + HybsSystem.CR ;
390                            throw new HybsSystemException( errMsg,ex );
391                    }
392                    finally {
393                            Closer.stmtClose( pstmt );
394                            Closer.ioClose( reader );       // 5.7.0.3 (2013/11/22) finally縺ｧclose縺吶ｋ繧医≧縺ｫ螟画峩
395                            if( tran != null ) {                            // 5.5.2.6 (2012/05/25) findbugs蟇ｾ蠢?
396                                    tran.close( errFlag );                  // 5.1.9.0 (2010/08/01) Transaction 蟇ｾ蠢?
397                            }
398                    }
399    
400                    return commitCount;
401            }
402    
403            /**
404             * BufferedReader 繧医ｊ縲?NAME 陦後?鬆?岼蜷肴ュ蝣ｱ繧定ｪｭ縺ｿ蜿悶ｊ縺ｾ縺吶?
405             * 繝??繧ｿ繧ｫ繝ｩ繝?ｈ繧雁燕縺ｫ縲??逶ｮ蜷肴ュ蝣ｱ繧堤､ｺ縺?"#Name" 縺悟ｭ伜惠縺吶ｋ莉ｮ螳壹〒蜿悶ｊ霎ｼ縺ｿ縺ｾ縺吶?
406             * 縺薙?陦後?縲√ヵ繧｡繧､繝ｫ縺ｮ蠖｢蠑上↓辟｡髢｢菫ゅ↓縲ゝAB 縺ｧ蛹ｺ蛻?ｉ繧後※縺?∪縺吶?
407             * #NAME 驟榊?縺ｮ蜈磯?(陦檎分蜿ｷ縺ｫ縺ゅ◆繧句?謇?縺ｯ縲ヽOW_NO 縺ｨ縺?≧繧ｭ繝ｼ繧貞牡繧雁ｽ薙※縺ｾ縺吶?
408             * columns 縺瑚ｨｭ螳壹＆繧後※縺?ｋ蝣ｴ蜷医?縲?NAME 陦後〒縺ｯ縺ｪ縺上?columns 繧貞━蜈医＠縺ｾ縺吶?
409             *
410             * @og.rev 3.6.0.0 (2004/09/22) #NAME 陦後′隕九▽縺九ｉ縺ｪ縺??蜷医?縲√お繝ｩ繝ｼ縺ｨ縺励∪縺吶?
411             * @og.rev 3.6.0.2 (2004/10/04) columns 縺瑚ｨｭ螳壹＆繧後※縺?ｋ蝣ｴ蜷医?縲√◎繧後ｒ霑斐＠縺ｾ縺吶?
412             *
413             * @param       reader PrintWriter繧ｪ繝悶ず繧ｧ繧ｯ繝?
414             *
415             * @return      繧ｫ繝ｩ繝?錐驟榊?
416             */
417            private String[] readName( final BufferedReader reader ) {
418                    if( columns != null && columns.length > 0 ) {
419                            return columns ;
420                    }
421    
422                    try {
423                            String line;
424                            while((line = reader.readLine()) != null) {
425                                    if( line.length() == 0 ) { continue; }
426                                    if( line.charAt(0) == '#' ) {
427                                            if( line.length() >= 5 &&
428                                                    "#NAME".equalsIgnoreCase( line.substring( 0,5 ) ) ) {
429                                                    String[] rtn = StringUtil.csv2Array( line ,TAB_SEPARATOR.charAt(0) );
430                                                    rtn[0] = "ROW_NO";      // 蜈磯?繧ｫ繝ｩ繝?↓繧ｫ繝ｩ繝?錐繧剃ｸ弱∴繧九?
431                                                    return rtn ;
432                                            }
433                                            else { continue; }
434                                    }
435                                    else {
436                                            String errMsg = "#NAME 縺瑚ｦ九▽縺九ｋ蜑阪↓繝??繧ｿ縺瑚ｦ九▽縺九ｊ縺ｾ縺励◆縲? + HybsSystem.CR
437                                                            + " LINE=" + line;                      // 5.1.8.0 (2010/07/01) errMsg 菫ｮ豁｣
438                                            throw new HybsSystemException( errMsg );
439                                    }
440                            }
441                    }
442                    catch (IOException ex) {
443                            String errMsg = "繝輔ぃ繧､繝ｫ隱ｭ霎ｼ縺ｿ繧ｨ繝ｩ繝ｼ[" + reader.toString() + "]"  ;
444                            throw new HybsSystemException( errMsg,ex );
445                    }
446    
447                    String errMsg = "#NAME 縺瑚ｦ九▽縺九ｊ縺ｾ縺帙ｓ縺ｧ縺励◆縲?;
448                    throw new HybsSystemException( errMsg );
449            }
450    
451            /**
452             * BufferedReader 繧貞叙蠕励＠縺ｾ縺吶?
453             *
454             * 縺薙％縺ｧ縺ｯ縲∽ｸ?握逧?↑繝輔ぃ繧､繝ｫ蜃ｺ蜉帙ｒ閠??縺励◆ BufferedReader 繧剃ｽ懈?縺励∪縺吶?
455             *
456             * @return      謖?ｮ壹?隱ｭ縺ｿ蜿悶ｊ逕ｨBufferedReader繧ｪ繝悶ず繧ｧ繧ｯ繝?
457             */
458            private BufferedReader getBufferedReader() {
459                    if( filename == null ) {
460                            String errMsg = "繝輔ぃ繧､繝ｫ蜷阪′繧ｻ繝?ヨ縺輔ｌ縺ｦ縺?∪縺帙ｓ縲?;
461                            throw new HybsSystemException( errMsg );
462                    }
463                    String directory = HybsSystem.url2dir( fileURL );
464                    File file = new File( StringUtil.urlAppend( directory,filename ) );
465    
466                    BufferedReader out = FileUtil.getBufferedReader( file,encode );
467    
468                    return out ;
469            }
470    
471            /**
472             * 縲慎AG縲?騾壼ｸｸ縺ｯ菴ｿ縺?∪縺帙ｓ)讀懃ｴ｢譎ゅ?DB謗･邯唔D繧呈欠螳壹＠縺ｾ縺?蛻晄悄蛟､:DEFAULT)縲?
473             *
474             * @og.tag
475             *   讀懃ｴ｢譎ゅ?DB謗･邯唔D繧呈欠螳壹＠縺ｾ縺吶?蛻晄悄蛟､縺ｯ縲．EFAULT 縺ｧ縺吶?
476             *
477             * @param       id 繝??繧ｿ繝吶?繧ｹ謗･邯唔D
478             */
479            public void setDbid( final String id ) {
480                    dbid = nval( getRequestParameter( id ),dbid );
481            }
482    
483            /**
484             * 縲慎AG縲大庄螟蛾聞繝輔ぃ繧､繝ｫ繧剃ｽ懈?縺吶ｋ縺ｨ縺阪?鬆?岼蛹ｺ蛻?ｊ譁?ｭ励ｒ繧ｻ繝?ヨ縺励∪縺?蛻晄悄蛟､:繧ｿ繝?縲?
485             *
486             * @og.tag 蜿ｯ螟蛾聞繝輔ぃ繧､繝ｫ繧剃ｽ懈?縺吶ｋ縺ｨ縺阪?鬆?岼蛹ｺ蛻?ｊ譁?ｭ励ｒ繧ｻ繝?ヨ縺励∪縺吶?
487             *
488             * @param   separator 鬆?岼蛹ｺ蛻?ｊ譁?ｭ?
489             */
490            public void setSeparator( final String separator ) {
491                    this.separator = nval( getRequestParameter( separator ),this.separator );
492            }
493    
494            /**
495             * 縲慎AG縲題ｪｭ縺ｿ蜿悶ｊ蜈?ョ繧｣繝ｬ繧ｯ繝医Μ蜷阪ｒ謖?ｮ壹＠縺ｾ縺?
496             *              (蛻晄悄蛟､:FILE_URL[={@og.value org.opengion.hayabusa.common.SystemData#FILE_URL}])縲?
497             *
498             * @og.tag
499             * 縺薙?螻樊?縺ｧ謖?ｮ壹＆繧後ｋ繝?ぅ繝ｬ繧ｯ繝医Μ繧医ｊ縲√ヵ繧｡繧､繝ｫ繧定ｪｭ縺ｿ蜿悶ｊ縺ｾ縺吶?
500             * 謖?ｮ壽婿豕輔?縲??蟶ｸ縺ｮ fileURL 螻樊?縺ｨ蜷梧ｧ倥↓縲∝?鬆ｭ縺後?'/' (UNIX) 縺ｾ縺溘?縲?ｼ呈枚蟄礼岼縺後?
501             * ":" (Windows)縺ｮ蝣ｴ蜷医?縲∵欠螳壹?URL縺昴?縺ｾ縺ｾ縺ｮ繝?ぅ繝ｬ繧ｯ繝医Μ縺ｫ縲√◎縺?〒縺ｪ縺??蜷医?縲?
502             * fileURL = "{&#064;USER.ID}" 縺ｨ謖?ｮ壹☆繧九→縲：ILE_URL 螻樊?縺ｧ謖?ｮ壹?繝輔か繝ｫ繝??荳九↓縲?
503             * 縺輔ｉ縺ｫ縲∝推蛟倶ｺｺID蛻･縺ｮ繝輔か繝ｫ繝??荳九ｈ繧翫?隱ｭ縺ｿ蜿悶ｊ縺ｾ縺吶?
504             * (蛻晄悄蛟､:繧ｷ繧ｹ繝?Β螳壽焚縺ｮFILE_URL[={@og.value org.opengion.hayabusa.common.SystemData#FILE_URL}])縲?
505             *
506             * @og.rev 4.0.0.0 (2005/01/31) StringUtil.urlAppend 繝｡繧ｽ繝?ラ縺ｮ蛻ｩ逕ｨ
507             * @og.rev 4.0.0.0 (2007/11/20) 謖?ｮ壹＆繧後◆繝?ぅ繝ｬ繧ｯ繝医Μ蜷阪?譛?ｾ後′"\"or"/"縺ｧ邨ゅｏ縺｣縺ｦ縺?↑縺??蜷医↓縲?/"繧剃ｻ伜刈縺吶ｋ縲?
508             *
509             * @param       url 繝輔ぃ繧､繝ｫURL
510             * @see         org.opengion.hayabusa.common.SystemData#FILE_URL
511             */
512            public void setFileURL( final String url ) {
513                    String furl = nval( getRequestParameter( url ),null );
514                    if( furl != null ) {
515                            char ch = furl.charAt( furl.length()-1 );
516                            if( ch != '/' && ch != '\\' ) { furl = furl + "/"; }
517                            fileURL = StringUtil.urlAppend( fileURL,furl );
518                    }
519            }
520    
521            /**
522             * 縲慎AG縲代ヵ繧｡繧､繝ｫ繧剃ｽ懈?縺吶ｋ縺ｨ縺阪?繝輔ぃ繧､繝ｫ蜷阪ｒ繧ｻ繝?ヨ縺励∪縺?
523             *              (蛻晄悄蛟､:FILE_FILENAME[={@og.value org.opengion.hayabusa.common.SystemData#FILE_FILENAME}])縲?
524             *
525             * @og.tag
526             * 繝輔ぃ繧､繝ｫ繧剃ｽ懈?縺吶ｋ縺ｨ縺阪?繝輔ぃ繧､繝ｫ蜷阪ｒ繧ｻ繝?ヨ縺励∪縺吶?
527             * (蛻晄悄蛟､:繧ｷ繧ｹ繝?Β螳壽焚縺ｮFILE_FILENAME[={@og.value org.opengion.hayabusa.common.SystemData#FILE_FILENAME}])縲?
528             *
529             * @param   filename 繝輔ぃ繧､繝ｫ蜷?
530             * @see         org.opengion.hayabusa.common.SystemData#FILE_FILENAME
531             */
532            public void setFilename( final String filename ) {
533                    this.filename = nval( getRequestParameter( filename ),this.filename );
534            }
535    
536            /**
537             * 縲慎AG縲代ヵ繧｡繧､繝ｫ繧剃ｽ懈?縺吶ｋ縺ｨ縺阪?繝輔ぃ繧､繝ｫ繧ｨ繝ｳ繧ｳ繝ｼ繝?ぅ繝ｳ繧ｰ蜷阪ｒ繧ｻ繝?ヨ縺励∪縺?
538             *              (蛻晄悄蛟､:FILE_ENCODE[={@og.value org.opengion.hayabusa.common.SystemData#FILE_ENCODE}])縲?
539             *
540             * @og.tag
541             * 蛻晄悄蛟､縺ｯ縲√す繧ｹ繝?Β繝代Λ繝｡繝ｼ繧ｿ 縺ｮ FILE_ENCODE 螻樊?縺ｧ縲∬ｨｭ螳壹＠縺ｦ縺?∪縺吶?
542             * Shift_JIS,MS932,Windows-31J,UTF-8,ISO-8859-1,UnicodeLittle?･?･?･
543             * (蛻晄悄蛟､:繧ｷ繧ｹ繝?Β螳壽焚縺ｮFILE_ENCODE[={@og.value org.opengion.hayabusa.common.SystemData#FILE_ENCODE}])縲?
544             *
545             * @param   enc 繝輔ぃ繧､繝ｫ繧ｨ繝ｳ繧ｳ繝ｼ繝?ぅ繝ｳ繧ｰ蜷?
546             * @see     <a href="http://www.iana.org/assignments/character-sets">IANA Charset Registry</a>
547             * @see         org.opengion.hayabusa.common.SystemData#FILE_ENCODE
548             */
549            public void setEncode( final String enc ) {
550                    encode = nval( getRequestParameter( enc ),encode );
551            }
552    
553            /**
554             * 縲慎AG縲倉uery 縺ｮ邨先棡繧堤判髱｢荳翫↓陦ｨ遉ｺ縺吶ｋ繝｡繝?そ繝ｼ繧ｸID繧呈欠螳壹＠縺ｾ縺?蛻晄悄蛟､:MSG0040[縲?ｻｶ逋ｻ骭ｲ縺励∪縺励◆])縲?
555             *
556             * @og.tag
557             * 縺薙％縺ｧ縺ｯ縲∵､懃ｴ｢邨先棡縺ｮ莉ｶ謨ｰ繧?匳骭ｲ縺輔ｌ縺滉ｻｶ謨ｰ繧偵∪縺壼?蜉帙＠縲?
558             * 縺昴?谺｡縺ｫ縲√％縺薙〒謖?ｮ壹＠縺溘Γ繝?そ繝ｼ繧ｸ繧偵Μ繧ｽ繝ｼ繧ｹ縺九ｉ蜿門ｾ励＠縺ｦ
559             * 陦ｨ遉ｺ縺励∪縺吶?
560             * 陦ｨ遉ｺ縺輔○縺溘￥縺ｪ縺??蜷医?, displayMsg = "" 繧偵そ繝?ヨ縺励※縺上□縺輔＞縲?
561             * 蛻晄悄蛟､縺ｯ縲∵､懃ｴ｢莉ｶ謨ｰ繧定｡ｨ遉ｺ縺励∪縺吶?
562             * 窶ｻ 縺薙?螻樊?縺ｫ縺ｯ縲√Μ繧ｯ繧ｨ繧ｹ繝亥､画焚({&#064;XXXX})縺ｯ菴ｿ逕ｨ縺ｧ縺阪∪縺帙ｓ縲?
563             *
564             * @param   id 繝?ぅ繧ｹ繝励Ξ繧､縺ｫ陦ｨ遉ｺ縺輔○繧九Γ繝?そ繝ｼ繧ｸ ID
565             */
566            public void setDisplayMsg( final String id ) {
567                    if( id != null ) { displayMsg = id; }
568            }
569    
570            /**
571             * 縲慎AG縲?NAME 螻樊?縺ｮ莉｣繧上ｊ縺ｨ縺ｪ繧九ヵ繧｡繧､繝ｫ縺ｮ繧ｫ繝ｩ繝?錐繧?CSV蠖｢蠑上〒謖?ｮ壹＠縺ｾ縺吶?
572             *
573             * @og.tag
574             * 繝??繧ｿ繝輔ぃ繧､繝ｫ縺ｮ蜈磯?陦後↓縲?NAME 陦後′縺ゅｊ縲∬ｪｭ縺ｿ蜿悶ｋ縺ｹ縺阪ヵ繧｡繧､繝ｫ縺ｮ
575             * 繧ｫ繝ｩ繝?錐縺瑚ｨ倩ｿｰ縺輔ｌ縺ｦ縺?∪縺吶?騾壼ｸｸ縺ｯ縲√％縺ｮ繧ｫ繝ｩ繝?錐繧貞叙繧願ｾｼ繧薙〒縲?
576             * 蜷?ョ繝ｼ繧ｿ蛻励?繧ｫ繝ｩ繝?ｒ謖?ｮ壹＠縺ｾ縺吶?
577             * 縺薙?螻樊?縺ｯ縲√ヵ繧｡繧､繝ｫ縺ｫ#NAME 陦後′蟄伜惠縺励↑縺?莉悶す繧ｹ繝?Β縺九ｉ縺ｮ蜈･蜉帙ヵ繧｡繧､繝ｫ遲?
578             * 蝣ｴ蜷医↓縲?NAME 螻樊?縺ｮ莉｣繧上ｊ縺ｫ縲√き繝ｩ繝?錐繧貞､夜Κ繧医ｊ謖?ｮ壹＠縺ｾ縺吶?
579             *
580             * @og.rev 3.8.5.1 (2006/05/08) getCSVParameter 縺ｮ菴ｿ逕ｨ繧剃ｸｭ豁｢
581             *
582             * @param   clms 繝輔ぃ繧､繝ｫ縺ｮ繧ｫ繝ｩ繝?錐(繧ｫ繝ｳ繝槫玄蛻?ｊ譁?ｭ?
583             */
584            public void setColumns( final String clms ) {
585                    columns = StringUtil.csv2Array( nval( getRequestParameter( clms ),null ),',' );
586            }
587    
588            /**
589             * 縲慎AG縲第欠螳壽焚豈弱↓繧ｳ繝溘ャ繝医ｒ逋ｺ陦後＠縺ｾ縺?蛻晄悄蛟､:0 邨ゆｺ?∪縺ｧ繧ｳ繝溘ャ繝医＠縺ｾ縺帙ｓ)縲?
590             *
591             * @og.tag
592             * 騾壼ｸｸ縺ｯ縲∝?縺ｦ縺ｮ蜃ｦ逅?′豁｣蟶ｸ縺ｫ邨ゆｺ?☆繧九°縲√↑縺ｫ繧ゅ＠縺ｪ縺?°(繝医Λ繝ｳ繧ｶ繧ｯ繧ｷ繝ｧ繝ｳ)
593             * 繧貞愛譁ｭ縺吶∋縺阪〒縲??荳ｭ縺ｧ縺ｮ繧ｳ繝溘ャ繝医?縺励∪縺帙ｓ縲?
594             * 縺励°縺励?蝣ｴ蜷医↓繧医▲縺ｦ縲∽ｻｶ謨ｰ縺檎焚蟶ｸ縺ｫ螟壹＞蝣ｴ蜷医ｄ縲∝?螳溯｡悟庄閭ｽ縺ｪ蝣ｴ蜷医?縲?
595             * 騾比ｸｭ縺ｧ繧ｳ繝溘ャ繝医＠縺ｦ縲??蠎ｦ縲∝?逅?〒縺阪ｋ繧ゅ?縺?￠繧貞?逅?＠縺ｦ縺励∪縺?→縺?≧譁ｹ豕輔′縺ゅｊ縺ｾ縺吶?
596             * 縺ｾ縺溘?繝ｭ繝ｼ繝ｫ繝舌ャ繧ｯ繧ｨ繝ｪ繧｢縺ｮ髢｢菫ゅ↑縺ｩ縺ｧ縲√ョ繝ｼ繧ｿ驥上′螟壹＞蝣ｴ蜷医↓縲∝?逅?凾髢薙′逡ｰ蟶ｸ縺ｫ
597             * 髟ｷ縺上↑繧倶ｺ九′縺ゅｊ縲∵欠螳壻ｻｶ謨ｰ縺斐→縺ｮ繧ｳ繝溘ャ繝域ｩ溯?繧堤畑諢上＠縺ｦ縺?∪縺吶?
598             * 0 縺ｫ險ｭ螳壹☆繧九→縲∫ｵゆｺ?∪縺ｧ繧ｳ繝溘ャ繝医＠縺ｾ縺帙ｓ縲ょ?譛溷?縺ｯ縲? 縺ｧ縺吶?
599             *
600             * @param   cmtBat 謖?ｮ壽焚豈弱↓繧ｳ繝溘ャ繝医ｒ逋ｺ陦?蛻晄悄蛟､:0)
601             */
602            public void setCommitBatch( final String cmtBat ) {
603                    commitBatch = nval( getRequestParameter( cmtBat ),commitBatch );
604            }
605    
606            /**
607             * 縲慎AG縲代き繝ｩ繝?メ繧ｧ繝?け(DBType繝√ぉ繝?け)繧定｡後≧縺九←縺?°繧定ｨｭ螳壹＠縺ｾ縺?蛻晄悄蛟､:false)縲?
608             *
609             * @og.tag
610             * 繧ｫ繝ｩ繝??謨ｴ蜷域?繝√ぉ繝?け繧定｡後≧蝣ｴ蜷医?縺薙?螻樊?繧定ｨｭ螳?true)縺励∪縺吶?
611             * 蛻晄悄蛟､縺ｯ縲∬｡後ｏ縺ｪ縺?false)縺ｧ縺吶?
612             * 繝√ぉ繝?け縺吶ｋ繧ｫ繝ｩ繝??縲?NAME 繧?columns 縺ｧ謖?ｮ壹＆繧後◆繧ｫ繝ｩ繝?〒縺ｯ縺ｪ縺上?
613             * BODY驛ｨ縺ｮSQL譁?〒謖?ｮ壹＆繧後◆繧ｫ繝ｩ繝?錐( [繧ｫ繝ｩ繝?錐] )縺ｧ縺吶?縺薙ｌ縺ｯ縲∫峩謗･縲ヾQL譁?ｸｭ縺ｫ
614             * 險倩ｿｰ縺励※縺?ｋ蛟､繧??{&#064;XXXX}譁?ｭ礼ｭ峨?縲√メ繧ｧ繝?け蜃ｺ譚･縺ｪ縺?ぜ縺ｧ縺吶?
615             *
616             * @og.rev 3.6.0.2 (2004/10/04) 譁ｰ隕剰ｿｽ蜉?蜿悶ｊ霎ｼ縺ｿ譎ょ?繝√ぉ繝?け
617             *
618             * @param   flag 繝√ぉ繝?け繧定｡後≧縺九←縺?°(true:陦後≧/false:陦後ｏ縺ｪ縺?
619             * @see     #setUseColumnAdjust( String )
620             */
621            public void setUseColumnCheck( final String flag ) {
622                    useColumnCheck = nval( getRequestParameter( flag ),useColumnCheck );
623            }
624    
625            /**
626             * 縲慎AG縲代き繝ｩ繝?､画鋤(DBType螟画鋤)繧定｡後≧縺九←縺?°繧定ｨｭ螳壹＠縺ｾ縺?蛻晄悄蛟､:false)縲?
627             *
628             * @og.tag
629             * 繧ｫ繝ｩ繝??螟画鋤繧定｡後≧蝣ｴ蜷医?縺薙?螻樊?繧定ｨｭ螳?true)縺励∪縺吶?
630             * 蛻晄悄蛟､縺ｯ縲∬｡後ｏ縺ｪ縺?false)縺ｧ縺吶?
631             * 螟画鋤縺吶ｋ繧ｫ繝ｩ繝??縲?NAME 繧?columns 縺ｧ謖?ｮ壹＆繧後◆繧ｫ繝ｩ繝?〒縺ｯ縺ｪ縺上?
632             * BODY驛ｨ縺ｮSQL譁?〒謖?ｮ壹＆繧後◆繧ｫ繝ｩ繝?錐[繧ｫ繝ｩ繝?錐]縺ｧ縺吶?縺薙ｌ縺ｯ縲∫峩謗･縲ヾQL譁?ｸｭ縺ｫ
633             * 險倩ｿｰ縺励※縺?ｋ蛟､繧??{&#064;XXXX}譁?ｭ礼ｭ峨?縲∝､画鋤蜃ｺ譚･縺ｪ縺?ぜ縺ｧ縺吶?
634             *
635             * @og.rev 3.6.0.2 (2004/10/04) 譁ｰ隕剰ｿｽ蜉?蜿悶ｊ霎ｼ縺ｿ譎ょ､画鋤
636             *
637             * @param   flag 螟画鋤繧定｡後≧縺九←縺?°(true:陦後≧/false:陦後ｏ縺ｪ縺?
638             * @see     #setUseColumnCheck( String )
639             */
640            public void setUseColumnAdjust( final String flag ) {
641                    useColumnAdjust = nval( getRequestParameter( flag ),useColumnAdjust );
642            }
643    
644            /**
645             * 縲慎AG縲鮮ULL 繝√ぉ繝?け縺吶∋縺阪き繝ｩ繝??繧偵き繝ｳ繝槫玄蛻?ｊ(CSV蠖｢蠑?縺ｧ謖?ｮ壹＠縺ｾ縺吶?
646             *
647             * @og.tag nullCheck="AAA,BBB,CCC,DDD"
648             * 蛻?ｧ｣譁ｹ豕輔?縲??蟶ｸ縺ｮ繝代Λ繝｡繝ｼ繧ｿ蜿門ｾ怜ｾ後↓縲，SV蛻?ｧ｣縺励∪縺吶?
649             *
650             * @og.rev 3.8.0.2 (2005/06/30) 譁ｰ隕剰ｿｽ蜉?
651             * @og.rev 3.8.8.5 (2007/03/09) 騾壼ｸｸ縺ｮ繝代Λ繝｡繝ｼ繧ｿ蜿門ｾ怜ｾ後↓縲，SV蛻?ｧ｣縺ｫ謌ｻ縺励∪縺吶?
652             *
653             * @param   clms 繧ｫ繝ｩ繝??(CSV蠖｢蠑?
654             */
655            public void setNullCheck( final String clms ) {
656                    nullCheck = StringUtil.csv2Array( getRequestParameter( clms ) );
657                    if( nullCheck.length == 0 ) { nullCheck = null; }
658            }
659            
660            /**
661             * 縲慎AG縲大叙繧願ｾｼ縺ｿ譎ゅ↓髯､螟悶☆繧玖｡後ｒ謖?ｮ壹＠縺ｾ縺?蛻晄悄蛟､:0)縲?
662             *
663             * @og.tag
664             * TAB蛹ｺ蛻?ｊ繝?く繧ｹ繝医ｄEXCEL遲峨?繝??繧ｿ縺ｮ隱ｭ縺ｿ蟋九ａ縺ｮ蛻晄悄蛟､繧呈欠螳壹＠縺ｾ縺吶?
665             * 繝輔ぃ繧､繝ｫ縺ｮ蜈磯?陦後′縲?ｼ占｡後→縺励※繧ｫ繧ｦ繝ｳ繝医＠縺ｾ縺吶?縺ｧ縲∬ｨｭ螳壼?縺ｯ縲∬ｪｭ縺ｿ鬟帙?縺?
666             * 莉ｶ謨ｰ縺ｫ縺ｪ繧翫∪縺吶?(?代→謖?ｮ壹☆繧九→縲?ｼ台ｻｶ隱ｭ縺ｿ鬟帙?縺励??定｡檎岼縺九ｉ隱ｭ縺ｿ霎ｼ縺ｿ縺ｾ縺吶?)
667             * 隱ｭ縺ｿ鬟帙?縺励?縲√さ繝｡繝ｳ繝郁｡後↑縺ｩ縺ｯ縲∫┌隕悶＠縺ｾ縺吶?縺ｧ縲∝ｮ滄圀縺ｮ陦梧焚蛻?ｪｭ縺ｿ鬟帙?縺励∪縺吶?
668             * ?クAME螻樊?繧??columns 螻樊?縺ｯ縲∵怏蜉ｹ縺ｧ縺吶?
669             *
670             * @og.rev 5.5.7.1 (2012/10/05) 譁ｰ隕剰ｿｽ蜉?
671             *
672             * @param   count 蜈磯?陦後ｒ辟｡隕悶☆繧九°縺ｩ縺?°(true:辟｡隕悶☆繧?false:辟｡隕悶＠縺ｪ縺?
673             */
674            public void setSkipRowCount( final String count ) {
675                    skipRowCount = nval( getRequestParameter( count ),skipRowCount );
676            }
677    
678            /**
679             * 縲慎AG縲第､懃ｴ｢邨先棡縺鯉ｼ蝉ｻｶ縺ｮ縺ｨ縺榊?逅?ｒ邯夊｡後☆繧九°縺ｩ縺?°[true/false]繧呈欠螳壹＠縺ｾ縺?蛻晄悄蛟､:false[邯夊｡後☆繧犠)縲?
680             *
681             * @og.tag
682             * 蛻晄悄蛟､縺ｯ縲’alse(邯夊｡後☆繧?縺ｧ縺吶?
683             *
684             * @og.rev 5.7.6.2 (2014/05/16) 譁ｰ隕剰ｿｽ蜉?
685             *
686             * @param  cmd 讀懃ｴ｢邨先棡縺鯉ｼ蝉ｻｶ縺ｮ縺ｨ縺阪?[true:蜃ｦ逅?ｒ荳ｭ豁｢縺吶ｋ/false:邯夊｡後☆繧犠
687             */
688            public void setStopZero( final String cmd ) {
689                    stopZero = nval( getRequestParameter( cmd ),stopZero );
690            }
691    
692            /**
693             * 繧ｫ繝ｩ繝?､画鋤縲√き繝ｩ繝?メ繧ｧ繝?け繧定｡後≧蜀?Κ繧ｯ繝ｩ繧ｹ
694             *
695             * @og.rev 4.0.0.0 (2005/01/31) static 繧ｯ繝ｩ繧ｹ蛹悶?蠑墓焚縺ｫResourceManager霑ｽ蜉?
696             * @og.group 繝輔ぃ繧､繝ｫ蜈･蜉?
697             *
698             * @version  4.0
699             * @author   Kazuhiko Hasegawa
700             * @since    JDK5.0,
701             */
702            static class CheckColumnData {
703                    private final DBColumn[] dbClm    ;
704                    private final int[]      clmChkNo ;
705                    private final int        len      ;             // 髟ｷ縺包ｼ舌?譎ゅ?縲√↑縺ｫ繧ゅ＠縺ｪ縺??
706                    private final ErrorMessage errMsg = new ErrorMessage( "Check Columns Error!" );
707    
708                    /**
709                     * 繧ｳ繝ｳ繧ｹ繝医Λ繧ｯ繧ｿ繝ｼ
710                     *
711                     * @param       clmNo   繧ｫ繝ｩ繝?分蜿ｷ驟榊?
712                     * @param chkClm String[]
713                     * @param resource ResourceManager
714                     */
715                    CheckColumnData( final int[] clmNo, final String[] chkClm,final ResourceManager resource ) {
716                            if( clmNo  == null || clmNo.length  == 0 ||
717                                    chkClm == null || chkClm.length == 0 ) { // return; }   // 菴輔ｂ縺励↑縺?
718    
719                                    dbClm    = null;
720                                    clmChkNo = null;
721                                    len      = 0;
722                            }
723                            else {
724                                    clmChkNo = clmNo ;
725                                    len = clmNo.length ;
726                                    dbClm = new DBColumn[len];
727                                    for( int i=0; i<len; i++ ) {
728                                            dbClm[i] = resource.makeDBColumn( chkClm[i] );  // 4.0.0 (2005/01/31)
729                                    }
730                            }
731                    }
732    
733                    /**
734                     * 蠑墓焚縺ｮ繝??繧ｿ繧?DBColumn 縺ｧ豁｣隕丞喧(valueSet繝｡繧ｽ繝?ラ邨檎罰)縺励∪縺吶?
735                     *
736                     * @param       data    ?題｡悟?縺ｮ繝??繧ｿ驟榊?
737                     * @return String[]
738                     * @see org.opengion.hayabusa.db.DBColumn#valueSet( String )
739                     */
740                    String[] adjustData( final String[] data ) {
741                            if( len == 0 ) { return data; }
742                            String[] ajstData = new String[len];
743                            for( int i=0; i<len; i++ ) {
744                                    String val = data[clmChkNo[i]];
745                                    ajstData[i] = dbClm[i].valueSet( val );
746                            }
747                            return ajstData ;
748                    }
749    
750                    /**
751                     * 蠑墓焚縺ｮ繝??繧ｿ繧?DBColumn 縺ｧ豁｣隕丞喧(valueSet繝｡繧ｽ繝?ラ邨檎罰)縺励∪縺吶?
752                     *
753                     * @param       row     陦檎分蜿ｷ
754                     * @param       data    ?題｡悟?縺ｮ繝??繧ｿ驟榊?
755                     * @return ErrorMessage
756                     * @see org.opengion.hayabusa.db.DBColumn#valueSet( String )
757                     */
758                    ErrorMessage checkData( final int row,final String[] data ) {
759                            for( int i=0; i<len; i++ ) {
760                                    String val = data[clmChkNo[i]];
761                                    errMsg.append( row+1,dbClm[i].valueCheck( val ) );
762                            }
763                            return errMsg ;
764                    }
765            }
766    
767            /**
768             * 縺薙?繧ｪ繝悶ず繧ｧ繧ｯ繝医?譁?ｭ怜?陦ｨ迴ｾ繧定ｿ斐＠縺ｾ縺吶?
769             * 蝓ｺ譛ｬ逧?↓繝?ヰ繝?げ逶ｮ逧?↓菴ｿ逕ｨ縺励∪縺吶?
770             *
771             * @return 縺薙?繧ｯ繝ｩ繧ｹ縺ｮ譁?ｭ怜?陦ｨ迴ｾ
772             */
773            @Override
774            public String toString() {
775                    return org.opengion.fukurou.util.ToString.title( this.getClass().getName() )
776                                    .println( "VERSION"                     ,VERSION                )
777                                    .println( "dbid"                        ,dbid                   )
778                                    .println( "separator"           ,separator              )
779                                    .println( "fileURL"                     ,fileURL                )
780                                    .println( "filename"            ,filename               )
781                                    .println( "encode"                      ,encode                 )
782                                    .println( "displayMsg"          ,displayMsg             )
783                                    .println( "columns"                     ,columns                )
784                                    .println( "clmKeys"                     ,clmKeys                )
785                                    .println( "sql"                         ,sql                    )
786                                    .println( "commitBatch"         ,commitBatch    )
787                                    .println( "useColumnCheck"      ,useColumnCheck )
788                                    .println( "useColumnAdjust"     ,useColumnAdjust)
789                                    .println( "nullCheck"           ,nullCheck              )
790                                    .println( "dyStart"                     ,dyStart                )
791                                    .println( "Other..."            ,getAttributes().getAttribute() )
792                                    .fixForm().toString() ;
793            }
794    }