Method XCopy

src/main/java/serviceRun.java:173–247

(Backuproot backuproot)

    private void XCopy(Backuproot backuproot) throws SQLException, IOException {
        logger.info("Loading File list:"+backuproot.getRootpath());
        List<String> fileList=new ArrayList<>();
        Map<String,Long> mapFile=new HashMap<>();
        loadAllFiles(new File(backuproot.getRootpath()),fileList);
        logger.info("Loading CurrentFile In Db:"+ backuproot.getId());
        {
            String sqlquery = "select id,filepath from tb_backfiles where backuprootid=" + backuproot.getId();
            ResultSet ret = mysqlHelper.querySql(sqlquery);
            while(ret!=null&&ret.next())
            {
                mapFile.put(ret.getString("filepath"),ret.getLong("id"));
            }
        }
        logger.info("begin xcopy! total:"+ fileList.size());
        long counter=0;
        long timestamp=new Date().getTime()/1000;
        for(String file:fileList)
        {
            if(file.indexOf("/.")!=-1||file.indexOf("\\.")!=-1)
            {
                //不拷贝.开头的文件夹和文件
                continue;
            }
            counter++;
            if(new Date().getTime()/1000!=timestamp)
            {
                timestamp=new Date().getTime()/1000;
                System.out.println("copy progress:"+counter*100/fileList.size()+"%  "+counter+"/"+fileList.size());
            }
            File fileHandle=new File(file);
            long id=0;
           if(!mapFile.containsKey(file))
           {
               String sqlquery="select * from tb_backfiles where filepath='"+file.replace("\\","\\\\").replace("'","\\'")+"' and backuprootid="+backuproot.getId();
               //ResultSet ret= mysqlHelper.querySql(sqlquery);
           //if(ret==null||!ret.next()) {
               //第一次拷贝，创建档案
               mysqlHelper.exeSql("insert into tb_backfiles (backuprootid,filepath,versionhistorycnt,lastbackuptime) values (" +
                       backuproot.getId() + ",'" + file.replace("\\","\\\\").replace("'","\\'") + "',0,now())");
               ResultSet ret= mysqlHelper.querySql(sqlquery);
               if(ret==null||!ret.next())
               {
                   logger.error("内部错误！数据库异常，退出...");
                   break;
               }
               id=ret.getLong("id");
           }
           else
           {
               id=mapFile.get(file);
           }
           //判断文件是否有修改
            ResultSet ret=mysqlHelper.querySql("select * from tb_backfilehistory where backupfileid="+id+" order by id desc limit 1");
           if(ret!=null&&ret.next())
           {
               long lastmotify=ret.getLong("motifytime");
               long filesize=ret.getLong("filesize");