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.ByteArrayInputStream;
019    import java.io.IOException;
020    import java.util.ArrayList;
021    import java.util.List;
022    
023    import javax.xml.parsers.DocumentBuilder;
024    import javax.xml.parsers.DocumentBuilderFactory;
025    
026    import org.opengion.fukurou.db.Transaction;
027    import org.opengion.fukurou.util.ApplicationInfo;
028    import org.opengion.fukurou.util.StringUtil;
029    import org.opengion.fukurou.util.URLConnect;
030    import org.w3c.dom.Document;
031    import org.w3c.dom.Element;
032    import org.w3c.dom.Node;
033    import org.w3c.dom.NodeList;
034    
035    /**
036     * 莨晞?隕∵ｱゅ↓蟇ｾ縺励※縲？TTP邨檎罰縺ｧ繝??繧ｿ繧定ｪｭ蜿悶＠縺ｾ縺吶?
037     *
038     * 隱ｭ蜿匁婿豕輔↓繧医ｊ隱ｭ縺ｿ蜿悶▲縺溘ョ繝ｼ繧ｿ繧単OST繝??繧ｿ縺ｨ縺励※騾∽ｿ｡縺励?繝ｪ繝｢繝ｼ繝医?繧ｹ繝井ｸ翫〒
039     * 莨晞?蜃ｦ逅?ｒ螳溯｡後＠縺ｾ縺吶?
040     *
041     * 蜃ｦ逅??豬√ｌ縺ｨ縺励※縺ｯ莉･荳九?繧医≧縺ｫ縺ｪ繧翫∪縺吶?
042     * 竭?TTP縺ｧ隱ｭ蜿門?逅?ｒ螳溯｡後☆繧九◆繧√?繧ｵ繝ｼ繝悶Ξ繝?ヨ繧貞他縺ｳ蜃ｺ縺吶?
043     * 竭｡竭?〒蜻ｼ縺ｳ蜃ｺ縺励＆繧後◆繧ｵ繝ｼ繝悶Ξ繝?ヨ縺後?隱ｭ蜿門?逅?ｒ螳溯｡後☆繧九◆繧√?繧ｪ繝悶ず繧ｧ繧ｯ繝医ｒ逕滓?縺励?
044     *   隱ｭ蜿門?逅?ｒ螳溯｡後☆繧九?
045     * 竭｢隱ｭ蜿悶＠縺溽ｵ先棡XML繧偵ヱ繝ｼ繧ｹ縺励?縺昴?隱ｭ蜿悶ョ繝ｼ繧ｿ繧剃ｼ晞?繧ｪ繝悶ず繧ｧ繧ｯ繝医↓貂｡縺嶺ｼ晞?蜃ｦ逅?ｒ螳溯｡後☆繧九?
046     * 竭｣莨晞?蜃ｦ逅?ｮ溯｡悟ｾ後?竭｢縺ｮ邨先棡XML縺九ｉ蠕励ｉ繧後ｋ譖ｴ譁ｰ繧ｭ繝ｼ(驟榊?)繧単ost繝??繧ｿ縺ｨ縺励※貂｡縺励?
047     *   HTTP邨檎罰縺ｧ蠕悟?逅?螳御ｺ??逅?∪縺溘?繧ｨ繝ｩ繝ｼ蜃ｦ逅?繧貞ｮ溯｡後☆繧九?
048     *
049     * 縺ｾ縺壺蔵縺ｫ縺､縺?※縲∝他縺ｳ蜃ｺ縺励＆繧後ｋ繧ｵ繝ｼ繝悶Ξ繝?ヨ縺ｯ縲?
050     *   [繝ｪ繝｢繝ｼ繝域磁邯壼?URL]servlet/remoteControl?class=TransferReadWrapper&amp;type=read 縺ｫ縺ｪ繧翫∪縺吶?
051     *   [繝ｪ繝｢繝ｼ繝域磁邯壼?URL]縺ｯ縲”ttp://[繝帙せ繝亥錐]:[繝昴?繝育分蜿ｷ]/[繧ｳ繝ｳ繝?く繧ｹ繝亥錐]縺ｮ蠖｢蠑上↓縺ｪ繧翫∪縺吶′縲?
052     *   縺薙ｌ縺ｫ縺､縺?※縺ｯ縲∬ｪｭ蜿門ｯｾ雎｡縺ｧ謖?ｮ壹＠縺ｾ縺吶?
053     *   謗･邯壽凾縺ｫ繧ｨ繝ｩ繝ｼ縺檎匱逕溘＠縺溷?蜷医ｄ縲√Ξ繧ｹ繝昴Φ繧ｹ繝??繧ｿ縺ｫ蟇ｾ縺励※"row_error"縺ｨ縺?≧
054     *   譁?ｭ怜?縺悟ｭ伜惠縺吶ｋ蝣ｴ蜷医?縲√お繝ｩ繝ｼ縺ｨ縺励※蜃ｦ逅?＠縺ｾ縺吶?
055     *   縺昴ｌ莉･螟悶?蝣ｴ蜷医?縲∵ｭ｣蟶ｸ邨ゆｺ?→縺励※蜃ｦ逅?＠縺ｾ縺吶?
056     * 谺｡縺ｫ竭｡縺ｫ縺､縺?※縲√し繝ｼ繝悶Ξ繝?ヨ邨檎罰縺ｧ陦後ｏ繧後ｋ莨晞?蜃ｦ逅?↓縺､縺?※縲√◎縺ｮ隱ｭ蜿匁婿豕輔?縲?
057     *   縺薙?繧ｯ繝ｩ繧ｹ繧堤ｶ呎価縺励◆蜷?し繝悶け繝ｩ繧ｹ縺ｮ繧ｯ繝ｩ繧ｹ蜷阪↓繧医ｊ豎ｺ螳壹＆繧後∪縺吶?
058     *   蜈ｷ菴鍋噪縺ｫ縺ｯ縲√し繝悶け繝ｩ繧ｹ縺ｮ繧ｯ繝ｩ繧ｹ蜷阪↓蟇ｾ縺励※縲√％縺ｮ繧ｯ繝ｩ繧ｹ(隕ｪ繧ｯ繝ｩ繧ｹ)縺ｮ繧ｯ繝ｩ繧ｹ蜷?"_" 繧帝勁螟悶＠縺滄Κ蛻?′
059     *   隱ｭ蜿匁婿豕輔→縺励※隱崎ｭ倥＆繧後∪縺吶?
060     *   萓九→縺励※縲√し繝悶け繝ｩ繧ｹ蜷阪′TransferRead_HTTP_CB01縺ｮ蝣ｴ蜷医?謗･邯壼?縺ｫ縺翫￠繧玖ｪｭ蜿匁婿豕輔?
061     *   譌ｧ莨晞?DB隱ｭ蜿?CB01)縺ｨ縺ｪ繧翫∪縺吶?
062     *   縺ｾ縺溘?繝ｪ繝｢繝ｼ繝医?繧ｹ繝井ｸ翫〒螳溯｡後＆繧後ｋ莨晞?蜃ｦ逅??[繝ｪ繝｢繝ｼ繝郁ｪｭ蜿門ｯｾ雎｡]縺ｯ縲∝?縺ｮ隱ｭ蜿門ｯｾ雎｡縺ｧ險ｭ螳壹＠縺ｾ縺吶?
063     *   縺薙?縺薙→縺九ｉ縲？TTP邨檎罰縺ｧ隱ｭ蜿門?逅?ｒ陦後≧蝣ｴ蜷医?蜈??隱ｭ蜿門ｯｾ雎｡縺ｫ縺ｯ縲ー繝ｪ繝｢繝ｼ繝域磁邯壼?URL]縺ｨ
064     *   [繝ｪ繝｢繝ｼ繝郁ｪｭ蜿門ｯｾ雎｡]縺ｮ2縺､繧定ｨｭ螳壹☆繧句ｿ?ｦ√′縺ゅｊ縺ｾ縺吶?
065     *   蜈ｷ菴鍋噪縺ｪ險ｭ螳壽婿豕輔↓縺､縺?※縺ｯ蜷?し繝悶け繝ｩ繧ｹ縺ｮJavaDoc繧貞盾辣ｧ縺励※荳九＆縺??
066     * 竭｢縺ｫ縺､縺?※縲∬ｿ斐＆繧後ｋXML繝??繧ｿ縺ｯ[繝ｬ繧ｹ繝昴Φ繧ｹ繝??繧ｿ縺ｮXML讒矩?]縺ｮ蠖｢蠑上↓縺ｪ繧翫∪縺吶?
067     *   縺薙％縺ｧ縲‥ataList縺ｯ縲∽ｼ晞?螳溯｡後が繝悶ず繧ｧ繧ｯ繝医↓貂｡縺輔ｌ繧九ョ繝ｼ繧ｿ縺ｫ縺ｪ繧翫∪縺吶?
068     *   縺ｾ縺溘?keyList縺ｫ縺､縺?※縺ｯ縲∽ｼ晞?螳溯｡檎ｵゆｺ?ｾ後?HTTP邨檎罰縺ｧ螳御ｺ??逅?ｒ陦後≧縺溘ａ縺ｮ譖ｴ譁ｰ繧ｭ繝ｼ縺ｫ縺ｪ繧翫∪縺吶?
069     *   (繝ｭ繝ｼ繧ｫ繝ｫ縺ｮ莨晞?隱ｭ蜿悶が繝悶ず繧ｧ繧ｯ繝医?繝医Λ繝ｳ繧ｶ繧ｯ繧ｷ繝ｧ繝ｳ縺ｫ蟇ｾ縺励※蜷御ｸ?が繝悶ず繧ｧ繧ｯ繝医↓縺ｪ繧翫∪縺吶′縲?
070     *    HTTP謗･邯壼?縺ｧ繧ｵ繝ｼ繝悶Ξ繝?ヨ邨檎罰縺ｧ逕滓?縺輔ｌ繧九?繝ｪ繝｢繝ｼ繝医?莨晞?隱ｭ蜿悶が繝悶ず繧ｧ繧ｯ繝医?縲?
071     *    隱ｭ蜿門?逅?→螳御ｺ?繧ｨ繝ｩ繝ｼ蜃ｦ逅?〒逡ｰ縺ｪ繧翫∪縺吶?縺薙?縺溘ａ縲∬ｪｭ蜿悶＠縺溘ョ繝ｼ繧ｿ縺ｮ繧ｭ繝ｼ繧偵Ο繝ｼ繧ｫ繝ｫ縺ｫ菫晄戟縺励?
072     *    譛?ｾ後?螳御ｺ?繧ｨ繝ｩ繝ｼ蜃ｦ逅??髫帙↓縲∬ｪｭ蜿悶＠縺溘ョ繝ｼ繧ｿ縺ｮ繧ｭ繝ｼ(譖ｴ譁ｰ繧ｭ繝ｼ)繧単ostData縺ｨ縺励※貂｡縺吶％縺ｨ縺ｧ縲?
073     *    豁｣縺励￥螳御ｺ?繧ｨ繝ｩ繝ｼ蜃ｦ逅?′陦後ｏ繧後ｋ繧医≧縺ｫ蟇ｾ蠢懊＠縺ｦ縺?∪縺?
074     * 譛?ｾ後↓竭｣縺ｫ縺､縺?※縲∝他縺ｳ蜃ｺ縺励＆繧後ｋ繧ｵ繝ｼ繝悶Ξ繝?ヨ縺ｯ縲?
075     *   [繝ｪ繝｢繝ｼ繝域磁邯壼?URL]servlet/remoteControl?class=TransferReadWrapper&amp;type=complete (豁｣蟶ｸ邨ゆｺ?凾)
076     *   [繝ｪ繝｢繝ｼ繝域磁邯壼?URL]servlet/remoteControl?class=TransferReadWrapper&amp;type=error    (繧ｨ繝ｩ繝ｼ逋ｺ逕滓凾)
077     *   縺ｨ縺ｪ繧翫∪縺吶?
078     *
079     * HTTP謗･邯壽凾縺ｫ縺ｯ縲∽ｻ･荳九?繝昴せ繝医ョ繝ｼ繧ｿ縺碁?菫｡縺輔ｌ縺ｾ縺吶?
080     * [繝昴せ繝医ョ繝ｼ繧ｿ]
081     * 繝ｻKBREAD                     (隱ｭ蜿匁婿豕? 窶ｻ繧ｵ繝悶け繝ｩ繧ｹ縺ｮ譛?ｾ後?"_"(繧｢繝ｳ繝??繝舌?)莉･髯阪?譁?ｭ怜?
082     * 繝ｻREADOBJ            (繝ｪ繝｢繝ｼ繝郁ｪｭ蜿門ｯｾ雎｡) 窶ｻ繝ｭ繝ｼ繧ｫ繝ｫ縺ｮ隱ｭ蜿門ｯｾ雎｡縺九ｉ繝ｪ繝｢繝ｼ繝域磁邯壼?URL繧帝勁縺?◆譁?ｭ怜?
083     * 繝ｻREADPRM            (隱ｭ蜿悶ヱ繝ｩ繝｡繝ｼ繧ｿ繝ｼ)
084     * 繝ｻKBEXEC                     (螳溯｡梧婿豕?
085     * 繝ｻEXECDBID           (螳溯｡梧磁邯壼?DBID)
086     * 繝ｻEXECOBJ            (螳溯｡悟ｯｾ雎｡)
087     * 繝ｻEXECPRM            (螳溯｡後ヱ繝ｩ繝｡繝ｼ繧ｿ繝ｼ)
088     * 繝ｻERROR_SENDTO       (隱ｭ縺ｿ蜿悶ｊ蜈??繧ｹ繝医さ繝ｼ繝?
089     * 繝ｻHFROM (隱ｭ縺ｿ蜿悶ｊ蜈??繧ｹ繝医さ繝ｼ繝?
090     * 繝ｻn (繧ｭ繝ｼ莉ｶ謨ｰ)
091     * 繝ｻk1?枳n (繧ｭ繝ｼ)
092     *
093     * 縺ｾ縺溘?繝??繧ｿ隱ｭ蜿匁凾縺ｫ霑斐＆繧後ｋXML縺ｯ莉･荳九?讒矩?繧偵＠縺ｦ縺?∪縺吶?
094     * [繝ｬ繧ｹ繝昴Φ繧ｹ繝??繧ｿ縺ｮXML讒矩?]
095     * &lt;root&gt;
096     *  &lt;dataList&gt;
097     *   &lt;data&gt;aaa&lt;/data&gt;
098     *   &lt;data&gt;bbb&lt;/data&gt;
099     *   &lt;data&gt;ccc&lt;/data&gt;
100     *   &lt;data&gt;ddd&lt;/data&gt;
101     *   &lt;data&gt;eee&lt;/data&gt;
102     *  &lt;/dataList&gt;
103     *  &lt;keyList&gt;
104     *   &lt;key&gt;KEY1&lt;/key&gt;
105     *   &lt;key&gt;KEY2&lt;/key&gt;
106     *   &lt;key&gt;KEY3&lt;/key&gt;
107     *  &lt;/keyList&gt;
108     * &lt;/root&gt;
109     *
110     * @og.group 莨晞?繧ｷ繧ｹ繝?Β
111     *
112     * @version  5.0
113     * @author   Hiroki.Nakamura
114     * @since    JDK1.6
115     */
116    public abstract class TransferRead_HTTP implements TransferRead {
117    
118            // 繝ｪ繝｢繝ｼ繝亥宛蠕｡繧ｵ繝ｼ繝悶Ξ繝?ヨ蜷?
119            private static final String REMOTE_SERVLET = "servlet/remoteControl?class=TransferReadWrapper";
120    
121            // 譖ｴ譁ｰ蟇ｾ雎｡縺ｮ繧ｭ繝ｼ
122            private String[] keys = null;
123    
124            /**
125             * URL謗･邯壹ｒ陦後＞繝??繧ｿ繧定ｪｭ縺ｿ蜿悶ｊ縺ｾ縺吶?
126             * 謗･邯壹ヱ繝ｩ繝｡繝ｼ繧ｿ縺ｫ縺ｯ縲?type=read"縺御ｻ伜刈縺輔ｌ縺ｾ縺吶?
127             *
128             * @param config 莨晞?險ｭ螳壹が繝悶ず繧ｧ繧ｯ繝?
129             * @param tran 繝医Λ繝ｳ繧ｶ繧ｯ繧ｷ繝ｧ繝ｳ繧ｪ繝悶ず繧ｧ繧ｯ繝?
130             *
131             * @return 隱ｭ縺ｿ蜿悶ｊ縺励◆繝??繧ｿ(驟榊?)
132             */
133            @Override
134            public String[] read( final TransferConfig config, final Transaction tran ) {
135                    splitReadObj( config.getReadObj() );
136                    String url = getRemoteHost() + REMOTE_SERVLET+ "&type=read";
137                    String postData = getPostData( keys, config );
138                    URLConnect conn = null;
139                    String data = null;
140                    try {
141                            conn = connect( url, postData, config );
142                            data = readData( conn );
143                    }
144                    catch( IOException ex ) {
145                            String errMsg = "URL謗･邯壽凾縺ｫ萓句､悶′逋ｺ逕溘＠縺ｾ縺励◆縲?URL=" + url + "]";
146                            throw new RuntimeException( errMsg, ex );
147                    }
148                    finally {
149                            if( conn != null ) { conn.disconnect(); }
150                    }
151    
152                    List<String> valList = new ArrayList<String>();
153                    List<String> keyList = new ArrayList<String>();
154    
155                    DocumentBuilderFactory dbfactory = DocumentBuilderFactory.newInstance();
156                    Document doc = null;
157                    try {
158                            DocumentBuilder builder = dbfactory.newDocumentBuilder();
159                            doc = builder.parse( new ByteArrayInputStream( data.getBytes( "UTF-8" ) ) );
160                    }
161                    catch( Exception ex ) {
162                            String errMsg = "XML繝代?繧ｹ譎ゅ↓繧ｨ繝ｩ繝ｼ縺檎匱逕溘＠縺ｾ縺励◆縲?;
163                            throw new RuntimeException( errMsg, ex );
164                    }
165                    Element root = doc.getDocumentElement();
166    
167                    // 繝??繧ｿ驛ｨ蛻?ｒ蜿門ｾ励＠縺ｾ縺吶?
168                    NodeList dataChilds = root.getElementsByTagName( "dataList" ).item(0).getChildNodes();
169                    int numDataChild = dataChilds.getLength();
170                    for( int i=0; i<numDataChild; i++ ) {
171                            Node nd = dataChilds.item(i);
172                            if( nd.getNodeType() == Node.ELEMENT_NODE ) {
173                                    if( "data".equals( ((Element)nd).getTagName() ) )       {
174                                            valList.add( nd.getTextContent() );
175                                    }
176                            }
177                    }
178    
179                    // 莉･髯阪?蜃ｦ逅?〒繝??繧ｿ繧呈峩譁ｰ縺吶ｋ縺溘ａ縺ｮ繧ｭ繝ｼ繧貞叙蠕励＠縺ｾ縺吶?
180                    NodeList keyChilds = root.getElementsByTagName( "keyList" ).item(0).getChildNodes();
181                    int numKeyChild = keyChilds.getLength();
182                    for( int i=0; i<numKeyChild; i++ ) {
183                            Node nd = keyChilds.item(i);
184                            if( nd.getNodeType() == Node.ELEMENT_NODE ) {
185                                    if( "key".equals( ((Element)nd).getTagName() ) )        {
186                                            keyList.add( nd.getTextContent() );
187                                    }
188                            }
189                    }
190    //              keys = keyList.toArray( new String[0] );
191                    keys = keyList.toArray( new String[keyList.size()] );
192    
193    //              return valList.toArray( new String[0] );
194                    return valList.toArray( new String[valList.size()] );
195            }
196    
197            /**
198             * 隱ｭ蜿悶＠縺溘ョ繝ｼ繧ｿ縺ｫ蟇ｾ縺励※螳御ｺ??逅?ｒ陦後＞縺ｾ縺吶?
199             * 謗･邯壹ヱ繝ｩ繝｡繝ｼ繧ｿ縺ｫ縺ｯ縲?type=complete"縺御ｻ伜刈縺輔ｌ縺ｾ縺吶?
200             *
201             * @param config 莨晞?險ｭ螳壹が繝悶ず繧ｧ繧ｯ繝?
202             * @param tran 繝医Λ繝ｳ繧ｶ繧ｯ繧ｷ繝ｧ繝ｳ繧ｪ繝悶ず繧ｧ繧ｯ繝?
203             */
204            @Override
205            public void complete( final TransferConfig config, final Transaction tran ) {
206                    splitReadObj( config.getReadObj() );
207                    String url = getRemoteHost() + REMOTE_SERVLET + "&type=complete";
208                    String postData = getPostData( keys, config );
209                    URLConnect conn = null;
210                    try {
211                            conn = connect( url, postData, config );
212                    }
213                    catch( IOException ex ) {
214                            String errMsg = "URL謗･邯壽凾縺ｫ萓句､悶′逋ｺ逕溘＠縺ｾ縺励◆縲?URL=" + url + "]";
215                            throw new RuntimeException( errMsg, ex );
216                    }
217                    finally {
218                            if( conn != null ) { conn.disconnect(); }
219                    }
220            }
221    
222            /**
223             * 隱ｭ蜿悶＠縺溘ョ繝ｼ繧ｿ縺ｫ蟇ｾ縺励※繧ｨ繝ｩ繝ｼ蜃ｦ逅?ｒ陦後＞縺ｾ縺吶?
224             * 謗･邯壹ヱ繝ｩ繝｡繝ｼ繧ｿ縺ｫ縺ｯ縲?type=error"縺御ｻ伜刈縺輔ｌ縺ｾ縺吶?
225             *
226             * @param config 莨晞?險ｭ螳壹が繝悶ず繧ｧ繧ｯ繝?
227             * @param appInfo DB謗･邯壽ュ蝣ｱ
228             */
229            @Override
230            public void error( final TransferConfig config, final ApplicationInfo appInfo ) {
231                    splitReadObj( config.getReadObj() );
232                    String url = getRemoteHost() + REMOTE_SERVLET + "&type=error";
233                    String postData = getPostData( keys, config );
234                    URLConnect conn = null;
235                    try {
236                            conn = connect( url, postData, config );
237                    }
238                    catch( IOException ex ) {
239                            String errMsg = "URL謗･邯壽凾縺ｫ萓句､悶′逋ｺ逕溘＠縺ｾ縺励◆縲?URL=" + url + "]";
240                            throw new RuntimeException( errMsg, ex );
241                    }
242                    finally {
243                            if( conn != null ) { conn.disconnect(); }
244                    }
245            }
246    
247            /**
248             * (縺薙?繧ｯ繝ｩ繧ｹ縺ｧ縺ｯ縲√し繝昴?繝医＆繧後※縺ｾ縺帙ｓ縲?
249             *
250             * @return 譖ｴ譁ｰ繧ｭ繝ｼ(驟榊?)
251             */
252            @Override
253            public String[] getKeys() {
254                    String errMsg = "縺薙?繧ｯ繝ｩ繧ｹ縺ｧ縺ｯ縲√し繝昴?繝医＆繧後※縺ｾ縺帙ｓ縲?;
255                    throw new RuntimeException( errMsg );
256            }
257    
258            /**
259             * (縺薙?繧ｯ繝ｩ繧ｹ縺ｧ縺ｯ縲√し繝昴?繝医＆繧後※縺ｾ縺帙ｓ縲?
260             *
261             * @param keys 譖ｴ譁ｰ繧ｭ繝ｼ(驟榊?)
262             */
263            @Override
264            public void setKeys( final String[] keys ) {
265                    String errMsg = "縺薙?繧ｯ繝ｩ繧ｹ縺ｧ縺ｯ縲√し繝昴?繝医＆繧後※縺ｾ縺帙ｓ縲?;
266                    throw new RuntimeException( errMsg );
267            }
268    
269            /**
270             * 繝ｭ繝ｼ繧ｫ繝ｫ縺ｮ隱ｭ蜿門ｯｾ雎｡繧偵?繝ｪ繝｢繝ｼ繝域磁邯壼?縺ｮ隱ｭ蜿門ｯｾ雎｡縺ｨ繝ｪ繝｢繝ｼ繝域磁邯壼?URL縺ｫ蛻?ｧ｣縺励∪縺吶?
271             *
272             * @param localReadObj 繝ｭ繝ｼ繧ｫ繝ｫ縺ｮ隱ｭ蜿門ｯｾ雎｡
273             */
274            protected abstract void splitReadObj( final String localReadObj );
275    
276            /**
277             * 繝ｪ繝｢繝ｼ繝域磁邯壼?URL繧定ｿ斐＠縺ｾ縺吶?
278             * 縺薙?繝｡繧ｽ繝?ラ縺ｯ縲＋@link #splitReadObj(String)}縺ｮ蠕後↓蜻ｼ縺ｳ蜃ｺ縺励☆繧句ｿ?ｦ√′縺ゅｊ縺ｾ縺吶?
279             *
280             * @return 繝ｪ繝｢繝ｼ繝域磁邯壼?URL
281             */
282            protected abstract String getRemoteHost();
283    
284            /**
285             * 繝ｪ繝｢繝ｼ繝域磁邯壼?縺ｮ隱ｭ蜿門ｯｾ雎｡繧定ｿ斐＠縺ｾ縺吶?
286             * 縺薙?繝｡繧ｽ繝?ラ縺ｯ縲＋@link #splitReadObj(String)}縺ｮ蠕後↓蜻ｼ縺ｳ蜃ｺ縺励☆繧句ｿ?ｦ√′縺ゅｊ縺ｾ縺吶?
287             *
288             * @return 謗･邯啅RL
289             */
290            protected abstract String getRemoteReadObj();
291    
292            /**
293             * 謖?ｮ壹?URL縺ｫ謗･邯壹＠縺ｾ縺吶?
294             *
295             * @param url 謗･邯啅RL
296             * @param postData POST縺吶ｋ繝??繧ｿ
297             * @param config 莨晞?險ｭ螳壹が繝悶ず繧ｧ繧ｯ繝?
298             *
299             * @return 謗･邯壹が繝悶ず繧ｧ繧ｯ繝?
300             * @throws IOException 縺ｪ繧薙ｉ縺九?繧ｨ繝ｩ繝ｼ縺檎匱逕溘＠縺溷?蜷医?
301             */
302            protected URLConnect connect( final String url, final String postData, final TransferConfig config ) throws IOException {
303                    URLConnect conn = new URLConnect( url, TransferConfig.HTTP_AUTH_USER_PASS );
304                    if( config.getProxyHost() != null && config.getProxyHost().length() > 0  ) {
305                            conn.setProxy( config.getProxyHost(),config.getProxyPort() );
306                    }
307                    conn.setCharset( "UTF-8" );
308                    conn.setPostData( postData );
309                    conn.connect();
310                    return conn;
311            }
312    
313            /**
314             * 謖?ｮ壹?URL縺ｫ謗･邯壹＠繝ｬ繧ｹ繝昴Φ繧ｹ繝??繧ｿ繧定ｿ斐＠縺ｾ縺吶?
315             *
316             * @param conn URL謗･邯壹が繝悶ず繧ｧ繧ｯ繝?
317             *
318             * @return 繝ｬ繧ｹ繝昴Φ繧ｹ繝??繧ｿ
319             */
320            private String readData( final URLConnect conn ) throws IOException {
321                    String readData = conn.readData();
322                    // 霑斐＆繧後◆繝??繧ｿ荳ｭ縺ｫ"row_error"縺悟ｭ伜惠縺吶ｋ蝣ｴ蜷医?繧ｨ繝ｩ繝ｼ縺ｨ縺励※蜃ｦ逅?＠縺ｾ縺吶?
323                    if( readData != null && readData.indexOf( "row_error" ) >= 0 ) {
324                            throw new RuntimeException( readData );
325                    }
326                    return readData;
327            }
328    
329            /**
330             * 莨晞?險ｭ螳壹が繝悶ず繧ｧ繧ｯ繝医ｒURL繝代Λ繝｡繝ｼ繧ｿ繝ｼ縺ｫ螟画鋤縺励∪縺吶?
331             *
332             * @param       keys    譖ｴ譁ｰ繧ｭ繝ｼ(驟榊?)
333             * @param       config  莨晞?險ｭ螳壹が繝悶ず繧ｧ繧ｯ繝?
334             *
335             * @return      URL繝代Λ繝｡繝ｼ繧ｿ繝ｼ
336             */
337            protected String getPostData( final String[] keys, final TransferConfig config ) {
338                    // 繧ｵ繝悶け繝ｩ繧ｹ蜷阪°繧芽ｦｪ繧ｯ繝ｩ繧ｹ蜷?"_"繧帝勁縺?◆驛ｨ蛻?ｒ隱ｭ蜿匁婿豕輔→縺吶ｋ縲?
339                    String kbRead = getClass().getName().replace( getClass().getSuperclass().getName() + "_", "" );
340    
341                    StringBuilder buf = new StringBuilder();
342                    buf.append( "KBREAD="           ).append( StringUtil.urlEncode( kbRead ) );
343                    buf.append( "&READOBJ="             ).append( StringUtil.urlEncode( getRemoteReadObj() ) );
344                    buf.append( "&READPRM="             ).append( StringUtil.urlEncode( config.getReadPrm() ) );
345                    buf.append( "&KBEXEC="              ).append( StringUtil.urlEncode( config.getKbExec() ) );
346                    buf.append( "&EXECDBID="    ).append( StringUtil.urlEncode( config.getExecDbid() )  );
347                    buf.append( "&EXECOBJ="             ).append( StringUtil.urlEncode( config.getExecObj() ) );
348                    buf.append( "&EXECPRM="             ).append( StringUtil.urlEncode( config.getExecPrm() ) );
349                    buf.append( "&ERROR_SENDTO=").append( StringUtil.urlEncode( config.getErrorSendto() ) );
350                    buf.append( "&HFROM="               ).append( StringUtil.urlEncode( config.getHfrom() ) );
351    
352                    if( keys != null && keys.length > 0 ) {
353                            buf.append( "&n=" ).append( keys.length );
354                            for( int i=0; i<keys.length; i++ ) {
355                                    buf.append( "&k" ).append( i ).append( "=" );
356                                    buf.append( StringUtil.urlEncode( keys[i] ) );
357                            }
358                    }
359                    else {
360                            buf.append( "&n=0" );
361                    }
362    
363                    return buf.toString();
364            }
365    }