核心是mysqldump和Runtime
操作其实并不是很困难,创建一个进行备份操作的类,接收到备份调用后,标记该表正在备份,然后创建一个子线程进行备份操作。所需的配置信息是从配置文件读取的,也要注意在Windows和linux下路径问题。
配置文件如下:
# 数据库地址 dbAddress=localhost # 要备份的数据库名称 databaseName=nms # 数据库用户名 username = root # 数据库密码 password = root # mysqldump 路径 Linux mysqlpath = /usr/bin/ # 备份文件存放位置 Linux sqlFilePath =/MySQlBack/ # mysqldump 路径 Windows #mysqlpath = C\://Program Files//MySQL//MySQL Server 5.5//bin// # 备份文件存放位置 Windows #sqlFilePath =C\://MySQl//
执行功能的代码类如下:
package com.nms.common.db; import java.io.File; import java.io.IOException; import java.io.InputStream; import java.util.Map; import java.util.Properties; import java.util.concurrent.ConcurrentHashMap; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; /** * 用于数据库备份操作 */ public class DbBackUpMethod { private static Log logger = LogFactory.getLog(DbBackUpMethod.class); private static Properties pros = getPprVue("db.properties"); public static Map<String, String> backUpTableList = new ConcurrentHashMap<String, String>(); private static DbBackUpMethod backObj = new DbBackUpMethod(); public static DbBackUpMethod getDbBackUpMethod(){ return backObj; } public void backup(String tableName) { if(null != backUpTableList.get(tableName)) return ; backUpTableList.put(tableName, tableName); // 标记已经用于备份 new Thread(new DbBackUpThread(tableName)).start(); } /** * 用于执行某表的备份 */ class DbBackUpThread implements Runnable { String tableName = null; public DbBackUpThread(String tableName){ this.tableName = tableName; } @Override public void run() { try { String username = pros.getProperty("username"); String password = pros.getProperty("password"); String mysqlpaths = pros.getProperty("mysqlpath"); String address = pros.getProperty("dbAddress"); String databaseName = pros.getProperty("databaseName"); String sqlpath = pros.getProperty("sqlFilePath"); File backupath = new File(sqlpath); if (!backupath.exists()) { backupath.mkdir(); } StringBuffer sb = new StringBuffer(); sb.append(mysqlpaths); sb.append("mysqldump "); sb.append("--opt "); sb.append("-h "); sb.append(address); sb.append(" "); sb.append("--user="); sb.append(username); sb.append(" "); sb.append("--password="); sb.append(password); sb.append(" "); sb.append("--lock-all-tables=true "); sb.append("--result-file="); sb.append(sqlpath); sb.append(tableName+".sql"); sb.append(" "); sb.append("--default-character-set=utf8 "); sb.append(databaseName); sb.append(" "); sb.append(tableName); Runtime cmd = Runtime.getRuntime(); Process p = cmd.exec(sb.toString()); p.waitFor(); // 该语句用于标记,如果备份没有完成,则该线程持续等待 } catch (Exception e) { logger.error("备份操作出现问题", e); }finally{ backUpTableList.remove(tableName); // 最终都将解除 } } } public static Properties getPprVue(String properName) { InputStream inputStream = DbBackUpMethod.class.getClassLoader().getResourceAsStream(properName); Properties p = new Properties(); try { p.load(inputStream); inputStream.close(); } catch (IOException e) { logger.error("无法读取用于备份数据的配置文件", e); } return p; } }
在Action中,可以直接调用备份操作方法:
DbBackUpMethod.getDbBackUpMethod().backup(tableName); // 调用备份
同时,如果页面有删除该表的操作,在操作前应该判断该表是否在进行备份
if(null != DbBackUpMethod.backUpTableList.get(tableName))
然后页面JSP调用时,可以给予响应的提示,我的判断是只能删除一张表:
function deleteTableByTableName(){ var pk = table.getSelectedKeys(); if(""==pk){ alert("请选择一条记录!"); return false; } if(pk.length > 1){ alert("请选择一条记录!"); return false; } var rows = table.get(pk); var tableName=rows.tableName; if(confirm("你确认要删除该表吗?")) { if(confirm("删除该表前,你需要备份操作吗?\n\n选择备份后,系统将后台进行相关操作!\n在此期间,您不能删除该表!\n备份操作可能将持续数小时时间!请知晓!")) { document.form1.action="backUpTable.action?tableName=" + tableName; document.form1.submit(); }else{ if(confirm("你确认提交吗?该表将删除!")) { document.form1.action="del.action?tableName=" + tableName; document.form1.submit(); } } } }
请您到ITEYE网站看 java小强 原创,谢谢!
http://cuisuqiang.iteye.com/ !
自建博客地址:http://www.javacui.com/ ,内容与ITEYE同步!
相关推荐
mysql自动备份 mysql自动备份mysql自动备份mysql自动备份
主要介绍了从MySQL全库备份中恢复某个库和某张表的方法,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
具体查询某张表的大小,相对简洁的方法实现表的查询,可以完成表的查询,非常简单简单的完成表的查询,
该文件为bat脚本文件,可以在win10系统下新建定时任务,并且实现自动备份MySQL数据库文件,操作很简单,下载者只需要按照使用说明文档的说明来操作即可。
我们的业务可能会这样要求:某张表是动态的,他要求每隔一段时间(如:一个月)自动生成一张结构相同的新表(如:日志表Log),这是我们要判断数据库中是否存在某张表,如果没有,则新建一张表,否者直接使用即可。...
java实现mysql数据库的表导出到excel文件,已经基本的demo包含jar包,可以导入的eclipse里面。比较好用吧
一个简单JAVA 小工程进行两个MYSQL数据库对象的比较,导入eclipse中,修改jdbc.properties文件中的JDBC信息,然后直接运行action包类中的main方法,生成EXCEL,excel中包含表,表中列,索引,函数过程差异比对结果。...
创建MySQL用户赋予某指定库表的权限[文].pdf
在MySQL中创建dept,emp,salgrade三张表,以供学习测试使用
该系统基于mysql+eclipse+jdk1.6(内部有注释,系统完整) 实现3张表的增删查改操作 简单GUI操作界面 适合课程设计
oracle对某表进行审计,观察对这个表的增删改查等sql操作
在项目开发中,我们经常会对某张表进行增删改查。我们根据条件刷选表中的数据放到gridview中以列表形式展现,同时给gridview添加各种样式,比如一般必用的鼠标经过,鼠标离开颜色变化,行选中等颜色加深,同时给列表...
连接查询是关系数据库中最...当检索数据时,通过连接操作查询出存放在多个表中的不同实体的信息。连接操作给用户带来很大的灵活性,他们可以在任何时候增加新的数据类型。为不同实体创建新的表,然后通过连接进行查询。
#!/bin/bash # 热备份mysql库表,打包文件结构是...如果是只需要还原某张表,则最好手动提取sql后,利用Navicat等工具还原,或者用mysql命令还原。 # 3.备份数据库:./mysqlbackup-v1.sh -t backup -d db1,db2[....]
在公司实际的项目开发中,我遇到这样一个需求,需要将oracle数据库某张表的某两列相加形成新的一列。
用java代码判断一张表在数据库中是否存在............
kettle批量导出mysql数据表,利用kettle的循环批量导出mysql 单个sql表脚本含视图,并生成命令行.source文件
这是quartz的mysql类型的11个管理quartz的建表语句,全部来自于官网下载,全名:tables_mysql_innodb.sql
页面风格:图书管理系统 界面好看风格大方 ,能够学习swing界面代码编写以及jdbc封装操作还有java语法练习 适用人群:学生、初学者、小白、小黑 适用场景:课程设计,课程结束小项目设计、毕业设计等 表结构:三张表...