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.fukurou.transfer;
017    
018    import java.io.BufferedReader;
019    import java.io.File;
020    import java.util.ArrayList;
021    import java.util.List;
022    
023    import org.opengion.fukurou.db.Transaction;
024    import org.opengion.fukurou.util.ApplicationInfo;
025    import org.opengion.fukurou.util.Closer;
026    import org.opengion.fukurou.util.FileUtil;
027    import org.opengion.fukurou.util.LogWriter;
028    import org.opengion.fukurou.util.StringUtil;
029    
030    /**
031     * 莨晞?隕∵ｱゅ↓蟇ｾ縺励※縲√ユ繧ｭ繧ｹ繝医ヵ繧｡繧､繝ｫ縺九ｉ繝??繧ｿ繧定ｪｭ蜿悶＠縺ｾ縺吶?
032     * 菴?＠縲∬ｪｭ蜿悶＆繧後ｋ繝??繧ｿ縺ｫ縺､縺?※縺ｯ縲∵立莨晞?繧ｷ繧ｹ繝?Β縺ｮ蠖｢蠑上→莠呈鋤諤ｧ繧呈戟縺溘○繧九◆繧√?
033     * 31Byte縺九ｉ430Byte縺ｾ縺ｧ縺ｮ400Byte繧貞叙蠕励＠縺ｾ縺吶?
034     *
035     * 隱ｭ蜿悶☆繧九ヵ繧｡繧､繝ｫ蜷阪?縲∬ｪｭ蜿門ｯｾ雎｡縺ｧ謖?ｮ壹＠縺ｾ縺吶?
036     * 繝輔ぃ繧､繝ｫ蜷阪?邨ｶ蟇ｾ繝代せ縺ｧ謖?ｮ壹☆繧句ｿ?ｦ√′縺ゅｊ縺ｾ縺吶?
037     *
038     * 隱ｭ霎ｼ蜿翫?縺昴?蠕後?螳溯｡悟?逅?′豁｣蟶ｸ邨ゆｺ?＠縺溷?蜷医?縲∬ｪｭ蜿悶ヵ繧｡繧､繝ｫ縺ｯ蜑企勁縺輔ｌ縺ｾ縺吶?
039     * 菴?＠縲∬ｪｭ蜿悶ヱ繝ｩ繝｡繝ｼ繧ｿ繝ｼ縺ｫ"UNDEL"縺ｨ縺?≧譁?ｭ励ｒ險ｭ螳壹＠縺溷?蜷医?縲∵ｭ｣蟶ｸ邨ゆｺ?＠縺溷?蜷医〒繧?
040     * 繝輔ぃ繧､繝ｫ縺ｯ蜑企勁縺輔ｌ縺ｾ縺帙ｓ縲?
041     *
042     * 縺ｾ縺溘?隱ｭ蜿悶☆繧九ユ繧ｭ繧ｹ繝医ヵ繧｡繧､繝ｫ縺ｮ繧ｨ繝ｳ繧ｳ繝ｼ繝峨?隱ｭ蜿悶ヱ繝ｩ繝｡繝ｼ繧ｿ繝ｼ縺梧欠螳壹☆繧九％縺ｨ縺後〒縺阪∪縺吶?
043     * 謖?ｮ壹＠縺ｪ縺??蜷医?繧ｷ繧ｹ繝?Β繝ｪ繧ｽ繝ｼ繧ｹ縺ｮ"DB_ENCODE"縺ｧ謖?ｮ壹＆繧後◆蛟､縺碁←逕ｨ縺輔ｌ縺ｾ縺吶?
044     *
045     * @og.group 莨晞?繧ｷ繧ｹ繝?Β
046     *
047     * @version  5.0
048     * @author   Hiroki.Nakamura
049     * @since    JDK1.6
050     */
051    public class TransferRead_SAMCB implements TransferRead {
052    
053            // 隱ｭ蜿悶ヵ繧｡繧､繝ｫ繧ｪ繝悶ず繧ｧ繧ｯ繝?
054            private String fileName = null;
055    
056            // 隱ｭ蜿悶ヵ繧｡繧､繝ｫ縺ｮ繧ｨ繝ｳ繧ｳ繝ｼ繝?
057    //      private String fileEncode = null;               // 5.5.2.4 (2012/05/16) 繝ｭ繝ｼ繧ｫ繝ｫ螟画焚蛹?
058    
059            // 螳御ｺ?凾縺ｫ隱ｭ蜿悶ヵ繧｡繧､繝ｫ繧貞炎髯､縺吶ｋ縺九←縺?°
060            private boolean fileDel = true;
061    
062            /**
063             * 繝輔ぃ繧､繝ｫ縺九ｉ繝??繧ｿ繧定ｪｭ縺ｿ蜿悶ｊ縺ｾ縺吶?
064             *
065             * @param config 莨晞?險ｭ螳壹が繝悶ず繧ｧ繧ｯ繝?
066             * @param tran 繝医Λ繝ｳ繧ｶ繧ｯ繧ｷ繝ｧ繝ｳ繧ｪ繝悶ず繧ｧ繧ｯ繝?
067             *
068             * @return 隱ｭ縺ｿ蜿悶ｊ縺励◆繝??繧ｿ(驟榊?)
069             */
070            @Override
071            public String[] read( final TransferConfig config, final Transaction tran ) {
072                    fileName = config.getReadObj();
073                    File fileRead = new File( fileName );
074                    if( !fileRead.exists() ) { return new String[0]; }
075    
076                    String readPrm = config.getReadPrm();
077                    if( readPrm != null && readPrm.indexOf( "UNDEL" ) >= 0 ) {
078                            fileDel = false;
079                            readPrm = readPrm.replace( "UNDEL", "" ).trim();
080                    }
081                    String fileEncode = readPrm;
082                    if( fileEncode == null || fileEncode.length() == 0 ) {
083                            fileEncode = "UTF-8";
084                    }
085    
086                    List<String> valList = new ArrayList<String>();
087                    BufferedReader reader = FileUtil.getBufferedReader( fileRead, fileEncode );
088                    String line = null;
089                    try {
090                            while( ( line = reader.readLine() ) != null ) {
091                                    line = StringUtil.stringFill( line, 500, fileEncode );
092                                    byte[] bytes = StringUtil.makeByte( line, fileEncode );
093                                    line = StringUtil.makeString( bytes, 30, 400, fileEncode );
094                                    valList.add( line );
095                            }
096                    }
097                    catch( Throwable ex ) {
098                            LogWriter.log( ex );
099                            String errMsg = "繝輔ぃ繧､繝ｫ隱ｭ蜿匁凾縺ｫ繧ｨ繝ｩ繝ｼ縺檎匱逕溘＠縺ｾ縺励◆縲?LINE=" + line + "]";
100                            throw new RuntimeException( errMsg, ex );
101                    }
102                    finally {
103                            Closer.ioClose( reader );
104                    }
105    
106    //              return valList.toArray( new String[0] );
107                    return valList.toArray( new String[valList.size()] );
108            }
109    
110            /**
111             * 譖ｴ譁ｰ(蜑企勁)蟇ｾ雎｡縺ｮ繝輔ぃ繧､繝ｫ蜷?驟榊?)繧定ｿ斐＠縺ｾ縺吶?
112             *
113             * @return 繝輔ぃ繧､繝ｫ蜷?驟榊?)
114             */
115            @Override
116            public String[] getKeys() {
117    //              String[] rtn = { fileName };
118    //              return rtn;
119                    return new String[] { fileName };               // 5.5.2.4 (2012/05/16)
120            }
121    
122            /**
123             * 譖ｴ譁ｰ(蜑企勁)蟇ｾ雎｡縺ｮ繝輔ぃ繧､繝ｫ蜷阪ｒ繧ｻ繝?ヨ縺励∪縺吶?
124             *
125             * @param keys 繝輔ぃ繧､繝ｫ蜷?驟榊?)
126             */
127            @Override
128            public void setKeys( final String[] keys ) {
129                    if( keys == null || keys.length == 0 ) { return; }
130                    fileName = keys[0];
131            }
132    
133            /**
134             * 隱ｭ蜿悶＠縺溘ョ繝ｼ繧ｿ縺ｫ蟇ｾ縺励※螳御ｺ??逅?ｒ陦後＞縺ｾ縺吶?
135             * 蜈ｷ菴鍋噪縺ｫ縺ｯ縲∬ｪｭ蜿悶＠縺溘ユ繧ｭ繧ｹ繝医ヵ繧｡繧､繝ｫ繧貞炎髯､縺励∪縺吶?
136             *
137             * @param config 莨晞?險ｭ螳壹が繝悶ず繧ｧ繧ｯ繝?
138             * @param tran 繝医Λ繝ｳ繧ｶ繧ｯ繧ｷ繝ｧ繝ｳ繧ｪ繝悶ず繧ｧ繧ｯ繝?
139             */
140            @Override
141            public void complete( final TransferConfig config, final Transaction tran ) {
142                    if( !fileDel ) { return; }
143    
144                    File fileRead = new File( fileName );
145                    if( !fileRead.exists() ) {
146                            return;
147    //                      String errMsg = "繝輔ぃ繧､繝ｫ縺悟ｭ伜惠縺励∪縺帙ｓ縲?FILE=" + fileRead.getAbsolutePath() + "]";
148    //                      throw new RuntimeException( errMsg );
149                    }
150    
151                    boolean rtn = fileRead.delete();
152                    if( !rtn ) {
153                            String errMsg = "繝輔ぃ繧､繝ｫ縺ｮ蜑企勁縺ｫ螟ｱ謨励＠縺ｾ縺励◆縲?FILE=" + fileRead.getAbsolutePath() + "]";
154                            throw new RuntimeException( errMsg );
155                    }
156            }
157    
158            /**
159             * 隱ｭ蜿悶＠縺溘ョ繝ｼ繧ｿ縺ｫ蟇ｾ縺励※繧ｨ繝ｩ繝ｼ蜃ｦ逅?ｒ陦後＞縺ｾ縺吶?
160             * (縺薙％縺ｧ縺ｯ菴輔ｂ蜃ｦ逅?＠縺ｾ縺帙ｓ)
161             *
162             * @param config 莨晞?險ｭ螳壹が繝悶ず繧ｧ繧ｯ繝?
163             * @param appInfo DB謗･邯壽ュ蝣ｱ
164             */
165            @Override
166            public void error( final TransferConfig config, final ApplicationInfo appInfo ) {
167            }
168    }