利⽤Java进⾏MySql数据库的导⼊和导出利⽤Java来进⾏Mysql数据库的导⼊和导出的总体思想是通过Java来调⽤命令窗⼝执⾏相应的命令。
MySql导出数据库的命令如下：
Sql代码
1. mysqldump -uusername -ppassword -hhost -Pport exportDatabaseName > exportPath
利⽤Java调⽤命令窗⼝执⾏命令来进⾏MySql导⼊数据库⼀般分三步⾛：
第⼀步：登录Mysql数据库，在登录数据库的时候也可以指定登录到哪个数据库，如果指定了则可以跳过第⼆步；第⼆步：切换数据库到需要导⼊的⽬标数据库
第三步：利⽤命令开始导⼊
在进⾏导出的时候，需要注意命令语句的运⾏环境，如果已经将mysql安装路径下的bin加⼊到
系统的path变量中，那么在导出的时候可以直接使⽤命令语句，否则，就需要在执⾏命令语句的
时候加上命令所在位置的路径，即mysql安装路径想的bin下的mysqldump命令。
基本代码如下：
Java代码
1. import java.io.IOException;
2. import java.io.InputStream;
3. import java.io.OutputStream;
4. import java.io.OutputStreamWriter;
5. import java.util.Properties;
6.
7. /**
8. * 在进⾏导出的时候，需要注意命令语句的运⾏环境，如果已经将mysql安装路径下的bin加⼊到
9. * 系统的path变量中，那么在导出的时候可以直接使⽤命令语句，否则，就需要在执⾏命令语句的
10. * 时候加上命令所在位置的路径，即mysql安装路径想的bin下的mysqldump命令
11. * @author andy
12. *
13. */
14. public class MySqlImportAndExport {
15.
16. public static void main(String args[]) throws IOException {
17. InputStream is = ClassLoader().getResourceAsStream("jdbc.properties");
18. Properties properties = new Properties();
19. properties.load(is);
20. // port(properties);//这⾥简单点异常我就直接往上抛
21. MySqlImportAndExport.importSql(properties);
22. }
23.
24. /**
25. * 根据属性⽂件的配置导出指定位置的指定数据库到指定位置
26. * @param properties
27. * @throws IOException
28. */
29. public static void export(Properties properties) throws IOException {
30. Runtime runtime = Runtime();
31. String command = getExportCommand(properties);
32. (command);//这⾥简单⼀点异常我就直接往上抛
33. }
34.
35. /**
36. * 根据属性⽂件的配置把指定位置的指定⽂件内容导⼊到指定的数据库中
37. * 在命令窗⼝进⾏mysql的数据库导⼊⼀般分三步⾛：
38. * 第⼀步是登到到mysql； mysql -uusername -ppassword -hhost -Pport -DdatabaseName；如果在登录的时候指定
了数据库名则会
39. * 直接转向该数据库，这样就可以跳过第⼆步，直接第三步；
40. * 第⼆步是切换到导⼊的⽬标数据库；use importDatabaseName；
41. * 第三步是开始从⽬标⽂件导⼊数据到⽬标数据库；source importPath；
42. * @param properties
43. * @throws IOException
44. */
45. public static void importSql(Properties properties) throws IOException {
46. Runtime runtime = Runtime();
47. //因为在命令窗⼝进⾏mysql数据库的导⼊⼀般分三步⾛，所以所执⾏的命令将以字符串数组的形式出现
48. String cmdarray[] = getImportCommand(properties);//根据属性⽂件的配置获取数据库导⼊所需的命令，组成⼀个
数组
49. //(cmdarray);//这⾥也是简单的直接抛出异常
50. Process process = (cmdarray[0]);
50. Process process = (cmdarray[0]);
51. //执⾏了第⼀条命令以后已经登录到mysql了，所以之后就是利⽤mysql的命令窗⼝
52. //进程执⾏后⾯的代码
53. OutputStream os = OutputStream();
54. OutputStreamWriter writer = new OutputStreamWriter(os);
55. //命令1和命令2要放在⼀起执⾏
56. writer.write(cmdarray[1] + "\r\n" + cmdarray[2]);
57. writer.flush();
58. writer.close();
59. os.close();
60. }
61.
62. /**
63. * 利⽤属性⽂件提供的配置来拼装命令语句
64. * 在拼装命令语句的时候有⼀点是需要注意的：⼀般我们在命令窗⼝直接使⽤命令来
65. * 进⾏导出的时候可以简单使⽤“>”来表⽰导出到什么地⽅，即mysqldump -uusername -ppassword databaseName
> exportPath，
66. * 但在Java中这样写是不⾏的，它需要你⽤-r明确的指出导出到什么地⽅，如：
67. * mysqldump -uusername -ppassword databaseName -r exportPath。
68. * @param properties
69. * @return
70. */
71. private static String getExportCommand(Properties properties) {
72. StringBuffer command = new StringBuffer();
73. String username = Property("jdbc.username");//⽤户名
74. String password = Property("jdbc.password");//⽤户密码
75. String exportDatabaseName = Property("portDatabaseName");//需要导出的数据库名
76. String host = Property("jdbc.host");//从哪个主机导出数据库，如果没有指定这个值，则默认取localh
ost
77. String port = Property("jdbc.port");//使⽤的端⼝号
78. String exportPath = Property("portPath");//导出路径
79.
80. //注意哪些地⽅要空格，哪些不要空格
81. command.append("mysqldump -u").append(username).append(" -p").append(password)//密码是⽤的⼩p，⽽端
⼝是⽤的⼤P。
82. .append(" -h").append(host).append(" -P").append(port).append(" ").append(exportDatabaseName).append(" -r
").append(exportPath);
83. String();
84. }
85.
86. /**
87. * 根据属性⽂件的配置，分三步⾛获取从⽬标⽂件导⼊数据到⽬标数据库所需的命令
88. * 如果在登录的时候指定了数据库名则会
89. * 直接转向该数据库，这样就可以跳过第⼆步，直接第三步；
90. * @param properties
91. * @return
92. */
93. private static String[] getImportCommand(Properties properties) {
94. String username = Property("jdbc.username");//⽤户名
95. String password = Property("jdbc.password");//密码
96. String host = Property("jdbc.host");//导⼊的⽬标数据库所在的主机
97. String port = Property("jdbc.port");//使⽤的端⼝号
98. String importDatabaseName = Property("jdbc.importDatabaseName");//导⼊的⽬标数据库的名称
99. String importPath = Property("jdbc.importPath");//导⼊的⽬标⽂件所在的位置
100. //第⼀步，获取登录命令语句
101. String loginCommand = new StringBuffer().append("mysql -u").append(username).append(" -p").append(pass word).append(" -h").append(host)
102. .append(" -P").append(port).toString();
103. //第⼆步，获取切换数据库到⽬标数据库的命令语句
104. String switchCommand = new StringBuffer("use ").append(importDatabaseName).toString();
105. //第三步，获取导⼊的命令语句
106. String importCommand = new StringBuffer("source ").append(importPath).toString();
java的jdbc连接数据库107. //需要返回的命令语句数组
108. String[] commands = new String[] {loginCommand, switchCommand, importCommand};
109. return commands;
110. }
111.
112. }
上述使⽤的jdbc.properties⽂件
Properties代码
1. jdbc.username=root
2. jdbc.password=password
3. jdbc.host=localhost
4. jdbc.port=3306
5. portDatabaseName=dbName
6. portPath=d\:\\dbName.sql
7. jdbc.importDatabaseName=test
8. jdbc.importPath=d\:\\dbName.sql
版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。
发表评论