package com.sql;
|
|
import java.io.BufferedReader;
|
import java.io.BufferedWriter;
|
import java.io.File;
|
import java.io.IOException;
|
import java.io.InputStreamReader;
|
import java.io.OutputStreamWriter;
|
import java.sql.ResultSet;
|
import java.sql.SQLException;
|
import java.util.Date;
|
|
import com.base.Com;
|
import com.config.AppConfig;
|
|
|
/**
|
* ¶¨ÆÚ±¸·ÝÊý¾Ý¿âµÄÏß³Ì
|
* @author ¾ü
|
*
|
*/
|
public class MysqlDBBackUp_Thread extends Thread {
|
private MysqlConnPool m_conn_pool = null;
|
private String db_path = ""; //Êý¾Ý¿âµÄ°²×°Ä¿Â¼
|
private int back_up_day = 30; //ĬÈϱ¸·ÝÊý¾Ý¿âµÄ¼ä¸ô
|
private Date m_latest_backup_time = new Date(); //×îºó±¸·ÝÊý¾Ý¿âµÄʱ¼ä
|
private int mSqlConnPort = 5306; //Êý¾Ý¿âµÄ¶Ë¿ÚºÅ
|
|
public MysqlDBBackUp_Thread(AppConfig cfg, MysqlConnPool con_pool) {
|
back_up_day = cfg.getAutoSqlDbBackUpDayInterval();
|
m_conn_pool = con_pool;
|
mSqlConnPort = m_conn_pool.getSqlConnPort();
|
|
Sql_Mysql sql = new Sql_Mysql(m_conn_pool.getConn());
|
try {
|
ResultSet res = sql.sqlMysqlQuery("select @@basedir as basePath from dual");
|
if(res.next()) {
|
db_path = res.getString(1);
|
db_path.substring(0, db_path.indexOf(":")+1);
|
}
|
|
res = sql.sqlMysqlQuery("SELECT SqlDB_BackUpTime FROM " + Sql_Mysql.AppSys_Table);
|
if(res.next()) {
|
m_latest_backup_time = res.getTimestamp(1);
|
}
|
} catch (SQLException e) {
|
e.printStackTrace();
|
} finally {
|
sql.close_con();
|
}
|
}
|
|
@Override
|
public void run() {
|
/**********************************************************************************/
|
System.out.println(this.getName() + " - MysqlDBBackUp_Thread Started ...");
|
/**********************************************************************************/
|
while(true) {
|
try {
|
boolean db_backup_manual_en = false;
|
for(int n=0; n<back_up_day; n++) {
|
for(int h=0; h<24*3600; h++) {
|
try {
|
sleep(1000);
|
db_backup_manual_en = getSqlDB_BackUpManual_EN();
|
if(true == db_backup_manual_en) {
|
break;
|
}
|
} catch (InterruptedException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
}
|
|
if(true == db_backup_manual_en) {
|
break;
|
}
|
|
Date dt = new Date();
|
long dt_s = (dt.getTime() - m_latest_backup_time.getTime())/1000;
|
if((dt_s/(24*3600)) >= back_up_day) {
|
break;
|
}
|
}
|
|
System.out.println(this.getName() + " - MysqlDBBackUp_Thread backup all dbs at "
|
+ Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms));
|
doDbBackUp();
|
updateBackupInf();
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
}
|
|
|
//»ñÈ¡Êý¾Ý¿â±¸·Ý±í¸ñÖÐµÄ SqlDB_BackUpManual_ENÖµ
|
private boolean getSqlDB_BackUpManual_EN() {
|
boolean en = false;
|
Sql_Mysql sql = new Sql_Mysql(m_conn_pool.getConn());
|
try {
|
ResultSet res = sql.sqlMysqlQuery("SELECT SqlDB_BackUpManual_EN FROM " + Sql_Mysql.AppSys_Table);
|
if(res.next()) {
|
en = res.getBoolean(1);
|
}
|
} catch (SQLException e) {
|
e.printStackTrace();
|
} finally {
|
sql.close_con();
|
}
|
return en;
|
}
|
|
|
//¸üб¸·ÝÊý¾Ý¿â±í¸ñÖеÄÐÅÏ¢
|
private void updateBackupInf() {
|
Sql_Mysql sql = new Sql_Mysql(m_conn_pool.getConn());
|
try {
|
sql.sqlMysqlExecute("UPDATE " + Sql_Mysql.AppSys_Table
|
+ " SET "
|
+ " SqlDB_BackUpTime='" + Com.getDateTimeFormat(new Date(), Com.DTF_YMDhms) + "',"
|
+ " SqlDB_BackUpManual_EN=false");
|
} catch (SQLException e) {
|
e.printStackTrace();
|
} finally {
|
sql.close_con();
|
}
|
}
|
|
//Ö´ÐÐÊý¾Ý¿â±¸·Ý
|
private void doDbBackUp() {
|
Process ps;
|
try {
|
String tmp_filename = "all_backup_" + Com.getDateTimeFormat(new Date(), Com.DTF_YMD_h_m_s);
|
String cmd_str = db_path + File.separator + "bin" + File.separator
|
+ "mysqldump -P " + mSqlConnPort + " -uroot -plmx8688139 --all-databases > "
|
+ db_path + File.separator + tmp_filename
|
+ "&echo popstar hello";
|
|
ps = Runtime.getRuntime().exec("cmd");
|
InputStreamReader isr = new InputStreamReader(ps.getErrorStream());
|
//Óûº³åÆ÷¶ÁÐÐ
|
BufferedReader br = new BufferedReader(isr);
|
|
// next command
|
OutputStreamWriter osw = new OutputStreamWriter (ps.getOutputStream ());
|
BufferedWriter bw = new BufferedWriter (osw);
|
bw.write(cmd_str);
|
bw.newLine();
|
bw.write("del " + db_path + File.separator + "*.bksql");
|
bw.newLine();
|
|
String target_filename = "all_backup_" + Com.getDateTimeFormat(new Date(), Com.DTF_YMD_h_m_s);
|
bw.write("rename " + db_path + File.separator + tmp_filename + " " + target_filename + ".bksql");
|
|
bw.newLine();
|
bw.flush();
|
bw.close();
|
osw.close();
|
|
String line = null;
|
//Ö±µ½¶ÁÍêΪֹ
|
while((line=br.readLine()) != null) {
|
System.out.println(line);
|
}
|
ps.destroy();
|
br.close();
|
isr.close();
|
} catch (IOException e2) {
|
// TODO Auto-generated catch block
|
e2.printStackTrace();
|
}
|
}
|
}
|
