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){

                 ;

             }

         }

     }

 }