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.io.PrintWriter;
020    
021    import org.opengion.fukurou.db.Transaction;
022    import org.opengion.fukurou.util.FileUtil;
023    import org.opengion.fukurou.util.StringUtil;
024    
025    /**
026     * 莨晞?隕∵ｱゅ↓蟇ｾ縺励※縺ｮ繝??繧ｿ繧偵ヵ繧｡繧､繝ｫ縺ｫ譖ｸ霎ｼ縺ｿ縺励∪縺吶?
027     * 菴?＠縲∵嶌縺崎ｾｼ縺ｾ繧後ｋ繝??繧ｿ縺ｫ縺､縺?※縺ｯ縲∵立莨晞?繧ｷ繧ｹ繝?Β縺ｮ蠖｢蠑上→莠呈鋤諤ｧ繧呈戟縺溘○繧九◆繧√?
028     * 繝??繧ｿ縺ｮ蜑?0Byte縺ｫ遨ｺ逋ｽ縺ｧ蝓九ａ縲√＆繧峨↓蜈ｨ菴薙〒讓呎ｺ悶〒縺ｯ500Byte縺ｫ縺ｪ繧九ｈ縺?↓陦梧忰縺ｫ繧らｩｺ逋ｽ蝓九ａ繧偵＠縺ｾ縺吶?
029     * 500byte莉･螟悶↓縺励◆縺??蜷医?縲∵嶌縺崎ｾｼ縺ｿ繝代Λ繝｡繝ｼ繧ｿ縺ｮ隨ｬ?貞ｼ墓焚縺ｫ謨ｴ謨ｰ縺ｧ謖?ｮ壹＠縺ｦ縺上□縺輔＞縲?
030     *
031     * 譖ｸ霎ｼ縺ｿ縺吶ｋ繝輔ぃ繧､繝ｫ蜷阪?縲∝ｮ溯｡悟ｯｾ雎｡縺ｧ謖?ｮ壹＠縺ｾ縺吶?繝輔ぃ繧､繝ｫ蜷阪?邨ｶ蟇ｾ繝代せ縺ｧ謖?ｮ壹＠縺ｦ荳九＆縺??
032     * 縺ｾ縺溘?譖ｸ霎ｼ縺吶ｋ繝?く繧ｹ繝医ヵ繧｡繧､繝ｫ縺ｮ繧ｨ繝ｳ繧ｳ繝ｼ繝峨?譖ｸ霎ｼ繝代Λ繝｡繝ｼ繧ｿ繝ｼ縺ｧ謖?ｮ壹☆繧九％縺ｨ縺後〒縺阪∪縺吶?
033     * 謖?ｮ壹＠縺ｪ縺??蜷医?UTF-8縺碁←逕ｨ縺輔ｌ縺ｾ縺吶?
034     *
035     * @og.group 莨晞?繧ｷ繧ｹ繝?Β
036     *
037     * @version  5.0
038     * @author   Hiroki.Nakamura
039     * @since    JDK1.6
040     */
041    public class TransferExec_SAMCB implements TransferExec {
042    
043            // 譖ｸ霎ｼ繝輔ぃ繧､繝ｫ繧ｪ繝悶ず繧ｧ繧ｯ繝?
044    //      private File fileWrite = null;                  // 5.5.2.4 (2012/05/16) 繝ｭ繝ｼ繧ｫ繝ｫ螟画焚蛹?
045    
046            // 譖ｸ霎ｼ繝輔ぃ繧､繝ｫ縺ｮ繧ｨ繝ｳ繧ｳ繝ｼ繝?
047    //      private String fileEncode = null;               // 5.5.2.4 (2012/05/16) 繝ｭ繝ｼ繧ｫ繝ｫ螟画焚蛹?
048    
049            /**
050             * 繝輔ぃ繧､繝ｫ縺ｫ譖ｸ霎ｼ縺ｿ縺励∪縺吶?
051             *
052             * @param vals 莨晞?繝??繧ｿ(驟榊?)
053             * @param config 莨晞?險ｭ螳壹が繝悶ず繧ｧ繧ｯ繝?
054             * @param tran 繝医Λ繝ｳ繧ｶ繧ｯ繧ｷ繝ｧ繝ｳ繧ｪ繝悶ず繧ｧ繧ｯ繝?
055             *
056             * @og.rev 5.5.3.3 (2012/06/15) close蜃ｦ逅?
057             * @og.rev 5.8.1.1 (2014/11/14) 繝代Λ繝｡繝ｼ繧ｿ縺ｧ譯∵焚謖?ｮ壼庄閭ｽ縺ｫ縺吶ｋ
058             */
059            @Override
060            public void execute( final String[] vals, final TransferConfig config, final Transaction tran ) {
061                    File fileWrite = new File( config.getExecObj() );
062                    
063                    String fileEncode = "UTF-8";
064                    // 5.8.1.1 (2014/11/14) fillByte霑ｽ蜉?
065                    int fillByte = 500;
066                    String execPrm = config.getExecPrm();
067                    if( execPrm != null && execPrm.length() > 0 ){
068                            String[] obj = StringUtil.csv2Array( execPrm, ' ' );
069                            fileEncode =  obj[0];
070                            if( obj.length > 1 ) {
071                                    fillByte = Integer.parseInt( obj[1] );
072                            }
073                    }
074    
075    //              String fileEncode = config.getExecPrm();
076    //              if( fileEncode == null || fileEncode.length() == 0 ) {
077    //                      fileEncode = "UTF-8";
078    //              }
079    
080                    PrintWriter writer = FileUtil.getPrintWriter( fileWrite,fileEncode );
081                    String line = null;
082                    for( String s : vals ) {
083                            // 蜑?0Byte繧堤ｩｺ逋ｽ蝓九ａ
084                            String preSpace = StringUtil.stringFill( "", 30, fileEncode );
085                            // 蜈ｨ菴薙〒500Byte縺ｫ縺ｪ繧九ｈ縺?↓蠕後ｍ縺ｫ遨ｺ逋ｽ蝓九ａ
086                            // 500Byte莉･螟悶ｂ謖?ｮ壼庄閭ｽ縺ｨ縺吶ｋ
087    //                      line = StringUtil.stringFill( preSpace + s, 500, fileEncode );
088                            line = StringUtil.stringFill( preSpace + s, fillByte, fileEncode );
089                            writer.println( line );
090                    }
091                    writer.close(); // 5.5.3.3 (2012/06/15)
092            }
093    }