java命令行導出、導入sql文件

@IocBean
public class SqlCommandModel{
    
    //用戶名
    @Inject("java:$conf.get('jdbc.username')")
    private String username;
    //用戶密碼  
    @Inject("java:$conf.get('jdbc.password')")
    private String password;
    //從哪個主機導出數據庫，如果沒有指定這個值，則默認取localhost
    @Inject("java:$conf.get('jdbc.host')")
    private String host;
    //使用的端口號 
    @Inject("java:$conf.get('jdbc.port')")
    private String port;
    //  路徑是mysql中 bin 文件 的位置
    @Inject("java:$conf.get('mysqlPath')")
    private String mysqlPath;
    
    //  導出數據庫名稱
    @Inject("java:$conf.get('jdbc.exportDatabaseName')")
    private String exportMysqlDataBase;
    
    //  導入數據庫名稱
    @Inject("java:$conf.get('jdbc.importDatabaseName')")
    private String importDataBase;

    
//    # 用戶名
//    jdbc.username=root  
//    # 數據庫密碼
//    jdbc.password=123456  
//    # localhost 
//    jdbc.host=127.0.0.1
//    # 端口號 
//    jdbc.port=3306  
//    # mysql下的bin文件的路徑  (linux)
//    mysqlPath=usr/local/mysql/bin
//     
//    # 要導出的數據庫名稱
//    jdbc.exportDatabaseName=bankmanaer
//    # 要導入的目標數據庫
//    jdbc.importDatabaseName=bankmanaer
    
    
    /**
     * 獲取導出命令
     * @param exportDatabaseName 表名稱 
     * @param exportPath 導出路徑
     * @return
     */
    public String getExportCommand(String exportDataTableName,String exportPath) {  

          StringBuffer command = new StringBuffer();  
          //注意哪些地方要空格，哪些不要空格  
          command.append("mysqldump -u ").append(username).append(" -p").append(password)//密碼是用的小p，而端口是用的大P。  
          .append(" -h").append(host).append(" -P").append(port).append(" ").append(exportMysqlDataBase + " ").append(exportDataTableName).append(" -r ").append(exportPath);  

//          如果是linux系統上則加上數據庫路徑
//          command.append(mysqlPath).append("mysqldump -u ").append(username).append(" -p").append(password)//密碼是用的小p，而端口是用的大P。  
//          .append(" -h").append(host).append(" -P").append(port).append(" ").append(exportMysqlDataBase + " ").append(exportDataTableName).append(" -r ").append(exportPath);
          
          return command.toString();  
    }
    
    
    // 得到 導入 數據庫的命令
   //  得到 導入數據 的 命令行語句
    /**
     * 
     * @param importPath 導入文件所在路徑
     * @return 
     */
    public  String[] getImportCommand(String importPath) {  

         //第一步，獲取登錄命令語句  
         String loginCommand = new StringBuffer().append("mysql -h").append(host).append(" -u ").append(username).append(" -p").append(password)  
         .append(" -P").append(port).toString(); 
         //第二步，獲取切換數據庫到目標數據庫的命令語句  
         String switchCommand = new StringBuffer().append("use ").append(importDataBase).toString();  
         //第三步，獲取導入的命令語句  
         String importCommand = new StringBuffer(" source ").append(importPath).toString();  
         //需要返回的命令語句數組           

        String[] commands = new String[] {loginCommand, switchCommand, importCommand};

         return commands;  
     }
    
    
    
    public static void main(String[] args) throws InterruptedException, IOException {
        
        SqlCommandModel sqlCommandModel = new SqlCommandModel();
        
        String[] tables = new String[5];
        
        //  這里其實是在命令窗口中執行的 command 命令行
        List<Process> list = new ArrayList<>();
        for (int i = 0; i < tables.length; i++) {
            String exportCommand = sqlCommandModel.getExportCommand(tables[i], "D:\\" + tables[i] + ".sql");
            Runtime runtime = Runtime.getRuntime();  
             //  這里其實是在命令窗口中執行的 command 命令行
             list.add(runtime.exec(exportCommand));
        }
        //等待所有子進程處理完畢
        for (Process process : list) {
            while(process.waitFor() != 0){
                ;
            }
        }
        
    }
    
}