Use the same connection for all custom mail manager queries.

This commit is contained in:
MobiusDev 2019-03-06 20:29:22 +00:00
parent b0efc59d8c
commit 03bfff35d1
12 changed files with 48 additions and 60 deletions

View File

@ -92,8 +92,7 @@ public class CustomMailManager
}
// Delete entry from database.
try (Connection con2 = DatabaseFactory.getConnection();
PreparedStatement stmt = con2.prepareStatement(DELETE_SQL))
try (PreparedStatement stmt = con.prepareStatement(DELETE_SQL))
{
stmt.setString(1, rs.getString("date"));
stmt.setInt(2, playerId);
@ -101,18 +100,18 @@ public class CustomMailManager
}
catch (SQLException e)
{
LOGGER.log(Level.WARNING, getClass().getSimpleName() + ": Error deleting entry from database:", e);
LOGGER.log(Level.WARNING, getClass().getSimpleName() + ": Error deleting entry from database: ", e);
}
// Send message.
MailManager.getInstance().sendMessage(msg);
LOGGER.info(getClass().getSimpleName() + ": Sent message at " + player.getName() + ".");
LOGGER.info(getClass().getSimpleName() + ": Message sent to " + player.getName() + ".");
}
}
}
catch (SQLException e)
{
LOGGER.log(Level.WARNING, getClass().getSimpleName() + ": Error loading from database:", e);
LOGGER.log(Level.WARNING, getClass().getSimpleName() + ": Error reading from database: ", e);
}
}, Config.CUSTOM_MAIL_MANAGER_DELAY, Config.CUSTOM_MAIL_MANAGER_DELAY);

View File

@ -92,8 +92,7 @@ public class CustomMailManager
}
// Delete entry from database.
try (Connection con2 = DatabaseFactory.getConnection();
PreparedStatement stmt = con2.prepareStatement(DELETE_SQL))
try (PreparedStatement stmt = con.prepareStatement(DELETE_SQL))
{
stmt.setString(1, rs.getString("date"));
stmt.setInt(2, playerId);
@ -101,18 +100,18 @@ public class CustomMailManager
}
catch (SQLException e)
{
LOGGER.log(Level.WARNING, getClass().getSimpleName() + ": Error deleting entry from database:", e);
LOGGER.log(Level.WARNING, getClass().getSimpleName() + ": Error deleting entry from database: ", e);
}
// Send message.
MailManager.getInstance().sendMessage(msg);
LOGGER.info(getClass().getSimpleName() + ": Sent message at " + player.getName() + ".");
LOGGER.info(getClass().getSimpleName() + ": Message sent to " + player.getName() + ".");
}
}
}
catch (SQLException e)
{
LOGGER.log(Level.WARNING, getClass().getSimpleName() + ": Error loading from database:", e);
LOGGER.log(Level.WARNING, getClass().getSimpleName() + ": Error reading from database: ", e);
}
}, Config.CUSTOM_MAIL_MANAGER_DELAY, Config.CUSTOM_MAIL_MANAGER_DELAY);

View File

@ -92,8 +92,7 @@ public class CustomMailManager
}
// Delete entry from database.
try (Connection con2 = DatabaseFactory.getConnection();
PreparedStatement stmt = con2.prepareStatement(DELETE_SQL))
try (PreparedStatement stmt = con.prepareStatement(DELETE_SQL))
{
stmt.setString(1, rs.getString("date"));
stmt.setInt(2, playerId);
@ -101,18 +100,18 @@ public class CustomMailManager
}
catch (SQLException e)
{
LOGGER.log(Level.WARNING, getClass().getSimpleName() + ": Error deleting entry from database:", e);
LOGGER.log(Level.WARNING, getClass().getSimpleName() + ": Error deleting entry from database: ", e);
}
// Send message.
MailManager.getInstance().sendMessage(msg);
LOGGER.info(getClass().getSimpleName() + ": Sent message at " + player.getName() + ".");
LOGGER.info(getClass().getSimpleName() + ": Message sent to " + player.getName() + ".");
}
}
}
catch (SQLException e)
{
LOGGER.log(Level.WARNING, getClass().getSimpleName() + ": Error loading from database:", e);
LOGGER.log(Level.WARNING, getClass().getSimpleName() + ": Error reading from database: ", e);
}
}, Config.CUSTOM_MAIL_MANAGER_DELAY, Config.CUSTOM_MAIL_MANAGER_DELAY);

