以编程方式通过Java导入(mysql)数据库转储

Ali*_*ehi 15 java mysql database jdbc

如何通过java程序以编程方式导入mysql数据库转储文件(包含insert和create table语句).我需要这个作为单元测试的设置阶段.

不幸的是,这不起作用:

Connection conn = dbConnectionSource.getConnection();
Statement stmt = conn.createStatement();
stmt.execute(FileUtils.readFileToString(new File("./some-sql-file")));
conn.close();
Run Code Online (Sandbox Code Playgroud)

谢谢

PS - 在Rails中,我使用fixture来填充测试数据库.我通过设置要测试的环境来创建底层表来创建底层表,Java中的任何类似的东西.

jvi*_*lta 13

如果您可以在运行导入的任何地方访问mysql可执行文件,则可以从java启动新进程并执行此命令.像这样的东西:

Runtime rt = Runtime.getRuntime();
Process pr = rt.exec("mysql -p -h ServerName DbName < dump.sql");
Run Code Online (Sandbox Code Playgroud)

  • 只是一个修复,我们不能像在java中那样使用重定向:Process pr = rt.exec(new String [] {"/ bin/bash"," - c","mysql -p -h ServerName DbName <dump.sql" }); 谢谢你的回答 :) (2认同)

Hei*_*deh 5

备份:

/******************************************************/
//Database Properties
/******************************************************/
String dbName = “dbName”;
String dbUser = “dbUser”;
String dbPass = “dbPass”;

/***********************************************************/
// Execute Shell Command
/***********************************************************/
String executeCmd = “”;
executeCmd = “mysqldump -u “+dbUser+” -p”+dbPass+” “+dbName+” -r backup.sql”;
}
Process runtimeProcess =Runtime.getRuntime().exec(executeCmd);
int processComplete = runtimeProcess.waitFor();
if(processComplete == 0){

out.println(“Backup taken successfully”);

} else {

out.println(“Could not take mysql backup”);

}
Run Code Online (Sandbox Code Playgroud)

恢复:

/******************************************************/
//Database Properties
/******************************************************/
String dbName = “dbName”;
String dbUser = “dbUser”;
String dbPass = “dbPass”;

/***********************************************************/
// Execute Shell Command
/***********************************************************/
String executeCmd = “”;

executeCmd = new String[]{“/bin/sh”, “-c”, “mysql -u” + dbUser+ ” -p”+dbPass+” ” + dbName+ ” < backup.sql” };

}
Process runtimeProcess =Runtime.getRuntime().exec(executeCmd);
int processComplete = runtimeProcess.waitFor();
if(processComplete == 0){

out.println(“success”);

} else {

out.println(“restore failure”);

}
Run Code Online (Sandbox Code Playgroud)