利用Java进行MySql数据库的导入和导出

本文涉及的产品
云数据库 RDS MySQL,集群系列 2核4GB
推荐场景:
搭建个人博客
RDS MySQL Serverless 基础系列,0.5-2RCU 50GB
RDS MySQL Serverless 高可用系列,价值2615元额度,1个月
简介:

利用Java来进行Mysql数据库的导入和导出的总体思想是通过Java来调用命令窗口执行相应的命令。

  MySql导出数据库的命令如下:

mysqldump -uusername -ppassword -hhost -Pport exportDatabaseName > exportPath

  利用Java调用命令窗口执行命令来进行MySql导入数据库一般分三步走:

  第一步:登录Mysql数据库,在登录数据库的时候也可以指定登录到哪个数据库,如果指定了则可以跳过第二步;

  第二步:切换数据库到需要导入的目标数据库

  第三步:利用命令开始导入

  在进行导出的时候,需要注意命令语句的运行环境,如果已经将mysql安装路径下的bin加入到系统的path变量中,那么在导出的时候可以直接使用命令语句,否则,就需要在执行命令语句的时候加上命令所在位置的路径,即mysql安装路径想的bin下的mysqldump命令。

  基本代码如下:

  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.  * 在进行导出的时候,需要注意命令语句的运行环境,如果已经将mysql安装路径下的bin加入到 
  8.  * 系统的path变量中,那么在导出的时候可以直接使用命令语句,否则,就需要在执行命令语句的 
  9.  * 时候加上命令所在位置的路径,即mysql安装路径想的bin下的mysqldump命令 
  10.  * @author andy 
  11.  * 
  12.  */ 
  13. public class MySqlImportAndExport {  
  14.     public static void main(String args[]) throws IOException {  
  15.         InputStream is = MySqlImportAndExport.class.getClassLoader().getResourceAsStream("jdbc.properties");  
  16.         Properties properties = new Properties();  
  17.         properties.load(is);  
  18. //      MySqlImportAndExport.export(properties);//这里简单点异常我就直接往上抛 
  19.         MySqlImportAndExport.importSql(properties);  
  20.     }  
  21.       
  22.     /** 
  23.      * 根据属性文件的配置导出指定位置的指定数据库到指定位置 
  24.      * @param properties 
  25.      * @throws IOException 
  26.      */ 
  27.     public static void export(Properties properties) throws IOException {  
  28.         Runtime runtime = Runtime.getRuntime();  
  29.         String command = getExportCommand(properties);  
  30.         runtime.exec(command);//这里简单一点异常我就直接往上抛 
  31.     }  
  32.       
  33.     /** 
  34.      * 根据属性文件的配置把指定位置的指定文件内容导入到指定的数据库中 
  35.      * 在命令窗口进行mysql的数据库导入一般分三步走: 
  36.      * 第一步是登到到mysql; mysql -uusername -ppassword -hhost -Pport -DdatabaseName;如果在登录的时候指定了数据库名则会 
  37.      * 直接转向该数据库,这样就可以跳过第二步,直接第三步;  
  38.      * 第二步是切换到导入的目标数据库;use importDatabaseName; 
  39.      * 第三步是开始从目标文件导入数据到目标数据库;source importPath; 
  40.      * @param properties 
  41.      * @throws IOException  
  42.      */ 
  43.     public static void importSql(Properties properties) throws IOException {  
  44.         Runtime runtime = Runtime.getRuntime();  
  45.         //因为在命令窗口进行mysql数据库的导入一般分三步走,所以所执行的命令将以字符串数组的形式出现 
  46.         String cmdarray[] = getImportCommand(properties);//根据属性文件的配置获取数据库导入所需的命令,组成一个数组 
  47.         //runtime.exec(cmdarray);//这里也是简单的直接抛出异常 
  48.         Process process = runtime.exec(cmdarray[0]);  
  49.         //执行了第一条命令以后已经登录到mysql了,所以之后就是利用mysql的命令窗口 
  50.         //进程执行后面的代码 
  51.         OutputStream os = process.getOutputStream();  
  52.         OutputStreamWriter writer = new OutputStreamWriter(os);  
  53.         //命令1和命令2要放在一起执行 
  54.         writer.write(cmdarray[1] + "\r\n" + cmdarray[2]);  
  55.         writer.flush();  
  56.         writer.close();  
  57.         os.close();  
  58.     }  
  59.       
  60.     /** 
  61.      * 利用属性文件提供的配置来拼装命令语句 
  62.      * 在拼装命令语句的时候有一点是需要注意的:一般我们在命令窗口直接使用命令来 
  63.      * 进行导出的时候可以简单使用“>”来表示导出到什么地方,即mysqldump -uusername -ppassword databaseName > exportPath, 
  64.      * 但在Java中这样写是不行的,它需要你用-r明确的指出导出到什么地方,如: 
  65.      * mysqldump -uusername -ppassword databaseName -r exportPath。 
  66.      * @param properties 
  67.      * @return 
  68.      */ 
  69.     private static String getExportCommand(Properties properties) {  
  70.         StringBuffer command = new StringBuffer();  
  71.         String username = properties.getProperty("jdbc.username");//用户名 
  72.         String password = properties.getProperty("jdbc.password");//用户密码 
  73.         String exportDatabaseName = properties.getProperty("jdbc.exportDatabaseName");//需要导出的数据库名 
  74.         String host = properties.getProperty("jdbc.host");//从哪个主机导出数据库,如果没有指定这个值,则默认取localhost 
  75.         String port = properties.getProperty("jdbc.port");//使用的端口号 
  76.         String exportPath = properties.getProperty("jdbc.exportPath");//导出路径 
  77.           
  78.         //注意哪些地方要空格,哪些不要空格 
  79.         command.append("mysqldump -u").append(username).append(" -p").append(password)//密码是用的小p,而端口是用的大P。 
  80.         .append(" -h").append(host).append(" -P").append(port).append(" ").append(exportDatabaseName).append(" -r ").append(exportPath);  
  81.         return command.toString();  
  82.     }  
  83.       
  84.     /** 
  85.      * 根据属性文件的配置,分三步走获取从目标文件导入数据到目标数据库所需的命令 
  86.      * 如果在登录的时候指定了数据库名则会 
  87.      * 直接转向该数据库,这样就可以跳过第二步,直接第三步;  
  88.      * @param properties 
  89.      * @return 
  90.      */ 
  91.     private static String[] getImportCommand(Properties properties) {  
  92.         String username = properties.getProperty("jdbc.username");//用户名 
  93.         String password = properties.getProperty("jdbc.password");//密码 
  94.         String host = properties.getProperty("jdbc.host");//导入的目标数据库所在的主机 
  95.         String port = properties.getProperty("jdbc.port");//使用的端口号 
  96.         String importDatabaseName = properties.getProperty("jdbc.importDatabaseName");//导入的目标数据库的名称 
  97.         String importPath = properties.getProperty("jdbc.importPath");//导入的目标文件所在的位置 
  98.         //第一步,获取登录命令语句 
  99.         String loginCommand = new StringBuffer().append("mysql -u").append(username).append(" -p").append(password).append(" -h").append(host)  
  100.         .append(" -P").append(port).toString();  
  101.         //第二步,获取切换数据库到目标数据库的命令语句 
  102.         String switchCommand = new StringBuffer("use ").append(importDatabaseName).toString();  
  103.         //第三步,获取导入的命令语句 
  104.         String importCommand = new StringBuffer("source ").append(importPath).toString();  
  105.         //需要返回的命令语句数组 
  106.         String[] commands = new String[] {loginCommand, switchCommand, importCommand};  
  107.         return commands;  
  108.     }  
  109.       
  110. }

  上述使用的jdbc.properties文件

  1. jdbc.username=root  
  2. jdbc.password=password 
  3. jdbc.host=localhost  
  4. jdbc.port=3306  
  5. jdbc.exportDatabaseName=dbName  
  6. jdbc.exportPath=d\:\\dbName.sql  
  7. jdbc.importDatabaseName=test  
  8. jdbc.importPath=d\:\\dbName.sql