View File

@ -92,8 +92,7 @@ public class CustomMailManager
}
// Delete entry from database.
try (Connection con2 = DatabaseFactory.getConnection();
PreparedStatement stmt = con2.prepareStatement(DELETE_SQL))
try (PreparedStatement stmt = con.prepareStatement(DELETE_SQL))
{
stmt.setString(1, rs.getString("date"));
stmt.setInt(2, playerId);
@ -101,18 +100,18 @@ public class CustomMailManager
}
catch (SQLException e)
{
LOGGER.log(Level.WARNING, getClass().getSimpleName() + ": Error deleting entry from database:", e);
LOGGER.log(Level.WARNING, getClass().getSimpleName() + ": Error deleting entry from database: ", e);
}
// Send message.
MailManager.getInstance().sendMessage(msg);
LOGGER.info(getClass().getSimpleName() + ": Sent message at " + player.getName() + ".");
LOGGER.info(getClass().getSimpleName() + ": Message sent to " + player.getName() + ".");
}
}
}
catch (SQLException e)
{
LOGGER.log(Level.WARNING, getClass().getSimpleName() + ": Error loading from database:", e);
LOGGER.log(Level.WARNING, getClass().getSimpleName() + ": Error reading from database: ", e);
}
}, Config.CUSTOM_MAIL_MANAGER_DELAY, Config.CUSTOM_MAIL_MANAGER_DELAY);

View File

@ -92,8 +92,7 @@ public class CustomMailManager
}
// Delete entry from database.
try (Connection con2 = DatabaseFactory.getConnection();
PreparedStatement stmt = con2.prepareStatement(DELETE_SQL))
try (PreparedStatement stmt = con.prepareStatement(DELETE_SQL))
{
stmt.setString(1, rs.getString("date"));
stmt.setInt(2, playerId);
@ -101,18 +100,18 @@ public class CustomMailManager
}
catch (SQLException e)
{
LOGGER.log(Level.WARNING, getClass().getSimpleName() + ": Error deleting entry from database:", e);
LOGGER.log(Level.WARNING, getClass().getSimpleName() + ": Error deleting entry from database: ", e);
}
// Send message.
MailManager.getInstance().sendMessage(msg);
LOGGER.info(getClass().getSimpleName() + ": Sent message at " + player.getName() + ".");
LOGGER.info(getClass().getSimpleName() + ": Message sent to " + player.getName() + ".");
}
}
}
catch (SQLException e)
{
LOGGER.log(Level.WARNING, getClass().getSimpleName() + ": Error loading from database:", e);
LOGGER.log(Level.WARNING, getClass().getSimpleName() + ": Error reading from database: ", e);
}
}, Config.CUSTOM_MAIL_MANAGER_DELAY, Config.CUSTOM_MAIL_MANAGER_DELAY);

View File

@ -92,8 +92,7 @@ public class CustomMailManager
}
// Delete entry from database.
try (Connection con2 = DatabaseFactory.getConnection();
PreparedStatement stmt = con2.prepareStatement(DELETE_SQL))
try (PreparedStatement stmt = con.prepareStatement(DELETE_SQL))
{
stmt.setString(1, rs.getString("date"));
stmt.setInt(2, playerId);
@ -101,18 +100,18 @@ public class CustomMailManager
}
catch (SQLException e)
{
LOGGER.log(Level.WARNING, getClass().getSimpleName() + ": Error deleting entry from database:", e);
LOGGER.log(Level.WARNING, getClass().getSimpleName() + ": Error deleting entry from database: ", e);
}
// Send message.
MailManager.getInstance().sendMessage(msg);
LOGGER.info(getClass().getSimpleName() + ": Sent message at " + player.getName() + ".");
LOGGER.info(getClass().getSimpleName() + ": Message sent to " + player.getName() + ".");
}
}
}
catch (SQLException e)
{
LOGGER.log(Level.WARNING, getClass().getSimpleName() + ": Error loading from database:", e);
LOGGER.log(Level.WARNING, getClass().getSimpleName() + ": Error reading from database: ", e);
}
}, Config.CUSTOM_MAIL_MANAGER_DELAY, Config.CUSTOM_MAIL_MANAGER_DELAY);

