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();
			}
		}
	}
}

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。