main
黄海 7 months ago
parent f16d376674
commit e9bbce4844

@ -1,6 +1,6 @@
package com.dsideal.YunXiaoTools.Controller; package com.dsideal.YunXiaoTools.Controller;
import com.dsideal.YunXiaoTools.Utils.BackupMysqlUtil; import com.dsideal.YunXiaoTools.Utils.MysqlBackupUtil;
import com.jfinal.aop.Before; import com.jfinal.aop.Before;
import com.jfinal.core.Controller; import com.jfinal.core.Controller;
import com.jfinal.ext.interceptor.GET; import com.jfinal.ext.interceptor.GET;
@ -14,7 +14,7 @@ public class DataBaseController extends Controller {
// http://10.10.21.20:9008/backupMysql // http://10.10.21.20:9008/backupMysql
@Before({GET.class}) @Before({GET.class})
public void backupMysql() { public void backupMysql() {
BackupMysqlUtil bm = new BackupMysqlUtil(); MysqlBackupUtil bm = new MysqlBackupUtil();
String url = bm.doAction(); String url = bm.doAction();
Kv kv = Kv.create(); Kv kv = Kv.create();
kv.set("success", true); kv.set("success", true);

@ -1,6 +1,6 @@
package com.dsideal.YunXiaoTools.Cron4j; package com.dsideal.YunXiaoTools.Cron4j;
import com.dsideal.YunXiaoTools.Utils.BackupMysqlUtil; import com.dsideal.YunXiaoTools.Utils.MysqlBackupUtil;
import com.dsideal.YunXiaoTools.Start; import com.dsideal.YunXiaoTools.Start;
import com.jfinal.plugin.cron4j.ITask; import com.jfinal.plugin.cron4j.ITask;
import lombok.SneakyThrows; import lombok.SneakyThrows;
@ -11,7 +11,7 @@ public class LingDianTask implements ITask {
public void run() { public void run() {
//如果是读取侧 //如果是读取侧
if (Start.DEPLOY_ID == 1) { if (Start.DEPLOY_ID == 1) {
BackupMysqlUtil bm = new BackupMysqlUtil(); MysqlBackupUtil bm = new MysqlBackupUtil();
bm.doAction(); bm.doAction();
} }
} }

@ -8,7 +8,7 @@ import java.io.*;
import java.time.LocalDateTime; import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter; import java.time.format.DateTimeFormatter;
public class BackupMysqlUtil { public class MysqlBackupUtil {
//数据库连接串 //数据库连接串
public static String jdbcUrl; public static String jdbcUrl;
//数据库用户名 //数据库用户名

@ -5,7 +5,7 @@ import com.obs.services.ObsClient;
import java.io.*; import java.io.*;
import java.util.zip.*; import java.util.zip.*;
public class DatabaseRestore { public class MysqlRestoreUtil {
private final String obsEndpoint; private final String obsEndpoint;
private final String obsAccessKey; private final String obsAccessKey;
private final String obsSecretKey; private final String obsSecretKey;
@ -18,7 +18,7 @@ public class DatabaseRestore {
private final String dbPassword; private final String dbPassword;
private final String dbName; private final String dbName;
public DatabaseRestore() { public MysqlRestoreUtil() {
// 从配置文件读取配置 // 从配置文件读取配置
this.obsEndpoint = PropKit.get("obs.endPoint"); this.obsEndpoint = PropKit.get("obs.endPoint");
this.obsAccessKey = PropKit.get("obs.accessKey"); this.obsAccessKey = PropKit.get("obs.accessKey");
Loading…
Cancel
Save