java实现数据库备份(MySQL基于java实现备份表操作)
java实现数据库备份
MySQL基于java实现备份表操作
核心是mysqldump和Runtime
操作其实并不是很困难,创建一个进行备份操作的类,接收到备份调用后,标记该表正在备份,然后创建一个子线程进行备份操作。所需的配置信息是从配置文件读取的,也要注意在Windows和linux下路径问题。
配置文件如下:
Java代码 收藏代码
# 数据库地址
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//
执行功能的代码类如下:
Java代码 收藏代码
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中,可以直接调用备份操作方法:
Java代码 收藏代码
DbBackUpMethod.getDbBackUpMethod().backup(tableName); // 调用备份
同时,如果页面有删除该表的操作,在操作前应该判断该表是否在进行备份
Java代码 收藏代码
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(); } } } } |
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持开心学习网。
原文链接:https://www.iteye.com/blog/cuisuqiang-1998420
- 深入理解mysql索引(MySQL中冗余和重复索引的区别说明)
- python和mysql实战(由Python编写的MySQL管理工具代码实例)
- mysql数据库基础练习(最全50个Mysql数据库查询练习题)
- thinkphp5怎么设置默认返回(thinkphp5.1框架实现格式化mysql时间戳为日期的方式小结)
- navicat15激活页面不显示(Navicat for MySQL 15注册激活详细教程)
- mysql自增锁(深入剖析 MySQL 自增锁)
- mysql的使用步骤(MySQL infobright的安装步骤)
- mysql经典问题(MySQL null的一些易错点)
- navicatformysql怎么激活(一文读懂navicat for mysql基础知识)
- mysql拼接和过滤(mysql 如何动态修改复制过滤器)
- mysql修改表内字段的数据类型(mysql修改记录时update操作 字段=字段+字符串)
- mysqldump备份缺点(MySQL5.7 mysqldump备份与恢复的实现)
- mysql 操作日志(MySQL中的undo日志)
- mysql 查询都是0的值(MySQL按小时查询数据,没有的补0)
- mysql中length、char_length区别
- mysql单个表可以储存多少内容(浅谈mysql一张表到底能存多少数据)
- 华为 Watch GT2 Pro 智能手表曝光,新增支持无线充电(华为WatchGT2)
- vivo首款智能手表来了 也有血氧饱和度监测,一次充电18天续航(vivo首款智能手表来了)
- 你知道 七夕 的真正含义吗(你知道七夕的真正含义吗)
- 七夕的寓意(七夕的寓意)
- 苏志燮赵恩静结婚,韩国四大公共财产变三人,这么快就有替补了(苏志燮赵恩静结婚)
- 《内在美》后,一大波新韩剧来袭,李钟硕朴信惠宋慧乔玄彬回归(一大波新韩剧来袭)