| 336 | } |
| 337 | |
| 338 | private void removeWastedData(long backupfilehistoryid,String backupfilefullpath) { |
| 339 | //get fileid |
| 340 | try { |
| 341 | ResultSet ret=mysqlHelper.querySql("select backupfileid from tb_backfilehistory where id="+backupfilehistoryid); |
| 342 | if(ret!=null&&ret.next()) |
| 343 | { |
| 344 | long backupfileid=ret.getLong("backupfileid"); |
| 345 | mysqlHelper.exeSql("delete from tb_backfilehistory where id="+backupfilehistoryid); |
| 346 | File file=new File(backupfilefullpath); |
| 347 | if(file.exists()) { |
| 348 | logger.info("delete broken file:"+backupfilefullpath); |
| 349 | file.delete(); |
| 350 | } |
| 351 | ret=mysqlHelper.querySql("select count(*) from tb_backfilehistory where backupfileid="+backupfileid); |
| 352 | if(ret!=null&&ret.next()) |
| 353 | { |
| 354 | int historycnt=ret.getInt("count(*)"); |
| 355 | if(historycnt==0) |
| 356 | { |
| 357 | //delete parent |
| 358 | mysqlHelper.exeSql("delete from tb_backfiles where id="+backupfileid); |
| 359 | } |
| 360 | } |
| 361 | } |
| 362 | } catch (Exception e) |
| 363 | { |
| 364 | logger.error(e.getMessage()); |
| 365 | } |
| 366 | } |
| 367 | |
| 368 | private void checkdata(boolean withhash) |
| 369 | { |