phpmyadmin误删表后的恢复过程

转自：http://blog.csdn.net/ssrc0604hx/article/details/18717983

话说今天不知道是抽风了还是失魂了，在用phpmyadmin删除测试数据时，竟然将整个表删除了：

等程序运行出错时，才出现整个表都没有了，而且之前也没有备份好！这下蛋疼了，这个可是production服务器，里面的数据可不能丢啊！
 
服务器是linux的，我不是很熟悉，也不知道mysql装在哪。
无奈之下，google，发现有不少人也有像我一样犯傻的一回，但是几乎没有看到具体的解决方法（有说用硬盘软件找回，也有说用二进制文件找回），但是我本身对服务器不大懂，觉得好纠结，那边又在催说数据怎么没有了，还说一定得找回来。
这下我更急了，晚饭都没心情吃。
 
这时，我找到了一些专门帮人恢复数据的技术人员。
他问了我数据量，数据库引擎，当我说是‘myisam’时，他来了句：那无解了。。
当时我一下子懵了。
 
情急之下，我想到了，之前在testing服务器里面有一个副本数据库，但是那里的数据已经有些时日了，根本没有最新一个月的数据。
这根本无法解救我！
 
这里我在phpmyadmin中看到了这个：
 
脑里出来了google上说的用二进制恢复，就点开看一下。结果大喜！OMG，服务器开通了日志！
里面有数据库的操作日志，而且还是sql格式的！！！
我之前没有接触过这个东西，但这时它就是我的救命稻草。
我浏览了一下，里面有近一个月的更新记录，已经足够了。不过有一个问题，在phpmyadmin里面看，只能显示其中一小部份内容，面对10几w的数据行，想要一个个找出被删表的数据，太难了。
 
这时，我想到了可以从服务器中下载这些文件，然后得到其中的数据。
说干就干，我登录服务器，搜索这些二进制文件：
上图中红圈的就是了
 
然后将这些文件一个个导出成可以阅读的sql：
这样将这些二进制文件一个个输出成了正常的sql文件。
 
这时，就是要从这些文件中找到被删表相关的数据了，于是我写了个java程序帮我做这个事情：
[java] view plain copy
print?
  1. package com.nerve.sql.reload;  
  2.    
  3. import java.io.BufferedReader;  
  4. import java.io.BufferedWriter;  
  5. import java.io.FileReader;  
  6. import java.io.FileWriter;  
  7. import java.util.ArrayList;  
  8. import java.util.List;  
  9.    
  10. import org.nerve.util.NumberUtil;  
  11.    
  12. /** 
  13.  * @project: cloudOffice_swing 
  14.  * @file: ReloadWorker.java 
  15.  * @package: com.nerve.sql.reload 
  16.  * @description: 
  17.  *    将二进制日志导出的文件中相应表的操作记录提出出来 
  18.  * @author: 集成显卡    1053214511@qq.com 
  19.  * @date&time: Jan 23, 2014 
  20.  * @change log: 
  21.  */  
  22. public class ReloadWorker {  
  23.       
  24.     public void read(List<String> orgF, String targetF, String table) throws Exception{  
  25.         BufferedWriter bw = new BufferedWriter(new FileWriter(targetF, true));  
  26.           
  27.         for(String or:orgF){  
  28.             BufferedReader br = new BufferedReader(new FileReader(or));  
  29.             String t = null;  
  30.             String t2 = null;  
  31.             table = table.toUpperCase();  
  32.             while((t=br.readLine())!=null){  
  33.                 t2 = t.toUpperCase();  
  34.                 /* 
  35.                  * 如果是update操作，直接提出 
  36.                  */  
  37.                 if(t2.startsWith("UPDATE "+table)){  
  38.                     bw.append(t+"; ");  
  39.                 }  
  40.                 /* 
  41.                  *  如果是insert语句，因为有一些旧服务器的数据 
  42.                  *  所以要先执行delete操作 
  43.                  */  
  44.                 else if(t2.startsWith("INSERT INTO "+table)){  
  45.                     String ids = t2.substring(t2.lastIndexOf(","));  
  46.                     bw.append("delete from "+table+" where id="+NumberUtil.toDigital(ids)+"; ");  
  47.                     bw.append(t+"; ");  
  48.                 }  
  49.                 /* 
  50.                  * sql语句后面都要加 ; ，因为原来没有，不加的话，在导入到数据库时，出错 
  51.                  */  
  52.             }  
  53.             br.close();  
  54.         }  
  55.           
  56.         bw.flush();  
  57.         bw.close();  
  58.     }  
  59.       
  60.     public static void main(String[] args) throws Exception{  
  61.         long sd = System.currentTimeMillis();  
  62.         ReloadWorker w = new ReloadWorker();  
  63.         List<String> orgs = new ArrayList<String>();  
  64.         orgs.add("C:/Users/IBM_ADMIN/Desktop/000015.txt");  
  65.         orgs.add("C:/Users/IBM_ADMIN/Desktop/000016.txt");  
  66.         orgs.add("C:/Users/IBM_ADMIN/Desktop/000017.txt");  
  67.         orgs.add("C:/Users/IBM_ADMIN/Desktop/000018.txt");  
  68.         orgs.add("C:/Users/IBM_ADMIN/Desktop/000019.txt");  
  69.           
  70.         String targetS = "C:/Users/IBM_ADMIN/Desktop/000017_sql.txt";  
  71.         w.read(orgs, targetS, "task");  
  72.           
  73.         System.out.println("DONE, on " +(System.currentTimeMillis() - sd)/1000+" s");  
  74.     }  
  75. }  
