로컬PC에 파일 일괄다운로드

package common;
 
import java.io.BufferedOutputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.URL;
import java.net.URLConnection;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
 
public class FileLocalDownload {
 
    /**
     * 버퍼 사이즈
     */
    final static int size = 1024;
 
 
    public static void fileUrlReadAndDownload(String fileAddress, String localFileName, String downloadDir) {
        OutputStream outStream = null;
        URLConnection uCon = null;
        InputStream is = null;
        try {
            System.out.println("-------Download Start------");
            URL Url;
            byte[] buf;
            int byteRead;
            int byteWritten = 0;
            Url = new URL(fileAddress);
            outStream = new BufferedOutputStream(new FileOutputStream(downloadDir + "\\" + localFileName));
            uCon = Url.openConnection();
            is = uCon.getInputStream();
            buf = new byte[size];
            while ((byteRead = is.read(buf)) != -1) {
                outStream.write(buf, 0, byteRead);
                byteWritten += byteRead;
            }
            System.out.println("Download Successfully.");
            System.out.println("File name : " + localFileName);
            System.out.println("of bytes  : " + byteWritten);
            System.out.println("-------Download End--------");
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            try {
                is.close();
                outStream.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
 
    /**
     * 
     * @param fileAddress
     * @param downloadDir
     */
    public static void fileUrlDownload(String fileAddress, String downloadDir) {
        int slashIndex = fileAddress.lastIndexOf("filename=");
        int periodIndex = fileAddress.lastIndexOf(".");
        // 파일 어드레스에서 마지막에 있는 파일이름을 취득
        String fileName = fileAddress.substring(slashIndex + 9);
        if (periodIndex >= 1 && slashIndex >= 0 && slashIndex < fileAddress.length() - 1) {
            fileUrlReadAndDownload(fileAddress, fileName, downloadDir);
        } else {
            System.err.println("path or file name NG.");
        }
    }
    
    public static List getResult(ResultSet rs) throws Exception
    {
        ResultSetMetaData rsmd = rs.getMetaData(); //resultSet의 컬럼정보를 가져온다.
        int columnCount = rsmd.getColumnCount();   //컬럼 갯수
        ArrayList hashMapList = new ArrayList();
 
        HashMap columnMap= new HashMap(); //DB의 Field의 정보 모음
 
        //column 정보 담기
        for(int i = 1; i <= columnCount; i++) {
            String sTypeStr ="string";
            columnMap.put(rsmd.getColumnName(i).toLowerCase(), sTypeStr);
        }
 
        //row 담기
        while(rs.next()) {
            HashMap hashMap= new HashMap();
            Iterator iter = columnMap.keySet().iterator();
            while(iter.hasNext()) {
                String key = (String)iter.next();
                hashMap.put(key.toLowerCase(), rs.getString((key)));
            }
            hashMapList.add(hashMap);
        }
 
        return hashMapList;
    }
 
    public static void main(String[] args) throws Exception {
        
        Connection cn = null;
        String s_id            = "id"; /* 수정 : DB정보수정 */
         String s_pwd        = "pwd"; /* 수정 : DB정보수정 */
        String jdbc_driver = "oracle.jdbc.driver.OracleDriver";
        String jdbc_url = "jdbc:oracle:thin:@ip:port:sid"; /* 수정 : DB정보수정 */
        try{
            Class.forName(jdbc_driver);
            cn = DriverManager.getConnection(jdbc_url, s_id, s_pwd);
        }
        catch(Exception e) {
            System.out.println(e);
        }
        
        ResultSet rs    = null;
        String sql;
        PreparedStatement pstmt = null;
        Statement  st = null;
        List dataList = null;
        List<HashMap> resultList = new ArrayList();
        
        sql = " select filename, realfilename from file_info_table "; /* 수정 : SQL 작성하기 */
        
        pstmt = cn.prepareStatement(sql);
        rs = pstmt.executeQuery();
        
        if(rs != null ){
            dataList = getResult(rs);
        }
        
        String downDir = "C:/download"; /* 수정 : 다운로드받을 경로 작성 */
        
        for(int i=0; i < dataList.size(); i++){
            HashMap temp = (HashMap)dataList.get(i);
            String url = "http://filedownloadsite.com/filedown.do?filename="+temp.get("realfilename"); /* 수정 : 다운로드받을 url넣기 */
            fileUrlReadAndDownload(url, String.valueOf(temp.get("filename")), downDir);
        }
    }
}