根据读取数据库字段去linux下载文件到本地

落日映苍穹つ 2022-01-29 21:25 216阅读 0赞

**1.读取数据库字段**  
public class zipUrl \{  
private static final Logger logger = LoggerFactory  
.getLogger(zipUrl.class);  
@SuppressWarnings(\{ “unchecked” \})  
public static void main(String\[\] args) \{  
//File f1 = new File(“D:/wanzheng.txt”);// 员工信息中要有员工数据  
try \{  
Connection con = null;  
Class.forName(“com.mysql.jdbc.Driver”).newInstance();  
// mysql驱动  
con = (Connection) DriverManager.getConnection(“jdbc:mysql://114.116.148.197:3306/天地壹号?useSSL=false”,“root”, “Zhou572162677??”);

Statement ps =(Statement) con.createStatement();
    	String sql = "select * from _out_statistic_709";
    	ResultSet rs = ps.executeQuery(sql);
    	while (rs.next()) {
    	// 循环输出结果集
    	//int status=rs.getInt("_status");
    	String filePath=rs.getString("_zip_url");
    	//logger.info("zipUrl为"+filePath);
    	System.out.println(filePath);
    	
    		
    
    	}
    	} catch (Exception e) {
    		logger.info("异常信息为"+e);
    		
    	}

\}  
\}  
**2.根据获取到的字段保存到本地txt文件,读取txt文件下载到本地**  
//读取本地得txt文件, test1中保存的字段  
//根据字段去linux 下载到本地文件夹中  
public class GoLinuxToBenDi \{  
private static final Logger logger = LoggerFactory.getLogger(GoLinuxToBenDi.class);  
@SuppressWarnings(\{ “unchecked” \})  
public static void main(String\[\] args) \{  
List list = new ArrayList();

File f1 = new File("D:/wanzheng.txt");// 员工信息中要有员工数据
    
    	try {
    	
    		String s = null;
    		FileReader fileReader = new FileReader(f1);
    		BufferedReader bufferedReader = new BufferedReader(fileReader);
    		while ((s = bufferedReader.readLine()) != null) {
    			list.add(s);
    
    		}
    		 //ChannelSftp  cftp=SftpClient.connect("dev.tdyh.v5q.cn",22, "seelog", "1A(Uj*A]GIgMd*c8"); 
    		ChannelSftp  cftp=SftpClient.connect("web01.tdyh.v5q.cn",22, "seelog", "MxW3UooZKSp9sMZO"); //生产环境
    		// 读取文件得到每一个压缩包的url
    		for (int i = 0; i < list.size(); i++) {
    			// 连接linux 代码实现sz 下载 压缩包
    			StringBuilder  commands=new StringBuilder();
    			commands.append(list.get(i));
    			//logger.info("ur为"+commands);
    			String saveFile1="D:\\szxiazaiLinuxwenjiandizhi";//保存的路径
    			String test=list.get(i).toString();
    			int one = test.lastIndexOf("/");
    			String s1=test.substring((one+1),test.length());  //最后一个/后的内容
    			try{
    				SftpClient.download("/nfsdata/resource/mssj_service/outstorage/709/201512/", 
    		        		s1,
    		        		saveFile1,
    		        		cftp);
    			}catch(SftpException te){
    			    System.out.println("下载不是当前路径");
    				SftpClient.download("/data/nfsdata/resource/mssj_service/outstorage/709/201512/", 
    		        		s1,
    		        		saveFile1, 
    		        		cftp);
    			}
    			
    			
    			
    		}
    			
    		
    		
    		// 关闭流
    		bufferedReader.close();
    		fileReader.close();
    	} catch (Exception e) {
    		e.printStackTrace();
    	}
    }

\}  
**用到的工具类**  
public class SftpClient\{

/** 
     * 链接sftp 
     * @param host  主机 
     * @param port    端口 
     * @param username   用户名 
     * @param password  密码 
     * @return 
     */  
    public  static ChannelSftp connect(String host, int port, String username,String password) {  
         
        ChannelSftp sftp = null;  
        try {  
            JSch jsch = new JSch();  
            jsch.getSession(username, host, port);  
            Session sshSession = jsch.getSession(username, host, port);  
            System.out.println("Session创建成功");  
            sshSession.setPassword(password); 
            System.out.println("密码输入成功");
            Properties sshConfig = new Properties();  
            sshConfig.put("StrictHostKeyChecking", "no");
            System.out.println("链接参数设置成功");
            sshSession.setConfig(sshConfig);  
            sshSession.connect();  
            System.out.println("Session已连接");  
            Channel channel = sshSession.openChannel("sftp");  
            channel.connect();  
            sftp = (ChannelSftp) channel;  
            System.out.println("连接到主机" + host + ".");  
        } catch (Exception e) {  
            e.printStackTrace();  
        }  
        return sftp;  
    }  
    
    /** 
     * 文件下载 
     * @param directory 目录 
     * @param downloadFile 要下载文件名 
     * @param saveFile 保持的文件名 
     * @param sftp 
     */  
    public  static void download(String directory, String downloadFile,  
            String saveFile, ChannelSftp sftp) throws SftpException{  
            sftp.cd(directory);  
            File file = new File("D:\\szxiazaiLinuxwenjiandizhi");  
            sftp.get(downloadFile,file.toString());  
       
    }