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     *
030     * 譖ｸ霎ｼ縺ｿ縺吶ｋ繝輔ぃ繧､繝ｫ蜷阪?縲∝ｮ溯｡悟ｯｾ雎｡縺ｧ謖?ｮ壹＠縺ｾ縺吶?繝輔ぃ繧､繝ｫ蜷阪?邨ｶ蟇ｾ繝代せ縺ｧ謖?ｮ壹＠縺ｦ荳九＆縺??
031     * 縺ｾ縺溘?譖ｸ霎ｼ縺吶ｋ繝?く繧ｹ繝医ヵ繧｡繧､繝ｫ縺ｮ繧ｨ繝ｳ繧ｳ繝ｼ繝峨?譖ｸ霎ｼ繝代Λ繝｡繝ｼ繧ｿ繝ｼ縺梧欠螳壹☆繧九％縺ｨ縺後〒縺阪∪縺吶?
032     * 謖?ｮ壹＠縺ｪ縺??蜷医?繧ｷ繧ｹ繝?Β繝ｪ繧ｽ繝ｼ繧ｹ縺ｮ"DB_ENCODE"縺ｧ謖?ｮ壹＆繧後◆蛟､縺碁←逕ｨ縺輔ｌ縺ｾ縺吶?
033     *
034     * @og.group 莨晞?繧ｷ繧ｹ繝?Β
035     *
036     * @version  5.0
037     * @author   Hiroki.Nakamura
038     * @since    JDK1.6
039     */
040    public class TransferExec_SAMCB implements TransferExec {
041    
042            // 譖ｸ霎ｼ繝輔ぃ繧､繝ｫ繧ｪ繝悶ず繧ｧ繧ｯ繝?
043    //      private File fileWrite = null;                  // 5.5.2.4 (2012/05/16) 繝ｭ繝ｼ繧ｫ繝ｫ螟画焚蛹?
044    
045            // 譖ｸ霎ｼ繝輔ぃ繧､繝ｫ縺ｮ繧ｨ繝ｳ繧ｳ繝ｼ繝?
046    //      private String fileEncode = null;               // 5.5.2.4 (2012/05/16) 繝ｭ繝ｼ繧ｫ繝ｫ螟画焚蛹?
047    
048            /**
049             * 繝輔ぃ繧､繝ｫ縺ｫ譖ｸ霎ｼ縺ｿ縺励∪縺吶?
050             *
051             * @param vals 莨晞?繝??繧ｿ(驟榊?)
052             * @param config 莨晞?險ｭ螳壹が繝悶ず繧ｧ繧ｯ繝?
053             * @param tran 繝医Λ繝ｳ繧ｶ繧ｯ繧ｷ繝ｧ繝ｳ繧ｪ繝悶ず繧ｧ繧ｯ繝?
054             *
055             * @og.rev 5.5.3.3 (2012/06/15) close蜃ｦ逅?
056             */
057            @Override
058            public void execute( final String[] vals, final TransferConfig config, final Transaction tran ) {
059                    File fileWrite = new File( config.getExecObj() );
060    
061                    String fileEncode = config.getExecPrm();
062                    if( fileEncode == null || fileEncode.length() == 0 ) {
063                            fileEncode = "UTF-8";
064                    }
065    
066                    PrintWriter writer = FileUtil.getPrintWriter( fileWrite,fileEncode );
067                    String line = null;
068                    for( String s : vals ) {
069                            // 蜑?0Byte繧堤ｩｺ逋ｽ蝓九ａ
070                            String preSpace = StringUtil.stringFill( "", 30, fileEncode );
071                            // 蜈ｨ菴薙〒500Byte縺ｫ縺ｪ繧九ｈ縺?↓蠕後ｍ縺ｫ遨ｺ逋ｽ蝓九ａ
072                            line = StringUtil.stringFill( preSpace + s, 500, fileEncode );
073                            writer.println( line );
074                    }
075                    writer.close(); // 5.5.3.3 (2012/06/15)
076            }
077    }