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.File;
019    import java.util.ArrayList;
020    import java.util.List;
021    
022    import org.opengion.fukurou.db.Transaction;
023    import org.opengion.fukurou.util.ApplicationInfo;
024    import org.opengion.fukurou.util.FileUtil;
025    
026    /**
027     * 莨晞?隕∵ｱゅ↓蟇ｾ縺励※縲√ヵ繧｡繧､繝ｫ縺ｾ縺溘?繝?ぅ繝ｬ繧ｯ繝医Μ繧偵せ繧ｭ繝｣繝ｳ縺励?縺昴ｌ縺ｫ蜷ｫ縺ｾ繧後ｋ
028     * 繝輔ぃ繧､繝ｫ縺ｮ邨ｶ蟇ｾ繝代せ縺ｮ繝ｪ繧ｹ繝医ｒ蜿門ｾ励＠縺ｾ縺吶?
029     *
030     * 莨晞?螳夂ｾｩ繝槭せ繧ｿ縺ｮ隱ｭ蜿門ｯｾ雎｡縺ｯ縲√せ繧ｭ繝｣繝ｳ蟇ｾ雎｡縺ｮ繝輔ぃ繧､繝ｫ縺ｾ縺溘?繝?ぅ繝ｬ繧ｯ繝医Μ繧呈欠螳壹＠縺ｾ縺吶?
031     * 蜃ｦ逅?ｮ溯｡悟ｾ後?縲∵ｭ｣蟶ｸ邨ゆｺ?＠縺溷?蜷医?縲√せ繧ｭ繝｣繝ｳ縺励◆繝輔ぃ繧､繝ｫ繧貞炎髯､縺励∪縺吶?
032     * 菴?＠縲∬ｪｭ蜿悶ヱ繝ｩ繝｡繝ｼ繧ｿ繝ｼ縺ｫ"NODEL"繧呈欠螳壹＠縺溷?蜷医?繝輔ぃ繧､繝ｫ縺ｮ蜑企勁縺ｯ陦後ｏ繧後∪縺帙ｓ縲?
033     * 縺ｾ縺溘?繧ｨ繝ｩ繝ｼ縺檎匱逕溘＠縺溷?蜷医?隱ｭ蜿悶ヱ繝ｩ繝｡繝ｼ繧ｿ繝ｼ縺ｮ險ｭ螳壹↓髢｢繧上ｉ縺壹ヵ繧｡繧､繝ｫ縺ｮ蜑企勁縺ｯ
034     * 陦後ｏ繧後∪縺帙ｓ縲?
035     *
036     * 隱ｭ蜿門ｯｾ雎｡縺ｫ繝?ぅ繝ｬ繧ｯ繝医Μ繧呈欠螳壹＠縺溷?蜷医?縲∝?襍ｷ逧?↓繧ｵ繝悶ヵ繧ｩ繝ｫ繝?ｂ繧ｹ繧ｭ繝｣繝ｳ縺輔ｌ縺ｾ縺吶?
037     *
038     * @og.group 莨晞?繧ｷ繧ｹ繝?Β
039     *
040     * @version  5.0
041     * @author   Hiroki.Nakamura
042     * @since    JDK1.6
043     */
044    public class TransferRead_FILELIST implements TransferRead {
045    
046            // 譖ｴ譁ｰ(蜑企勁)蟇ｾ雎｡縺ｮ繝輔ぃ繧､繝ｫ蜷?驟榊?)
047            private String[] fileNames = null;
048    
049            /**
050             * 繝輔ぃ繧､繝ｫ縺ｾ縺溘?繝?ぅ繝ｬ繧ｯ繝医Μ繧偵せ繧ｭ繝｣繝ｳ縺励ヵ繧｡繧､繝ｫ縺ｮ邨ｶ蟇ｾ繝代せ縺ｮ繝ｪ繧ｹ繝医ｒ蜿門ｾ励＠縺ｾ縺吶?
051             *
052             * @og.rev 5.4.3.2 (2011/12/06) 繧ｳ繝斐?荳ｭ縺ｮ繝輔ぃ繧､繝ｫ蛻､螳夊ｿｽ蜉?
053             * @og.rev 5.5.2.4 (2012/05/16) 驟榊?繧定ｿ斐☆蝣ｴ蜷医?縲∝?驛ｨ陦ｨ迴ｾ繧呈垓髴ｲ縺励↑縺?ｈ縺?↓縲…lone 繧定ｿ斐＠縺ｾ縺吶?
054             *
055             * @param config 莨晞?險ｭ螳壹が繝悶ず繧ｧ繧ｯ繝?
056             * @param tran 繝医Λ繝ｳ繧ｶ繧ｯ繧ｷ繝ｧ繝ｳ繧ｪ繝悶ず繧ｧ繧ｯ繝?
057             *
058             * @return 繝輔ぃ繧､繝ｫ荳?ｦｧ(驟榊?)
059             */
060            @Override
061            public String[] read( final TransferConfig config, final Transaction tran ) {
062                    File file = new File( config.getReadObj() );
063                    if( !file.exists() ) {
064                            String errMsg = "繧ｹ繧ｭ繝｣繝ｳ蟇ｾ雎｡縺ｮ繝輔ぃ繧､繝ｫ/繝?ぅ繝ｬ繧ｯ繝医Μ縲?FILE=" + file.getAbsolutePath() + "]";
065                            throw new RuntimeException( errMsg );
066                    }
067    
068                    List<String> list = new ArrayList<String>();
069                    FileUtil.getFileList( file, false, list , false); // 5.4.3.2 繧ｳ繝斐?蛻､螳夊ｿｽ蜉?
070    
071    //              fileNames = list.toArray( new String[0] );
072                    fileNames = list.toArray( new String[list.size()] );
073    
074    //              return fileNames;
075                    return fileNames.clone();
076            }
077    
078            /**
079             * 譖ｴ譁ｰ(蜑企勁)蟇ｾ雎｡縺ｮ繝輔ぃ繧､繝ｫ蜷?驟榊?)繧定ｿ斐＠縺ｾ縺吶?
080             *
081             * @og.rev 5.5.2.4 (2012/05/16) 驟榊?繧定ｿ斐☆蝣ｴ蜷医?縲∝?驛ｨ陦ｨ迴ｾ繧呈垓髴ｲ縺励↑縺?ｈ縺?↓縲…lone 繧定ｿ斐＠縺ｾ縺吶?
082             *
083             * @return 繝輔ぃ繧､繝ｫ蜷?驟榊?)
084             */
085            public String[] getKeys() {
086    //              return fileNames;
087                    String[] rtn = null ;
088                    if( fileNames != null ) { rtn = fileNames.clone(); }
089                    return rtn ;
090            }
091    
092            /**
093             * 譖ｴ譁ｰ(蜑企勁)蟇ｾ雎｡縺ｮ繝輔ぃ繧､繝ｫ蜷?驟榊?)繧偵そ繝?ヨ縺励∪縺吶?
094             *
095             * @og.rev 5.5.2.4 (2012/05/16) 蜿ら?縺ｮ譬ｼ邏阪↓縺ｯ縲ヾystem.arraycopy 繧剃ｽｿ縺?∪縺吶?
096             *
097             * @param keys 繝輔ぃ繧､繝ｫ蜷?驟榊?)
098             */
099            public void setKeys( final String[] keys ) {
100    //              fileNames = keys;
101                    if( keys != null ) {
102                            int size = keys.length ;
103                            fileNames = new String[size];
104                            System.arraycopy( keys,0,fileNames,0,size );
105                    }
106                    else {
107                            fileNames = null;
108                    }
109            }
110    
111            /**
112             * 隱ｭ蜿悶＠縺滉ｼ晞?繝??繧ｿ縺ｮ繝倥ャ繝??繝??繧ｿ縺ｮ迥ｶ豕√ｒ'2'(謚懷?貂医∩)縺ｫ譖ｴ譁ｰ縺励∪縺吶?
113             * 譖ｴ譁ｰ蟇ｾ雎｡縺ｮ騾夂分NO縺ｫ縺､縺?※縺ｯ縲＋@link #setKeys(String[])}縺ｧ螟夜Κ縺九ｉ繧ｻ繝?ヨ縺吶ｋ縺薙→繧ゅ〒縺阪∪縺吶?
114             *
115             * @param config 莨晞?險ｭ螳壹が繝悶ず繧ｧ繧ｯ繝?
116             * @param tran 繝医Λ繝ｳ繧ｶ繧ｯ繧ｷ繝ｧ繝ｳ繧ｪ繝悶ず繧ｧ繧ｯ繝?
117             * @see #setKeys(String[])
118             */
119            @Override
120            public void complete( final TransferConfig config, final Transaction tran ) {
121                    if( fileNames == null || fileNames.length == 0 ) { return; }
122                    // 隱ｭ蜿悶ヱ繝ｩ繝｡繝ｼ繧ｿ繝ｼ縺ｫ"NODEL"縺梧欠螳壹＆繧後※縺?ｋ蝣ｴ蜷医?縲√せ繧ｭ繝｣繝ｳ縺励◆繝輔ぃ繧､繝ｫ繧貞炎髯､縺励↑縺??
123                    if( "NODEL".equalsIgnoreCase( config.getReadPrm() ) ) { return; }
124    
125                    for( String fileName : fileNames ) {
126                            File file = new File( fileName );
127                            if( !file.exists() ) {
128                                    String errMsg = "繝輔ぃ繧､繝ｫ縺悟ｭ伜惠縺励∪縺帙ｓ縲?FILE=" + file.getAbsolutePath() + "]";
129                                    throw new RuntimeException( errMsg );
130                            }
131    
132                            boolean rtn = file.delete();
133                            if( !rtn ) {
134                                    String errMsg = "繝輔ぃ繧､繝ｫ縺ｮ蜑企勁縺ｫ螟ｱ謨励＠縺ｾ縺励◆縲?FILE=" + file.getAbsolutePath() + "]";
135                                    throw new RuntimeException( errMsg );
136                            }
137                    }
138            }
139    
140            /**
141             * (縺薙％縺ｧ縺ｯ菴輔ｂ縺励∪縺帙ｓ)
142             *
143             * @param config 莨晞?險ｭ螳壹が繝悶ず繧ｧ繧ｯ繝?
144             * @param appInfo DB謗･邯壽ュ蝣ｱ
145             */
146            @Override
147            public void error( final TransferConfig config, final ApplicationInfo appInfo ) {
148            }
149    }