package com.nerve.sql.reload;
 
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.FileReader;
import java.io.FileWriter;
import java.util.ArrayList;
import java.util.List;
 
import org.nerve.util.NumberUtil;
 
/**
 * @project: cloudOffice_swing
 * @file: ReloadWorker.java
 * @package: com.nerve.sql.reload
 * @description:
 *    将二进制日志导出的文件中相应表的操作记录提出出来
 * @author: 集成显卡    1053214511@qq.com
 * @date&time: Jan 23, 2014
 * @change log:
 */
public class ReloadWorker {
    
    public void read(List<String> orgF, String targetF, String table) throws Exception{
        BufferedWriter bw = new BufferedWriter(new FileWriter(targetF, true));
        
        for(String or:orgF){
            BufferedReader br = new BufferedReader(new FileReader(or));
            String t = null;
            String t2 = null;
            table = table.toUpperCase();
            while((t=br.readLine())!=null){
                t2 = t.toUpperCase();
                /*
                 * 如果是update操作，直接提出
                 */
                if(t2.startsWith("UPDATE "+table)){
                    bw.append(t+";
");
                }
                /*
                 *  如果是insert语句，因为有一些旧服务器的数据
                 *  所以要先执行delete操作
                 */
                else if(t2.startsWith("INSERT INTO "+table)){
                    String ids = t2.substring(t2.lastIndexOf(","));
                    bw.append("delete from "+table+" where id="+NumberUtil.toDigital(ids)+";
");
                    bw.append(t+";
");
                }
                /*
                 * sql语句后面都要加 ; ，因为原来没有，不加的话，在导入到数据库时，出错
                 */
            }
            br.close();
        }
        
        bw.flush();
        bw.close();
    }
    
    public static void main(String[] args) throws Exception{
        long sd = System.currentTimeMillis();
        ReloadWorker w = new ReloadWorker();
        List<String> orgs = new ArrayList<String>();
        orgs.add("C:/Users/IBM_ADMIN/Desktop/000015.txt");
        orgs.add("C:/Users/IBM_ADMIN/Desktop/000016.txt");
        orgs.add("C:/Users/IBM_ADMIN/Desktop/000017.txt");
        orgs.add("C:/Users/IBM_ADMIN/Desktop/000018.txt");
        orgs.add("C:/Users/IBM_ADMIN/Desktop/000019.txt");
        
        String targetS = "C:/Users/IBM_ADMIN/Desktop/000017_sql.txt";
        w.read(orgs, targetS, "task");
        
        System.out.println("DONE, on " +(System.currentTimeMillis() - sd)/1000+" s");
    }
}

　　

得到了汇总的sql文件后，就导入到数据库中。
最后，出一个运行图：
 
终于松了一口气。（虽然这次导入花了5分钟。。）
 
最后提醒大家，一定要常备份，谨慎操作啊！
 
-----------------------------------------------------------
转载请注明出处：http://blog.csdn.net/ssrc0604hx/article/details/18717983
【推广】 免费学中医，健康全家人
原文地址：https://www.cnblogs.com/lvchenfeng/p/5256700.html