mysql import java_Java执行Mysql导入

深碍√TFBOYSˉ_ 2022-10-31 01:38 129阅读 0赞

String sql = "";

BufferedReader br = new BufferedReader(new FileReader(file));

while ((sql = br.readLine()) != null) \{//使用readLine方法，一次读一行

if (sql.length() > 1) \{

if (isFirstLine) \{

sql = sql.substring(1);

stmt.addBatch(sql);

executeCount++;

isFirstLine = false;

br.close();

缺点：必须一行是一个可执行SQL语句。

2、将上传SQL文件读取到BufferedReader中，调用mysql执行。

Process child = rt.exec("mysql -uroot -proot --default-character-set=utf8 prototype ");

OutputStream out = child.getOutputStream();//控制台的输入信息作为输出流

String line;

StringBuffer sb = new StringBuffer("");

String outStr;

BufferedReader br = new BufferedReader(new InputStreamReader(

new FileInputStream(fPath), "utf8"));

while ((line = br.readLine()) != null) \{

sb.append(line + "\\r\\n");

outStr = sb.toString();

OutputStreamWriter writer = new OutputStreamWriter(out, "utf8");

writer.write(outStr);

// 注：这里如果用缓冲方式写入文件的话，会导致中文乱码，用flush()方法则可以避免

writer.flush();

// 别忘记关闭输入输出流

out.close();

br.close();

writer.close();

3、通过Runtime.exec方法，直接调用mysql导入功能导入。2部操作String username = "root";//用户名

String password = "root";//密码

String host = "localhost";//导入的目标数据库所在的主机

String port = "3306";//使用的端口号

String character = "utf8";// 默认字符集

String importDatabaseName = "prototype";//导入的目标数据库的名称

String importPath = file.getAbsolutePath();//导入的目标文件所在的位置

//第一步，获取登录命令语句

StringBuilder sb = new StringBuilder();

sb.append("mysql -u").append(username);

sb.append(" -p").append(password);

sb.append(" -h").append(host);

sb.append(" -P").append(port);

sb.append(" --default-character-set=").append(character);

String loginCommand = sb.toString();

//第二步，获取切换数据库到目标数据库的命令语句

String switchCommand = new StringBuilder("use ").append(importDatabaseName).toString();

//第三步，获取导入的命令语句

String importCommand = new StringBuilder("source ").append(importPath).toString();

//需要返回的命令语句数组

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

Runtime runtime = Runtime.getRuntime();

Process process = runtime.exec(commands\[0\]);

//执行了第一条命令以后已经登录到mysql了，所以之后就是利用mysql的命令窗口

//进程执行后面的代码

OutputStream os = process.getOutputStream();

OutputStreamWriter writer = new OutputStreamWriter(os);

//命令1和命令2要放在一起执行

writer.write(commands\[1\] + "\\r\\n" + commands\[2\]);

writer.flush();

writer.close();

os.close();

process.destroy();

4、通过Runtime.exec方法，直接调用mysql导入功能导入。1部操作

String cmd = "cmd /c mysql -uroot -proot --default-character-set=utf8 prototype < \\""

\+ file.getAbsolutePath() + "\\"";

Runtime rt = Runtime.getRuntime();

Process p = rt.exec(cmd);

p.waitFor();

p.destroy();

分享到：

![18e900b8666ce6f233d25ec02f95ee59.png][]

![72dd548719f0ace4d5f9bca64e1d7715.png][]

2014-06-05 09:50

分类:数据库

[18e900b8666ce6f233d25ec02f95ee59.png]: /images/20221024/ef23b54faa1341dbbe127266fe46234d.png
[72dd548719f0ace4d5f9bca64e1d7715.png]: /images/20221024/1372369acf294d6ebf57066828ede665.png

mysql import java_Java执行Mysql导入

发表评论取消回复

还没有评论，来说两句吧...

相关阅读

相关数据导入失败：MySQL拒绝执行SQL语句

相关 mysql 执行_MySQL之执行流程

相关 mysql 执行概况_MySQL 执行计划简介

相关 mysql import java_Java执行Mysql导入

相关 import导入包

相关 mysql导入csv文件教程_Mysql导入csv文件_MySQL

相关 mysql怎么导入数据流_MySQL 导入数据

相关 docker 进入mysql容器_Docker进入mysql容器执行数据导入

相关 MySQL执行

相关 MySQL 执行计划和MySQL执行过程