概要
Springboot执行shell命令备份数据库。
1、查看mysql版本
mysql --version
2、相关依赖
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>cn.hutool</groupId>
<artifactId>hutool-all</artifactId>
<version>5.8.20</version>
</dependency>
3、具体代码
import cn.hutool.core.io.FileUtil;
import cn.hutool.core.io.IoUtil;
import lombok.SneakyThrows;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.core.io.Resource;
import org.springframework.stereotype.Component;
import java.io.BufferedReader;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.time.LocalDate;
import org.springframework.core.io.ResourceLoader;
@Component
@Slf4j
public class BackupJob {
//数据库连接地址
@Value("${spring.datasource.url}")
private String dbUrl;
//数据库名
@Value("${spring.datasource.name}")
private String dbName;
//用户名
@Value("${spring.datasource.username}")
private String dbUserName;
//密码
@Value("${spring.datasource.password}")
private String dbPassWord;
//存放路径
@Value("${backup.path}")
private String filePath;
// 在你的类中注入ResourceLoader,用来获取备份的sql文件
@Autowired
private ResourceLoader resourceLoader;
/**
* 数据库版本是否为 8.0 + (false=否 true=是), mysql8+ 需要参数 --column-statistics=0 , mysql8- 不需要
* 新版的mysqldump默认启用了一个新标志,通过--column-statistics=0来禁用
*/
boolean isDbVersion8 = true;
@SneakyThrows
public void backup() {
log.info("【备份数据库】--START");
String dbUrl2 = dbUrl.replace("jdbc:mysql://", "");
// 获取数据库地址
String[] serverPath = dbUrl2.substring(0, dbUrl2.indexOf("/")).split(":");
String ip = serverPath[0];
String port = serverPath[1];
// 数据库账号
String username = dbUserName;
// 数据库密码
String password = dbPassWord;
String dbParam = "";
// 备份文件目录+名称 备份文件存放目录+名称(名称 = 数据库名+时间字符串.sql)
String timeStr = LocalDate.now().toString();
String pathFileName = filePath + dbName + "_" + timeStr + ".sql";
String newCmd = "mysqldump -h{SERVER-PATH} -P{SERVER-PORT} -u{USERNAME} -p{PASSWORD} {DBNAME} {DB-PARAM} > {FILEPATH}";
if(isDbVersion8){
dbParam = "--column-statistics=0";
}
// 执行命令
newCmd = newCmd.replace("{USERNAME}", username)
.replace("{PASSWORD}", password)
.replace("{SERVER-PATH}", ip)
.replace("{DBNAME}", dbName)
.replace("{SERVER-PORT}", port)
.replace("{FILEPATH}", pathFileName)
.replace("{DB-PARAM}", dbParam);
//这里打印出来的命令是可以直接在 终端执行的。
System.out.println(newCmd);
System.out.println(pathFileName);
// 创建进程构建器
ProcessBuilder processBuilder = new ProcessBuilder();
// 设置命令和参数
processBuilder.command(getOsShell(), "-c" , newCmd);
// processBuilder.command(getOsShell(), "/c" , newCmd);
// 启动进程
Process process = processBuilder.start();
// 获取命令执行的输出流
InputStream inputStream = process.getInputStream();
BufferedReader reader = new BufferedReader(new InputStreamReader(inputStream));
// 读取输出
String line;
while ((line = reader.readLine()) != null) {
log.info(line);
}
// 等待命令执行完成
int exitCode = process.waitFor();
System.out.println("命令执行完成,退出码:" + exitCode);
if (exitCode == 0) {
log.info("数据库备份成功!");
} else {
log.info("数据库备份失败!");
}
//TODO 获取文件备份的文件、上传到云服务。
// Resource resource = resourceLoader.getResource("file:" + pathFileName);
// InputStream inputStream = resource.getInputStream();
// byte[] bytes = IoUtil.readBytes(resource.getInputStream());
//TODO 同步备份记录到数据库
//TODO 删除指定文件
// FileUtil.del(pathFileName);
}
public String getOsShell() {
String osName = System.getProperty("os.name");
// TODO Windows未测试
if (osName.toLowerCase().contains("windows")) {
return "cmd.exe";
} else if (osName.toLowerCase().contains("mac")) {
return "/bin/bash";
} else if (osName.toLowerCase().contains("linux")) {
return "/bin/bash";
}
return "";
}
}
技术细节
主要就是使用ProcessBuilder创建系统进程,执行终端命令。