mirror/VentureChat
1
0
Fork 1
mirror of https://github.com/Aust1n46/VentureChat.git synced 2025-05-23 10:39:05 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Load database async and add exception handling.

Browse Source 
Hikari seems to print it's own stacktrace even when you catch the
exception.
This commit is contained in:
Aust1n46 2021-04-09 17:19:08 -05:00
parent c663c49e9c
commit 8a6a4d61f2
2 changed files with 44 additions and 39 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/mineverse/Aust1n46/chat/MineverseChat.java
View File

@ -228,7 +228,9 @@ public class MineverseChat extends JavaPlugin implements PluginMessageListener {
MineverseChatAPI.addMineverseChatOnlinePlayerToMap(mcp); MineverseChatAPI.addMineverseChatOnlinePlayerToMap(mcp);
} }
Bukkit.getScheduler().runTaskAsynchronously(this, () -> {
Database.initializeMySQL(); Database.initializeMySQL();
});
commands.put("broadcast", new Broadcast("broadcast")); commands.put("broadcast", new Broadcast("broadcast"));
commands.put("channel", new Channel("channel")); commands.put("channel", new Channel("channel"));

35
src/mineverse/Aust1n46/chat/database/Database.java
View File

@ -13,6 +13,7 @@ import com.zaxxer.hikari.HikariConfig;
import com.zaxxer.hikari.HikariDataSource; import com.zaxxer.hikari.HikariDataSource;
import mineverse.Aust1n46.chat.MineverseChat; import mineverse.Aust1n46.chat.MineverseChat;
import mineverse.Aust1n46.chat.utilities.Format;
/** /**
* Initializes and handles writing to the chat logging database. * Initializes and handles writing to the chat logging database.
@ -21,6 +22,7 @@ public class Database {
private static HikariDataSource dataSource = null; private static HikariDataSource dataSource = null;
public static void initializeMySQL() { public static void initializeMySQL() {
try {
ConfigurationSection mysqlConfig = MineverseChat.getInstance().getConfig().getConfigurationSection("mysql"); ConfigurationSection mysqlConfig = MineverseChat.getInstance().getConfig().getConfigurationSection("mysql");
if (mysqlConfig.getBoolean("enabled", false)) { if (mysqlConfig.getBoolean("enabled", false)) {
String host = mysqlConfig.getString("host"); String host = mysqlConfig.getString("host");
@ -31,8 +33,10 @@ public class Database {
final HikariConfig config = new HikariConfig(); final HikariConfig config = new HikariConfig();
// config.setDriverClassName(org.postgresql.Driver.class.getName()); // config.setDriverClassName(org.postgresql.Driver.class.getName());
//final String jdbcUrl = String.format("jdbc:postgresql://%s:%d/%s", hostname, port, database); // final String jdbcUrl = String.format("jdbc:postgresql://%s:%d/%s", hostname,
final String jdbcUrl = String.format("jdbc:mysql://%s:%d/%s?autoReconnect=true&useSSL=false", host, port, database); // port, database);
final String jdbcUrl = String.format("jdbc:mysql://%s:%d/%s?autoReconnect=true&useSSL=false", host,
port, database);
config.setJdbcUrl(jdbcUrl); config.setJdbcUrl(jdbcUrl);
config.setUsername(user); config.setUsername(user);
config.setPassword(password); config.setPassword(password);
@ -40,16 +44,16 @@ public class Database {
config.addDataSourceProperty("prepStmtCacheSize", "250"); config.addDataSourceProperty("prepStmtCacheSize", "250");
config.addDataSourceProperty("prepStmtCacheSqlLimit", "2048"); config.addDataSourceProperty("prepStmtCacheSqlLimit", "2048");
dataSource = new HikariDataSource(config); dataSource = new HikariDataSource(config);
final String SQL_CREATE_TABLE = "CREATE TABLE IF NOT EXISTS VentureChat " + final String SQL_CREATE_TABLE = "CREATE TABLE IF NOT EXISTS VentureChat "
"(ID SERIAL PRIMARY KEY, ChatTime TEXT, UUID TEXT, Name TEXT, " + + "(ID SERIAL PRIMARY KEY, ChatTime TEXT, UUID TEXT, Name TEXT, "
"Server TEXT, Channel TEXT, Text TEXT, Type TEXT)"; + "Server TEXT, Channel TEXT, Text TEXT, Type TEXT)";
try (final Connection conn = dataSource.getConnection(); final Connection conn = dataSource.getConnection();
final PreparedStatement statement = conn.prepareStatement(SQL_CREATE_TABLE)) { final PreparedStatement statement = conn.prepareStatement(SQL_CREATE_TABLE);
statement.executeUpdate(); statement.executeUpdate();
} }
catch (SQLException e) { } catch (Exception exception) {
throw new RuntimeException(e); Bukkit.getConsoleSender().sendMessage(
} Format.FormatStringAll("&8[&eVentureChat&8]&c - Database could not be loaded. Is it running?"));
} }
} }
@ -57,7 +61,8 @@ public class Database {
return dataSource != null; return dataSource != null;
} }
public static void writeVentureChat(String uuid, String name, String server, String channel, String text, String type) { public static void writeVentureChat(String uuid, String name, String server, String channel, String text,
String type) {
MineverseChat plugin = MineverseChat.getInstance(); MineverseChat plugin = MineverseChat.getInstance();
Calendar currentDate = Calendar.getInstance(); Calendar currentDate = Calendar.getInstance();
SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
@ -65,9 +70,8 @@ public class Database {
Bukkit.getScheduler().runTaskAsynchronously(plugin, () -> { Bukkit.getScheduler().runTaskAsynchronously(plugin, () -> {
try (final Connection conn = dataSource.getConnection(); try (final Connection conn = dataSource.getConnection();
final PreparedStatement statement = conn.prepareStatement( final PreparedStatement statement = conn.prepareStatement(
"INSERT INTO VentureChat " + "INSERT INTO VentureChat " + "(ChatTime, UUID, Name, Server, Channel, Text, Type) "
"(ChatTime, UUID, Name, Server, Channel, Text, Type) " + + "VALUES (?, ?, ?, ?, ?, ?, ?)")) {
"VALUES (?, ?, ?, ?, ?, ?, ?)")) {
statement.setString(1, date); statement.setString(1, date);
statement.setString(2, uuid); statement.setString(2, uuid);
statement.setString(3, name); statement.setString(3, name);
@ -76,8 +80,7 @@ public class Database {
statement.setString(6, text); statement.setString(6, text);
statement.setString(7, type); statement.setString(7, type);
statement.executeUpdate(); statement.executeUpdate();
} } catch (SQLException error) {
catch(SQLException error) {
error.printStackTrace(); error.printStackTrace();
} }
}); });