本文出自seven的测试人生公众号最新内容请见作者的GitHub页:http://qaseven.github.io/

相关实践学习
如何快速连接云数据库RDS MySQL
本场景介绍如何通过阿里云数据管理服务DMS快速连接云数据库RDS MySQL,然后进行数据表的CRUD操作。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心,利用清洁计算为万物互联的新世界提供源源不断的能源动力,目前开服的区域包括中国(华北、华东、华南、香港)、新加坡、美国(美东、美西)、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程,来了解阿里云能够为你的业务带来哪些帮助     相关的阿里云产品:云服务器ECS 云服务器 ECS(Elastic Compute Service)是一种弹性可伸缩的计算服务,助您降低 IT 成本,提升运维效率,使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
相关文章
Java mysql根据很长的富文本如何自动获取简介
通过使用Jsoup解析富文本并提取纯文本,然后根据需要生成简介,可以有效地处理和展示长文本内容。该方法简单高效,适用于各种应用场景。希望本文对您在Java中处理富文本并生成简介的需求提供实用的指导和帮助。
51 14
Java mysql根据很长的富文本如何自动获取简介
通过使用Jsoup解析富文本并提取纯文本,然后根据需要生成简介,可以有效地处理和展示长文本内容。该方法简单高效,适用于各种应用场景。希望本文对您在Java中处理富文本并生成简介的需求提供实用的指导和帮助。
32 9
Linux下mysql数据库的导入与导出以及查看端口
本文详细介绍了在Linux下如何导入和导出MySQL数据库,以及查看MySQL运行端口的方法。通过这些操作,用户可以轻松进行数据库的备份与恢复,以及确认MySQL服务的运行状态和端口。掌握这些技能,对于日常数据库管理和维护非常重要。
91 8
Liunx部署java项目Tomcat、Redis、Mysql教程
本文详细介绍了如何在 Linux 服务器上安装和配置 Tomcat、MySQL 和 Redis,并部署 Java 项目。通过这些步骤,您可以搭建一个高效稳定的 Java 应用运行环境。希望本文能为您在实际操作中提供有价值的参考。
148 26
java版药品不良反应智能监测系统源码,采用SpringBoot、Vue、MySQL技术开发
基于B/S架构,采用Java、SpringBoot、Vue、MySQL等技术自主研发的ADR智能监测系统,适用于三甲医院,支持二次开发。该系统能自动监测全院患者药物不良反应,通过移动端和PC端实时反馈,提升用药安全。系统涵盖规则管理、监测报告、系统管理三大模块,确保精准、高效地处理ADR事件。
【深入了解MySQL】优化查询性能与数据库设计的深度总结
本文详细介绍了MySQL查询优化和数据库设计技巧,涵盖基础优化、高级技巧及性能监控。
26 0
数据库传奇:MySQL创世之父的两千金My、Maria
《数据库传奇:MySQL创世之父的两千金My、Maria》介绍了MySQL的发展历程及其分支MariaDB。MySQL由Michael Widenius等人于1994年创建,现归Oracle所有,广泛应用于阿里巴巴、腾讯等企业。2009年,Widenius因担心Oracle收购影响MySQL的开源性,创建了MariaDB,提供额外功能和改进。维基百科、Google等已逐步替换为MariaDB,以确保更好的性能和社区支持。掌握MariaDB作为备用方案,对未来发展至关重要。
59 3
MySQL崩溃保险箱:探秘Redo/Undo日志确保数据库安全无忧!
《MySQL崩溃保险箱:探秘Redo/Undo日志确保数据库安全无忧!》介绍了MySQL中的三种关键日志:二进制日志(Binary Log)、重做日志(Redo Log)和撤销日志(Undo Log)。这些日志确保了数据库的ACID特性,即原子性、一致性、隔离性和持久性。Redo Log记录数据页的物理修改,保证事务持久性;Undo Log记录事务的逆操作,支持回滚和多版本并发控制(MVCC)。文章还详细对比了InnoDB和MyISAM存储引擎在事务支持、锁定机制、并发性等方面的差异,强调了InnoDB在高并发和事务处理中的优势。通过这些机制,MySQL能够在事务执行、崩溃和恢复过程中保持
71 3
数据库灾难应对:MySQL误删除数据的救赎之道,技巧get起来!之binlog
《数据库灾难应对:MySQL误删除数据的救赎之道,技巧get起来!之binlog》介绍了如何利用MySQL的二进制日志(Binlog)恢复误删除的数据。主要内容包括: 1. **启用二进制日志**:在`my.cnf`中配置`log-bin`并重启MySQL服务。 2. **查看二进制日志文件**:使用`SHOW VARIABLES LIKE 'log_%';`和`SHOW MASTER STATUS;`命令获取当前日志文件及位置。 3. **创建数据备份**:确保在恢复前已有备份,以防意外。 4. **导出二进制日志为SQL语句**:使用`mysqlbinlog`
89 2
Python处理数据库:MySQL与SQLite详解 | python小知识
本文详细介绍了如何使用Python操作MySQL和SQLite数据库,包括安装必要的库、连接数据库、执行增删改查等基本操作,适合初学者快速上手。
267 15