feedc0de/LogBlock
1
0
Fork 0
forked from LogBlock/LogBlock
Code Pull Requests Activity

moved clearlog toan own thread

Browse Source
This commit is contained in:
Robin Kupper
2011-03-13 13:20:23 +01:00
parent c2e2ff2dc1
commit 3a9e9f7d71
2 changed files with 48 additions and 33 deletions
Download Patch File Download Diff File Expand all files Collapse all files

47
src/de/diddiz/LogBlock/ClearLog.java Normal file
View File

@@ -0,0 +1,47 @@
package de.diddiz.LogBlock;
import java.sql.Connection;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.logging.Level;
public class ClearLog implements Runnable
{
private Connection conn;
public ClearLog(Connection conn) {
this.conn = conn;
}
@Override
public void run() {
if (conn == null)
return;
Statement state = null;
try {
state = conn.createStatement();
for (String table : Config.worldTables) {
int deleted = state.executeUpdate("DELETE FROM `" + table + "` WHERE date < date_sub(now(), INTERVAL " + Config.keepLogDays + " DAY)");
if (deleted > 0)
LogBlock.log.info("[LogBlock] Cleared out table " + table + ". Deleted " + deleted + " entries.");
deleted = state.executeUpdate("DELETE `" + table + "-sign` FROM `" + table + "-sign` LEFT JOIN `" + table + "` ON (`" + table + "-sign`.`id` = `" + table + "`.`id`) WHERE `" + table + "`.`id` IS NULL;");
if (deleted > 0)
LogBlock.log.info("[LogBlock] Cleared out table " + table + "-sign. Deleted " + deleted + " entries.");
deleted = state.executeUpdate("DELETE `" + table + "-chest` FROM `" + table + "-chest` LEFT JOIN `" + table + "` ON (`" + table + "-chest`.`id` = `" + table + "`.`id`) WHERE `" + table + "`.`id` IS NULL;");
if (deleted > 0)
LogBlock.log.info("[LogBlock] Cleared out table " + table + "-chest. Deleted " + deleted + " entries.");
}
} catch (SQLException ex) {
LogBlock.log.log(Level.SEVERE, "[LogBlock] SQL exception", ex);
} finally {
try {
if (state != null)
state.close();
if (conn != null)
conn.close();
} catch (SQLException ex) {
LogBlock.log.log(Level.SEVERE, "[LogBlock] SQL exception on close", ex);
}
}
}
}

34
src/de/diddiz/LogBlock/LogBlock.java
View File

@@ -81,7 +81,7 @@ public class LogBlock extends JavaPlugin
return;
}
if (Config.keepLogDays >= 0)
dropOldLogs();
new Thread(new ClearLog(getConnection())).start();
LBBlockListener lbBlockListener = new LBBlockListener();
LBPlayerListener lbPlayerListener = new LBPlayerListener();
PluginManager pm = getServer().getPluginManager();
@@ -310,38 +310,6 @@ public class LogBlock extends JavaPlugin
return false;
}
private void dropOldLogs() {
Connection conn = getConnection();
if (conn == null)
return;
Statement state = null;
try {
state = conn.createStatement();
for (String table : Config.worldTables) {
int deleted = state.executeUpdate("DELETE FROM `" + table + "` WHERE date < date_sub(now(), INTERVAL " + Config.keepLogDays + " DAY)");
if (deleted > 0)
log.info("[LogBlock] Cleared out table " + table + ". Deleted " + deleted + " entries.");
deleted = state.executeUpdate("DELETE `" + table + "-sign` FROM `" + table + "-sign` LEFT JOIN `" + table + "` ON (`" + table + "-sign`.`id` = `" + table + "`.`id`) WHERE `" + table + "`.`id` IS NULL;");
if (deleted > 0)
log.info("[LogBlock] Cleared out table " + table + "-sign. Deleted " + deleted + " entries.");
deleted = state.executeUpdate("DELETE `" + table + "-chest` FROM `" + table + "-chest` LEFT JOIN `" + table + "` ON (`" + table + "-chest`.`id` = `" + table + "`.`id`) WHERE `" + table + "`.`id` IS NULL;");
if (deleted > 0)
log.info("[LogBlock] Cleared out table " + table + "-chest. Deleted " + deleted + " entries.");
}
} catch (SQLException ex) {
log.log(Level.SEVERE, "[LogBlock] SQL exception", ex);
} finally {
try {
if (state != null)
state.close();
if (conn != null)
conn.close();
} catch (SQLException ex) {
log.log(Level.SEVERE, "[LogBlock] SQL exception on close", ex);
}
}
}
private String getTable (Player player) {
return getTable(player.getWorld().getName());
}