View File

@ -92,8 +92,7 @@ public class CustomMailManager
}
// Delete entry from database.
try (Connection con2 = DatabaseFactory.getConnection();
PreparedStatement stmt = con2.prepareStatement(DELETE_SQL))
try (PreparedStatement stmt = con.prepareStatement(DELETE_SQL))
{
stmt.setString(1, rs.getString("date"));
stmt.setInt(2, playerId);
@ -101,18 +100,18 @@ public class CustomMailManager
}
catch (SQLException e)
{
LOGGER.log(Level.WARNING, getClass().getSimpleName() + ": Error deleting entry from database:", e);
LOGGER.log(Level.WARNING, getClass().getSimpleName() + ": Error deleting entry from database: ", e);
}
// Send message.
MailManager.getInstance().sendMessage(msg);
LOGGER.info(getClass().getSimpleName() + ": Sent message at " + player.getName() + ".");
LOGGER.info(getClass().getSimpleName() + ": Message sent to " + player.getName() + ".");
}
}
}
catch (SQLException e)
{
LOGGER.log(Level.WARNING, getClass().getSimpleName() + ": Error loading from database:", e);
LOGGER.log(Level.WARNING, getClass().getSimpleName() + ": Error reading from database: ", e);
}
}, Config.CUSTOM_MAIL_MANAGER_DELAY, Config.CUSTOM_MAIL_MANAGER_DELAY);

View File

@ -91,8 +91,7 @@ public class CustomMailManager
}
// Delete entry from database.
try (Connection con2 = DatabaseFactory.getConnection();
PreparedStatement stmt = con2.prepareStatement(DELETE_SQL))
try (PreparedStatement stmt = con.prepareStatement(DELETE_SQL))
{
stmt.setString(1, rs.getString("date"));
stmt.setInt(2, playerId);
@ -100,18 +99,18 @@ public class CustomMailManager
}
catch (SQLException e)
{
LOGGER.log(Level.WARNING, getClass().getSimpleName() + ": Error deleting entry from database:", e);
LOGGER.log(Level.WARNING, getClass().getSimpleName() + ": Error deleting entry from database: ", e);
}
// Send message.
MailManager.getInstance().sendMessage(msg);
LOGGER.info(getClass().getSimpleName() + ": Sent message at " + player.getName() + ".");
LOGGER.info(getClass().getSimpleName() + ": Message sent to " + player.getName() + ".");
}
}
}
catch (SQLException e)
{
LOGGER.log(Level.WARNING, getClass().getSimpleName() + ": Error loading from database:", e);
LOGGER.log(Level.WARNING, getClass().getSimpleName() + ": Error reading from database: ", e);
}
}, Config.CUSTOM_MAIL_MANAGER_DELAY, Config.CUSTOM_MAIL_MANAGER_DELAY);

View File

@ -92,8 +92,7 @@ public class CustomMailManager
}
// Delete entry from database.
try (Connection con2 = DatabaseFactory.getConnection();
PreparedStatement stmt = con2.prepareStatement(DELETE_SQL))
try (PreparedStatement stmt = con.prepareStatement(DELETE_SQL))
{
stmt.setString(1, rs.getString("date"));
stmt.setInt(2, playerId);
@ -101,18 +100,18 @@ public class CustomMailManager
}
catch (SQLException e)
{
LOGGER.log(Level.WARNING, getClass().getSimpleName() + ": Error deleting entry from database:", e);
LOGGER.log(Level.WARNING, getClass().getSimpleName() + ": Error deleting entry from database: ", e);
}
// Send message.
MailManager.getInstance().sendMessage(msg);
LOGGER.info(getClass().getSimpleName() + ": Sent message at " + player.getName() + ".");
LOGGER.info(getClass().getSimpleName() + ": Message sent to " + player.getName() + ".");
}
}
}
catch (SQLException e)
{
LOGGER.log(Level.WARNING, getClass().getSimpleName() + ": Error loading from database:", e);
LOGGER.log(Level.WARNING, getClass().getSimpleName() + ": Error reading from database: ", e);
}
}, Config.CUSTOM_MAIL_MANAGER_DELAY, Config.CUSTOM_MAIL_MANAGER_DELAY);

