jfinalmysql配置文件_JFinal定时备份mysql数据库(mysqldump实现)

1. 配置文件# windows 和  linux 不同

# database_backup_mysqldump &＃61; mysqldump

database_backup_mysqldump &＃61; C:\\Program Files\\MySQL\\MySQL Server 5.7\\bin\\mysqldump.exe

# 数据库配置(路径不以/结尾) 注意:该目录只存放备份SQL,否则会误删其他文件

database_backup_dir &＃61; D:/home/backup

# 清除30天前的备份文件

database_backup_clear_before_days &＃61; 30

# 数据库执行备份的定时任务

cron4j&＃61;mysqlBackup

mysqlBackup.cron&＃61;0 1 * * *

mysqlBackup.class&＃61;com.sohnny.jfinal.task.BackupMySqlTask

mysqlBackup.enable&＃61;true

2.定时备份MySQL任务类import java.io.BufferedReader;

import java.io.BufferedWriter;

import java.io.IOException;

import java.io.InputStreamReader;

import java.nio.file.Files;

import java.nio.file.Path;

import java.nio.file.Paths;

import java.nio.file.StandardOpenOption;

import java.time.LocalDateTime;

import java.time.format.DateTimeFormatter;

import java.util.Date;

import com.jfinal.plugin.activerecord.Db;

import com.jfinal.plugin.activerecord.Record;

import com.jfinal.plugin.cron4j.ITask;

import com.sohnny.MainConfig;

import com.sohnny.jfinal.common.kit.ClearFileKit;

public class BackupMySqlTask implements ITask {

String url &＃61; MainConfig.jdbcProp.get("jdbcUrl");

Path dir &＃61; Paths.get(MainConfig.sysProp.get("database_backup_dir"));

String mysqldump &＃61; MainConfig.sysProp.get("database_backup_mysqldump");

int beforeDays &＃61; MainConfig.sysProp.getInt("database_backup_clear_before_days");

&＃64;Override

public void run() {

//获取IP和PORT

String[] arrays &＃61; url.split("/");

String host &＃61; arrays[2];

String ip, port;

if (host.contains(":")) {

ip   &＃61; host.split(":")[0];

port &＃61; host.split(":")[1];

} else {

ip &＃61; host;

port &＃61; "3306";

}

//获取数据库名称

System.out.println(arrays[3]);

System.out.println(arrays[3].substring(0, arrays[3].indexOf("?")));

String dataBaseName &＃61; arrays[3].substring(0, arrays[3].indexOf("?"));

//创建备份目录

if (!Files.exists(dir)) {

try {

Files.createDirectories(dir);

} catch (IOException e) {

e.printStackTrace();

}

}

//生成备份文件名

String date &＃61; LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH-mm-ss"));

Path path &＃61; Paths.get(dir.toString(), dataBaseName&＃43;"-"&＃43;date&＃43;".sql");

Process process &＃61; null;

try {

String cmd &＃61; mysqldump&＃43;" -h "&＃43;ip&＃43;" -P "&＃43;port&＃43;" -u "&＃43;MainConfig.jdbcProp.get("user")&＃43;" -p"&＃43;MainConfig.jdbcProp.get("password").trim()&＃43;" --databases "&＃43;dataBaseName&＃43;" ";

System.out.println(cmd);

process &＃61; Runtime.getRuntime().exec(cmd);

try (

BufferedReader stdoutReader &＃61; new BufferedReader(new InputStreamReader(process.getInputStream()));

BufferedReader stderrReader &＃61; new BufferedReader(new InputStreamReader(process.getErrorStream()));

) {

backup(stdoutReader, path);

errOut(stderrReader, path);

} catch (IOException e) {

e.printStackTrace();

}

int exitVal &＃61; process.waitFor();

if (exitVal &＃61;&＃61; 0) {

System.out.println("数据库备份完成");

}

} catch (InterruptedException e) {

e.printStackTrace();

} catch (IOException e1) {

e1.printStackTrace();

}

//清除过期文件

ClearFileKit.clearFileByMonth(dir, beforeDays);

// 每次调度启动时&＃xff0c;向 task_run_log 写日志&＃xff0c;用于检查调度的时间是否与预期的一致&＃xff0c;避免出现 bug 却不知道

Record taskRunLog &＃61; new Record().set("taskName", "backupMySql").set("createAt", new Date());

Db.save("task_run_log", taskRunLog);

}

&＃64;Override

public void stop() {

// TODO Auto-generated method stub

}

private void backup (BufferedReader stdReader, Path path) throws IOException {

Path backupPath &＃61; null;

if (Files.notExists(path)) backupPath &＃61; Files.createFile(path);

String line;

try (BufferedWriter bw &＃61; Files.newBufferedWriter(backupPath, StandardOpenOption.WRITE)) {

while ((line &＃61; stdReader.readLine()) !&＃61; null) {

bw.write(line&＃43;"\n");

}

} catch (IOException e) {

e.printStackTrace();

}

}

private void errOut (BufferedReader stdReader, Path path) throws IOException {

String line;

try {

while ((line &＃61; stdReader.readLine()) !&＃61; null) {

System.err.println(line);

}

} catch (IOException e) {

e.printStackTrace();

}

}

public static void main(String[] args) {

new Thread(new BackupMySqlTask()).start();

}

}

