package com.itenp.gen.action; import java.io.BufferedReader; import java.io.FileInputStream; import java.io.FileOutputStream; import java.io.InputStream; import java.io.InputStreamReader; import java.io.OutputStreamWriter; import java.text.SimpleDateFormat; import java.util.Date; import java.util.HashMap; import java.util.List; import java.util.Map; import javax.annotation.Resource; import org.apache.log4j.Logger; import org.springframework.context.annotation.Scope; import org.springframework.stereotype.Controller; import com.itenp.gen.common.Constants; import com.itenp.gen.common.ParameterUtil; import com.itenp.gen.service.i.BackUpServiceI; import com.itenp.gen.system.PropertiesCache; import com.itenp.gen.vo.BackUpVO; import com.itenp.gen.vo.UserVO; /** 说明:数据备份还原 * 作者:fhadmin * from www.fhadmin.cn */ @SuppressWarnings("serial") @Scope("prototype") @Controller("backupAction") public class BackUpAction extends BaseAction { private static Logger log = Logger.getLogger(BackUpAction.class); private String databaseDirectory = PropertiesCache.getInstance().getDatabaseDirectory(); //数据库bin路径 private String databaseName = PropertiesCache.getInstance().getDatabaseName();//数据库名 private String userName = PropertiesCache.getInstance().getUserName(); private String userPwd = PropertiesCache.getInstance().getUserPwd(); private String copyDbCmd = PropertiesCache.getInstance().getCopyDbCmd();//数据库备份命令 private String copyprocCmd = PropertiesCache.getInstance().getCopyprocCmd();//存储工程备份命令 private String copyedFilePath = PropertiesCache.getInstance().getCopyedFilePath(); //备份后的文件存放位置 private String restoreCmd = PropertiesCache.getInstance().getRestoreCmd(); //数据库还原命令 private String msg = ""; private String msg1 = ""; private BackUpServiceI service; @Resource(name="backupService") public void setBackupService(BackUpServiceI service){ this.service=service; } @SuppressWarnings("unchecked") public String list() throws Exception { //System.out.println("copyedFilePath"+copyedFilePath); HashMap map = new HashMap(); //得到符合条件的记录List List<BackUpVO> list = (List)service.findList(map); request.setAttribute("list", list); log.debug("####"+PropertiesCache.getInstance().getTemplateDirectory()); // System.out.println(PropertiesCache.getInstance().getTemplateDirectory()); return "success"; } @SuppressWarnings("unchecked") public String backup() throws Exception { Runtime rt = Runtime.getRuntime(); // 调用 mysql 的 cmd: /*System.out.println("数据库bin路径"+databaseDirectory); System.out.println("数据库名"+databaseName); System.out.println("用户名"+userName); System.out.println("密码"+userPwd); System.out.println("数据库备份命令"+copyDbCmd); System.out.println("存储工程备份命令"+copyprocCmd);*/ String str = databaseDirectory+"/"+copyDbCmd+" --no-defaults "+"-u"+userName+" "+"-p"+userPwd+" "+copyprocCmd+" "+"--set-charset=utf-8"+" "+databaseName; //str = "D:\SOFT\MySQL\MySQL Server 5.5\bin/mysqldump -uroot -proot -R --set-charset=utf-8 nlnk"; //System.out.println(str); // Process child = rt.exec(databaseDirectory+"/"+copyDbCmd+" "+"-u"+userName+" "+"-p"+userPwd+" "+copyprocCmd+" "+"--set-charset=utf-8"+" "+databaseName);// 设置导出编码为utf8。这里必须是utf8 Process child = rt.exec(str);// 设置导出编码为utf8。这里必须是utf8 //调用mysql的cmd:备份某个表 // Process childtable = rt // .exec("D:/db/mysql/mysql-5.0.45-win32/bin/mysqldump -uroot -pmysql --set-charset=utf8 ibtts t_a_dbbak");// 设置导出编码为utf8。这里必须是utf8 // Process childtable = rt // .exec(databaseDirectory+"/"+copyDbCmd+" "+"-u"+userName+" "+"-p"+userPwd+" "+"--set-charset=utf8"+" "+databaseName+" "+"t_a_dbbak");// 设置导出编码为utf8。这里必须是utf8 // 把进程执行中的控制台输出信息写入.sql文件,即生成了备份文件。注:如果不对控制台信息进行读出,则会导致进程堵塞无法运行 InputStream in = child.getInputStream();// 控制台的输出信息作为输入流 InputStreamReader xx = new InputStreamReader(in, "utf8");// 设置输出流编码为utf8。这里必须是utf8,否则从流中读入的是乱码 String inStr; StringBuffer sb = new StringBuffer(""); String outStr; // 组合控制台输出信息字符串 BufferedReader br = new BufferedReader(xx); // System.out.println("------------"+br.readLine()); while ((inStr = br.readLine()) != null) { sb.append(inStr + "\r\n"); } outStr = sb.toString(); //判断是否保存成功 if(outStr != null && !outStr.trim().equals("")){ msg="ok"; } //System.out.println("-----"+outStr); //创建文件名称 SimpleDateFormat format = new SimpleDateFormat("yyyyMMddHHmmss"); String today=format.format(new Date()); //String targetDirectory = scontext.getRealPath("/WEB-INF/DBbackup"); // System.out.println(targetDirectory); // 要用来做导入用的sql目标文件:D:/ibtts.sql FileOutputStream fout = new FileOutputStream( copyedFilePath+"/"+today+"ibtts.sql" ); OutputStreamWriter writer = new OutputStreamWriter(fout, "utf8"); writer.write(outStr); // 注:这里如果用缓冲方式写入文件的话,会导致中文乱码,用flush()方法则可以避免 writer.flush(); // 别忘记关闭输入输出流 in.close(); xx.close(); br.close(); writer.close(); fout.close(); // System.out.println("/* Output OK! */"); //数据添加到数据库 HashMap map = new HashMap(); map.put("db_nm", "ibtts"); map.put("bk_nm", today+"ibtts.sql"); map.put("bk_user",((UserVO)session.get(Constants.S_LOGIN_USER)).getUser_id()); service.create(map); // copytable(); return list(); } /** * 数据的恢复 */ @SuppressWarnings("unchecked") public String load() throws Exception { copytable(); //得到页面所有参数 Map<String, String> map = ParameterUtil.getStringMap(request,session); //String targetDirectory = scontext.getRealPath("/WEB-INF/DBbackup"); //获取id后进行查询 BackUpVO vo=(BackUpVO) service.findById(map); String fPath=copyedFilePath+"/"+vo.getBk_nm(); System.out.println(fPath); //map.put("Id", vo.getId()); //String fPath = "D:/ibtts.sql"; Runtime rt = Runtime.getRuntime(); // 调用 mysql 的 cmd: //Process child = rt.exec("D:/db/mysql/mysql-5.0.45-win32/bin/mysql -uroot -pmysql ibtts"); Process child = rt.exec(databaseDirectory+"/"+restoreCmd+" "+"-u"+userName+" "+"-p"+userPwd+" "+databaseName); //System.out.println(databaseDirectory+"/"+restoreCmd+" "+"-u"+userName+" "+"-p"+userPwd+" "+databaseName); java.io.OutputStream out =child.getOutputStream();//控制台的输入信息作为输出流 String inStr; StringBuffer sb = new StringBuffer(""); String outStr; BufferedReader br = new BufferedReader(new InputStreamReader( new FileInputStream(fPath), "utf8")); while ((inStr = br.readLine()) != null) { sb.append(inStr + "\r\n"); } outStr = sb.toString(); OutputStreamWriter writer = new OutputStreamWriter(out, "utf8"); writer.write(outStr); // 注:这里如果用缓冲方式写入文件的话,会导致中文乱码,用flush()方法则可以避免 writer.flush(); // 别忘记关闭输入输出流 out.close(); br.close(); writer.close(); //获取还原用户 map.put("restore_user", ((UserVO)session.get(Constants.S_LOGIN_USER)).getUser_id()); //service.modify(map); restoretable(map); //--------------- //System.out.println(map); //System.out.println("恢复成功"); request.getSession().setAttribute("dbmap", map); msg1 = "tiaozhuan"; return "success"; } //对特定表的处理 public void copytable() throws Exception { Runtime rt = Runtime.getRuntime(); // 调用 mysql 的 cmd: //调用mysql的cmd:备份某个表 //Process child = rt // .exec("D:/db/mysql/mysql-5.0.45-win32/bin/mysqldump -uroot -pmysql --set-charset=utf8 ibtts t_a_dbbak");// 设置导出编码为utf8。这里必须是utf8 Process child = rt.exec(databaseDirectory+"/"+copyDbCmd+" --no-defaults "+"-u"+userName+" "+"-p"+userPwd+" "+"--set-charset=utf8"+" "+databaseName+" "+"t_a_dbbak");// 设置导出编码为utf8。这里必须是utf8 // 把进程执行中的控制台输出信息写入.sql文件,即生成了备份文件。注:如果不对控制台信息进行读出,则会导致进程堵塞无法运行 InputStream in = child.getInputStream();// 控制台的输出信息作为输入流 // System.out.println(databaseDirectory+"/"+copyDbCmd+" --no-defaults "+"-u"+userName+" "+"-p"+userPwd+" "+"--set-charset=utf8"+" "+databaseName+" "+"t_a_dbbak"); InputStreamReader xx = new InputStreamReader(in, "utf8");// 设置输出流编码为utf8。这里必须是utf8,否则从流中读入的是乱码 String inStr; StringBuffer sb = new StringBuffer(""); String outStr; // 组合控制台输出信息字符串 BufferedReader br = new BufferedReader(xx); while ((inStr = br.readLine()) != null) { sb.append(inStr + "\r\n"); } outStr = sb.toString(); //String targetDirectory = scontext.getRealPath("/WEB-INF/DBbackup"); // 要用来做导入用的sql目标文件:D:/ibtts.sql FileOutputStream fout = new FileOutputStream( copyedFilePath+"/"+"ibtts_talbe.sql" ); OutputStreamWriter writer = new OutputStreamWriter(fout, "utf8"); writer.write(outStr); // 注:这里如果用缓冲方式写入文件的话,会导致中文乱码,用flush()方法则可以避免 writer.flush(); // 别忘记关闭输入输出流 in.close(); xx.close(); br.close(); writer.close(); fout.close(); } public void restoretable(Map map) throws Exception { String fPath=copyedFilePath+"/"+"ibtts_talbe.sql"; //String fPath = "D:/ibtts.sql"; Runtime rt = Runtime.getRuntime(); // 调用 mysql 的 cmd: //Process child = rt.exec("D:/db/mysql/mysql-5.0.45-win32/bin/mysql -uroot -pmysql ibtts"); Process child = rt.exec(databaseDirectory+"/"+restoreCmd+" "+"-u"+userName+" "+"-p"+userPwd+" "+databaseName); System.out.println(databaseDirectory+"/"+restoreCmd+" "+"-u"+userName+" "+"-p"+userPwd+" "+databaseName); java.io.OutputStream out =child.getOutputStream();//控制台的输入信息作为输出流 String inStr; StringBuffer sb = new StringBuffer(""); String outStr; BufferedReader br = new BufferedReader(new InputStreamReader( new FileInputStream(fPath), "utf8")); while ((inStr = br.readLine()) != null) { sb.append(inStr + "\r\n"); } outStr = sb.toString(); OutputStreamWriter writer = new OutputStreamWriter(out, "utf8"); writer.write(outStr); // 注:这里如果用缓冲方式写入文件的话,会导致中文乱码,用flush()方法则可以避免 writer.flush(); // 别忘记关闭输入输出流 out.close(); br.close(); writer.close(); //System.out.println(map); /*int sign=0; BackUpVO vo=null; while(vo==null){ vo=(BackUpVO) service.findById(map); if(vo!=null||sign==100){ break; } sign++; } service.modify(map);*/ } @SuppressWarnings("unchecked") public String upbak() throws Exception{ HashMap map = new HashMap(); map = (HashMap)request.getSession().getAttribute("dbmap"); int sign=0; BackUpVO vo=null; while(vo==null){ vo=(BackUpVO) service.findById(map); if(vo!=null||sign==100){ break; } sign++; } service.modify(map); return list(); } public String getMsg() { return msg; } public void setMsg(String msg) { this.msg = msg; } public String getMsg1() { return msg1; } public void setMsg1(String msg1) { this.msg1 = msg1; } }
相关推荐
上述代码展示了如何使用Java来实现MySQL数据库的备份和还原操作。以下是对这些操作的详细解释: 首先,代码导入了多个Java库,包括`java.io`包下的类,用于处理输入/输出流,以及`java.util`包下的类,如`Date`和`...
在Java中实现MySQL数据库备份,主要涉及到以下几个步骤: 1. **连接MySQL**:使用JDBC(Java Database Connectivity)驱动,建立与MySQL服务器的连接。你需要在项目中添加MySQL JDBC驱动的jar包(如`mysql-...
这里我们讨论的“数据库备份及还原Java源码”是一个基于Swing开发的客户端程序,专用于MySQL数据库的备份和恢复操作。下面我们将深入探讨相关知识点。 1. **数据库备份**: - **全量备份**:备份整个数据库,包括...
本文将详细讲解如何使用Java实现基于MySQL数据库的备份与还原操作。 首先,我们了解到数据库备份通常有两种主要的方式:一是使用数据库管理工具(如MySQL的Workbench),二是通过编程方式执行。在Java中,我们可以...
在本文中,我们将介绍 MySQL 数据库备份还原实战操作步骤,包括使用 mysqldump 工具进行备份和恢复数据库的详细指令。 一、备份数据库 mysqldump 是 MySQL 提供的一种备份工具,使用 mysqldump 可以将 MySQL ...
1. **数据库备份**: - **全量备份**:通常通过执行`mysqldump`命令生成SQL脚本或者直接导出二进制日志文件。在Java中,可以使用`Runtime.getRuntime().exec()`方法执行系统命令来调用`mysqldump`。例如,创建一个...
在进行数据库备份和还原时,需要注意以下几点: - **安全性**:确保备份文件的安全存储,避免未经授权的访问。 - **计划**:定期执行备份,根据业务需求确定备份频率(如每天、每周等)。 - **验证**:备份后要验证...
本项目提供了一个基于Java Servlet(jsp)的MySQL数据库数据备份与还原的源代码,帮助用户轻松地完成这一任务。 首先,我们要理解数据库备份的重要性。在日常操作中,由于硬件故障、软件错误、恶意攻击或意外删除等...
Java在线备份和还原MySQL数据库,使用mysqldump命令实现备份,使用mysql命令实现的还原,具体大家看源代码吧,在还原的时候足足整了我一个下午才找到错误原因,源代码里面有写原因。大家看代码就知道了。
利用JDBC连接数据库,不依耐mysql的shell命令, 适合b/s 服务器备份
而`java实现数据库备份说明.txt`文件可能详细阐述了实现备份的具体步骤和技术细节,包括代码示例、配置说明和可能遇到的问题。 在实际项目中,为了提高容灾能力,我们还需要考虑备份的冗余和恢复策略。例如,可以...
JDBC提供了一种标准的方式来连接和操作数据库。首先,你需要在项目中引入MySQL的JDBC驱动,例如通过Maven或Gradle添加对应的依赖。 接下来,我们来看如何编写Java代码来备份MySQL数据库。这通常涉及到执行`...
本文详细介绍了如何使用Java实现MySQL数据库的备份与还原操作。通过上述方法,不仅可以提高数据安全性,还能有效地应对意外情况的发生。此外,对于企业级应用来说,还可以进一步结合自动化工具来实现定期自动备份,...
通过 Java Bean 的封装性,我们可以更方便地管理和操作数据库备份相关的代码。 #### 知识点详解 ##### 1. Java Bean 概述 Java Bean 是一种 Java 类,它遵循特定的编写规范,以便于被其他 Java 程序(如 JSP、...
在Java开发中,有时我们需要对数据库进行备份和还原操作,以确保数据的安全性和可恢复性。本篇将详细介绍如何使用Java来实现SQL Server和MySQL这两种常见数据库的备份与还原功能。 一、基础准备 首先,我们需要在...
总的来说,Java备份和还原数据库涉及到JDBC连接、操作系统命令调用、SQL语句执行等多个方面。了解并掌握这些技术,对于确保数据安全和业务连续性至关重要。同时,根据实际场景选择合适的备份策略,是每个IT专业人员...
总之,使用Java实现MySQL数据库的备份与还原,可以通过调用系统命令结合`mysqldump`和`mysql`工具,同时处理好输入输出流,确保数据的安全传输和存储。在实际操作中,还需要关注性能、安全性以及不同场景下的优化...