/*
* JobSchedulerMySQLMaintenanceMonitor.java
* Created on 30.05.2005
*
*/
package sos.scheduler.mysql;
import java.util.ArrayList;
import java.util.HashMap;
import sos.connection.SOSConnection;
import sos.connection.SOSMySQLConnection;
import sos.scheduler.job.JobSchedulerJob;
import sos.util.SOSSchedulerLogger;
/**
*
*
* @author Andreas Liebert
*/
public class JobSchedulerMySQLMaintenanceMonitor extends JobSchedulerJob {
public boolean spooler_process() throws Exception {
boolean new_connection=false;
SOSConnection connection = this.getConnection();
String database="";
String[] operations=null;
String[] tables=null;
String[] attributes=null;
this.setLogger(new SOSSchedulerLogger(spooler_log));
try{
if (getJobProperties().getProperty("config") != null) {
connection = sos.connection.SOSConnection.createInstance(getJobProperties().getProperty("config"));
connection.connect();
new_connection = true;
} else if (getJobProperties().getProperty("database") != null) {
database = getJobProperties().getProperty("database").toString();
if (database != null && database.length()>0) connection.execute("USE " + database);
getLogger().info("database changed to: " + database);
}
if (!(connection instanceof SOSMySQLConnection)){
getLogger().warn("This Job only works with MySQL databases.");
return false;
}
if (getJobProperties().getProperty("operations") != null) {
operations = getJobProperties().getProperty("operations").toString().split(",");
}
if (operations == null) {
operations = new String[3];
operations[0] = "ANALYZE";
operations[1] = "OPTIMIZE";
operations[2] = "REPAIR@QUICK";
}
if (getJobProperties().getProperty("tables") != null) {
tables = getJobProperties().getProperty("tables").split(",");
}
if (tables == null) {
ArrayList result = connection.getArrayValue("SHOW TABLES");
if (result != null && !result.isEmpty()) {
tables = new String[result.size()];
for(int i=0; i<result.size(); i++) {
tables[i] = result.get(i).toString();
}
}
}
if (tables == null) throw new Exception("no tables found for this database");
} catch (Exception e){
this.getLogger().error("Error reading Settings: "+e);
return false;
}
try{
for (int i=0; i<tables.length; i++) {
attributes = tables[i].split(":");
if (attributes == null || attributes.length == 1) {
attributes = new String[operations.length+1];
attributes[0] = tables[i];
for(int j=0; j<operations.length; j++) {
attributes[j+1] = operations[j];
}
}
for (int j=1; j<attributes.length; j++) {
String statement_suffix = "";
String statement;
attributes[j] = attributes[j].trim();
if (attributes[j].indexOf("@") > 0) {
statement_suffix = " " + attributes[j].substring(attributes[j].indexOf("@")+1);
attributes[j] = attributes[j].substring(0, attributes[j].indexOf("@"));
} else {
statement_suffix = "";
}
if (attributes[j].equalsIgnoreCase("ANALYZE")) statement = "ANALYZE TABLE " + attributes[0] + statement_suffix;
else if (attributes[j].equalsIgnoreCase("OPTIMIZE")) statement = "OPTIMIZE TABLE " + attributes[0] + statement_suffix;
else if (attributes[j].equalsIgnoreCase("REPAIR")) statement = "REPAIR TABLE " + attributes[0] + statement_suffix;
else{
getLogger().error("illegal operation was given for table [" + attributes[0] + "]: " + attributes[j]);
return false;
}
getLogger().debug3("processing statement: " + statement);
HashMap result = connection.getSingle(statement);
if (result == null || result.isEmpty()) {
getLogger().error("database returned no result for statement: " + statement);
return false;
}
getLogger().info("table: " + result.get("table").toString() + ", operation: " + result.get("op").toString()
+ ", Message Type: " + result.get("msg_type").toString() + ", Message Text: " + result.get("msg_text").toString() );
}
}
if (getJobProperties().getProperty("flush_tables") != null
&& getJobProperties().getProperty("flush_tables").toString().equalsIgnoreCase("yes")) {
getLogger().info("tables will be flushed to publish optimizations");
connection.execute("FLUSH TABLES");
}
} catch (Exception e){
getLogger().error ("maintenance monitor failed: " + e);
return false;
}finally {
if (new_connection && (connection != null)) {
connection.disconnect();
connection = null;
}
}
return false;
}
}
|