3. 清除过期文件类import static java.nio.file.FileVisitResult.CONTINUE;

import java.io.IOException;

import java.nio.file.DirectoryNotEmptyException;

import java.nio.file.FileVisitResult;

import java.nio.file.Files;

import java.nio.file.NoSuchFileException;

import java.nio.file.Path;

import java.nio.file.SimpleFileVisitor;

import java.nio.file.attribute.BasicFileAttributes;

import java.time.LocalDateTime;

import java.time.ZoneId;

public class ClearFileKit {

/**

* 清除某个目录下某几天前的文件

* &＃64;param dir

* &＃64;param days

*/

public static void clearFileByMonth(Path dir, int days) {

class DeleteFiles extends SimpleFileVisitor {

LocalDateTime beforeDateTime &＃61; LocalDateTime.now().minusDays(days);

boolean isDeleteDir &＃61; false;

public DeleteFiles(boolean isDeleteDir) {

this.isDeleteDir &＃61; isDeleteDir;

}

&＃64;Override

public FileVisitResult visitFile(Path file, BasicFileAttributes attr) {

if (attr.isSymbolicLink()) {

System.out.format("Symbolic link: %s%n ", file);

} else if (attr.isRegularFile()) {

try {

boolean isHarfYearBefore &＃61; attr.creationTime().toInstant().isBefore(beforeDateTime.atZone(ZoneId.systemDefault()).toInstant());

if (isHarfYearBefore) {

Files.delete(file);

System.out.format("Delete Regular file: %s%n ", file);

}

} catch (IOException e) {

e.printStackTrace();

}

} else {

System.out.format("Other: %s%n ", file);

}

//System.out.println("(" &＃43; attr.size() &＃43; "bytes)");

return CONTINUE;

}

// Print each directory visited.

&＃64;Override

public FileVisitResult postVisitDirectory(Path dir, IOException exc) {

if (isDeleteDir) {

try {

Files.delete(dir);

System.out.format("Delete Directory: %s%n ", dir);

} catch (NoSuchFileException x) {

System.err.format("%s: no such" &＃43; " directory%n", dir);

} catch (DirectoryNotEmptyException x) {

//System.err.format("%s not empty%n", dir);

} catch (IOException x) {

// File permission problems are caught here.

System.err.println(x);

}

}

return CONTINUE;

}

// If there is some error accessing

// the file, let the user know.

// If you don&＃39;t override this method

// and an error occurs, an IOException

// is thrown.

&＃64;Override

public FileVisitResult visitFileFailed(Path file, IOException exc) {

System.err.println(exc);

return CONTINUE;

}

}

long startTime &＃61; System.currentTimeMillis();

System.out.println("开始删除过期文件...");

Path startingDir &＃61; dir;

DeleteFiles pf &＃61; new DeleteFiles(false);

try {

Files.walkFileTree(startingDir, pf);

} catch (IOException e) {

e.printStackTrace();

}

long endTime &＃61; System.currentTimeMillis();

long time &＃61; endTime-startTime;

System.out.println("删除过期文件完成, 耗时&＃xff1a; " &＃43;time/1000&＃43;"  秒");

}

}