View File

@ -92,8 +92,7 @@ public class CustomMailManager
}
// Delete entry from database.
try (Connection con2 = DatabaseFactory.getConnection();
PreparedStatement stmt = con2.prepareStatement(DELETE_SQL))
try (PreparedStatement stmt = con.prepareStatement(DELETE_SQL))
{
stmt.setString(1, rs.getString("date"));
stmt.setInt(2, playerId);
@ -101,18 +100,18 @@ public class CustomMailManager
}
catch (SQLException e)
{
LOGGER.log(Level.WARNING, getClass().getSimpleName() + ": Error deleting entry from database:", e);
LOGGER.log(Level.WARNING, getClass().getSimpleName() + ": Error deleting entry from database: ", e);
}
// Send message.
MailManager.getInstance().sendMessage(msg);
LOGGER.info(getClass().getSimpleName() + ": Sent message at " + player.getName() + ".");
LOGGER.info(getClass().getSimpleName() + ": Message sent to " + player.getName() + ".");
}
}
}
catch (SQLException e)
{
LOGGER.log(Level.WARNING, getClass().getSimpleName() + ": Error loading from database:", e);
LOGGER.log(Level.WARNING, getClass().getSimpleName() + ": Error reading from database: ", e);
}
}, Config.CUSTOM_MAIL_MANAGER_DELAY, Config.CUSTOM_MAIL_MANAGER_DELAY);

View File

@ -92,8 +92,7 @@ public class CustomMailManager
}
// Delete entry from database.
try (Connection con2 = DatabaseFactory.getConnection();
PreparedStatement stmt = con2.prepareStatement(DELETE_SQL))
try (PreparedStatement stmt = con.prepareStatement(DELETE_SQL))
{
stmt.setString(1, rs.getString("date"));
stmt.setInt(2, playerId);
@ -101,18 +100,18 @@ public class CustomMailManager
}
catch (SQLException e)
{
LOGGER.log(Level.WARNING, getClass().getSimpleName() + ": Error deleting entry from database:", e);
LOGGER.log(Level.WARNING, getClass().getSimpleName() + ": Error deleting entry from database: ", e);
}
// Send message.
MailManager.getInstance().sendMessage(msg);
LOGGER.info(getClass().getSimpleName() + ": Sent message at " + player.getName() + ".");
LOGGER.info(getClass().getSimpleName() + ": Message sent to " + player.getName() + ".");
}
}
}
catch (SQLException e)
{
LOGGER.log(Level.WARNING, getClass().getSimpleName() + ": Error loading from database:", e);
LOGGER.log(Level.WARNING, getClass().getSimpleName() + ": Error reading from database: ", e);
}
}, Config.CUSTOM_MAIL_MANAGER_DELAY, Config.CUSTOM_MAIL_MANAGER_DELAY);

View File

@ -92,8 +92,7 @@ public class CustomMailManager
}
// Delete entry from database.
try (Connection con2 = DatabaseFactory.getConnection();
PreparedStatement stmt = con2.prepareStatement(DELETE_SQL))
try (PreparedStatement stmt = con.prepareStatement(DELETE_SQL))
{
stmt.setString(1, rs.getString("date"));
stmt.setInt(2, playerId);
@ -101,18 +100,18 @@ public class CustomMailManager
}
catch (SQLException e)
{
LOGGER.log(Level.WARNING, getClass().getSimpleName() + ": Error deleting entry from database:", e);
LOGGER.log(Level.WARNING, getClass().getSimpleName() + ": Error deleting entry from database: ", e);
}
// Send message.
MailManager.getInstance().sendMessage(msg);
LOGGER.info(getClass().getSimpleName() + ": Sent message at " + player.getName() + ".");
LOGGER.info(getClass().getSimpleName() + ": Message sent to " + player.getName() + ".");
}
}
}
catch (SQLException e)
{
LOGGER.log(Level.WARNING, getClass().getSimpleName() + ": Error loading from database:", e);
LOGGER.log(Level.WARNING, getClass().getSimpleName() + ": Error reading from database: ", e);
}
}, Config.CUSTOM_MAIL_MANAGER_DELAY, Config.CUSTOM_MAIL_MANAGER_DELAY);