Fixed queue.sql not being deleted

This commit is contained in:
Robin Kupper
2011-07-17 02:38:44 +02:00
parent ed71c77dc2
commit 3ff9788e36

View File

@@ -81,11 +81,12 @@ public class LogBlock extends JavaPlugin
conn = getConnection(); conn = getConnection();
conn.setAutoCommit(false); conn.setAutoCommit(false);
final Statement state = conn.createStatement(); final Statement state = conn.createStatement();
final BufferedReader in = new BufferedReader(new FileReader(file)); final BufferedReader reader = new BufferedReader(new FileReader(file));
String insert = null; String insert = null;
while ((insert = in.readLine()) != null) while ((insert = reader.readLine()) != null)
state.execute(insert); state.execute(insert);
conn.commit(); conn.commit();
reader.close();
file.delete(); file.delete();
log.info("[LogBlock] Successfully imported stored queue."); log.info("[LogBlock] Successfully imported stored queue.");
} catch (final Exception ex) { } catch (final Exception ex) {