package com.java110.job.task.backupDatabase;
|
|
import com.java110.dto.task.TaskDto;
|
import com.java110.job.quartz.TaskSystemQuartz;
|
import com.java110.utils.cache.MappingCache;
|
import com.java110.utils.util.StringUtil;
|
import org.slf4j.Logger;
|
import com.java110.core.log.LoggerFactory;
|
import org.springframework.stereotype.Component;
|
|
import java.io.File;
|
import java.io.FileInputStream;
|
import java.text.SimpleDateFormat;
|
import java.util.Date;
|
|
/**
|
* 备份数据库定时任务
|
*
|
* @author fqz
|
* @date 2021-08-04 14:36
|
*/
|
@Component
|
public class BackupDatabaseTemplate extends TaskSystemQuartz {
|
|
private static Logger logger = LoggerFactory.getLogger(BackupDatabaseTemplate.class);
|
|
//域
|
public static final String DOMAIN_COMMON = "DOMAIN.COMMON";
|
|
//键(tt)
|
public static final String BACKUP_DATABASE = "TT_BACKUP_DATABASE";
|
|
//键(hc_community)
|
public static final String HC_COMMUNITY_BACKUP_DATABASE = "HC_COMMUNITY_BACKUP_DATABASE";
|
|
//键(备份的数据库文件存储位置)
|
public static final String FILE_LOCATION = "FILE_LOCATION";
|
|
//键(区分windows和linux操作系统)
|
public static final String LINUX_OR_WINDOWS = "LINUX_OR_WINDOWS";
|
|
@Override
|
protected void process(TaskDto taskDto) throws Exception {
|
logger.debug("======开始执行数据库备份======" + taskDto.toString());
|
//取出tt库开关映射的值
|
String val = MappingCache.getValue(DOMAIN_COMMON, BACKUP_DATABASE);
|
//取出hc_community库开关映射的值
|
String hcVal = MappingCache.getValue(DOMAIN_COMMON, HC_COMMUNITY_BACKUP_DATABASE);
|
//取出数据库文件存储位置
|
String fileUrl = MappingCache.getValue(DOMAIN_COMMON, FILE_LOCATION);
|
if (StringUtil.isEmpty(fileUrl)) {
|
throw new IllegalArgumentException("文件存储位置不能为空！");
|
}
|
//备份tt库
|
if (!StringUtil.isEmpty(val)) {
|
String[] split = val.split("&");
|
String userName = split[0];
|
String password = split[1];
|
String databaseName = split[2];
|
String port = split[3];
|
String backName = new SimpleDateFormat("yyyy-MM-dd-HH-mm-ss").format(new Date()) + "-tt.sql";
|
BackupDatabaseTemplate.dbBackUp(userName, password, databaseName, fileUrl, backName, port);
|
}
|
//备份hc_community库
|
if (!StringUtil.isEmpty(hcVal)) {
|
String[] split = val.split("&");
|
String userName = split[0];
|
String password = split[1];
|
String databaseName = split[2];
|
String port = split[3];
|
String backName = new SimpleDateFormat("yyyy-MM-dd-HH-mm-ss").format(new Date()) + "-hc_community.sql";
|
BackupDatabaseTemplate.dbBackUp(userName, password, databaseName, fileUrl, backName, port);
|
}
|
}
|
|
/**
|
* 导出tt数据库
|
*
|
* @param userName
|
* @param password
|
* @param dbName
|
* @param backPath
|
* @param backName
|
* @param port
|
* @throws Exception
|
*/
|
public static void dbBackUp(String userName, String password, String dbName, String backPath, String backName, String port) throws Exception {
|
//获取操作系统区分标识
|
String operatingSystem = MappingCache.getValue(DOMAIN_COMMON, LINUX_OR_WINDOWS);
|
String pathSql = backPath + backName;
|
//创建备份sql文件
|
try {
|
File file = new File(pathSql);
|
System.out.println("======文件位置======：" + file);
|
if (!file.exists()) {
|
file.createNewFile();
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
|
StringBuffer sb = new StringBuffer();
|
sb.append("mysqldump");
|
sb.append(" -h" + port);
|
sb.append(" -u" + userName);
|
sb.append(" -p" + password);
|
sb.append(" " + dbName + " >");
|
sb.append(" " + pathSql);
|
System.out.println("======命令为======：" + sb.toString());
|
Runtime runtime = Runtime.getRuntime();
|
System.out.println("======开始备份数据库======：" + dbName);
|
if (!StringUtil.isEmpty(operatingSystem) && operatingSystem.equals("1")) { //1表示windows操作系统
|
Process process = runtime.exec("cmd /c" + sb.toString());
|
System.out.println("======返回结果======:" + process.toString());
|
} else if (!StringUtil.isEmpty(operatingSystem) && operatingSystem.equals("2")) { //2表示linux操作系统
|
Process process = runtime.exec("/home/mysql/mysql/bin/" + sb.toString());
|
System.out.println("======返回结果======:" + process.toString());
|
}
|
System.out.println("======备份数据库" + dbName + "成功!======");
|
}
|
|
}
|
