Upstream/LuckPerms
1
0
Fork 0
mirror of https://github.com/LuckPerms/LuckPerms.git synced 2025-01-17 05:41:35 +01:00
Code Issues Projects Releases Wiki Activity

Set character set to utf8 for messenger table (#1887)

Browse Source
This commit is contained in:
Luck 2019-12-24 13:46:19 +00:00
parent 88c432496b
commit dc5c6b0138
No known key found for this signature in database
GPG Key ID: EFA9B3EC5FD90F8B
1 changed files with 14 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
common/src/main/java/me/lucko/luckperms/common/messaging/sql/AbstractSqlMessenger.java
View File

@ -35,6 +35,7 @@ import java.sql.Connection;
import java.sql.PreparedStatement; import java.sql.PreparedStatement;
import java.sql.ResultSet; import java.sql.ResultSet;
import java.sql.SQLException; import java.sql.SQLException;
import java.sql.Statement;
/** /**
* An implementation of {@link Messenger} using SQL. * An implementation of {@link Messenger} using SQL.
@ -54,9 +55,20 @@ public abstract class AbstractSqlMessenger implements Messenger {
public void init() throws SQLException { public void init() throws SQLException {
try (Connection c = getConnection()) { try (Connection c = getConnection()) {
// init table // init table
try (PreparedStatement ps = c.prepareStatement("CREATE TABLE IF NOT EXISTS `" + getTableName() + "` (`id` INT AUTO_INCREMENT NOT NULL, `time` TIMESTAMP NOT NULL, `msg` TEXT NOT NULL, PRIMARY KEY (`id`))")) { String createStatement = "CREATE TABLE IF NOT EXISTS `" + getTableName() + "` (`id` INT AUTO_INCREMENT NOT NULL, `time` TIMESTAMP NOT NULL, `msg` TEXT NOT NULL, PRIMARY KEY (`id`)) DEFAULT CHARSET = utf8mb4";
ps.execute(); try (Statement s = c.createStatement()) {
try {
s.execute(createStatement);
} catch (SQLException e) {
if (e.getMessage().contains("Unknown character set")) {
// try again
s.execute(createStatement.replace("utf8mb4", "utf8"));
} else {
throw e;
} }
}
}
// pull last id // pull last id
try (PreparedStatement ps = c.prepareStatement("SELECT MAX(`id`) as `latest` FROM `" + getTableName() + "`")) { try (PreparedStatement ps = c.prepareStatement("SELECT MAX(`id`) as `latest` FROM `" + getTableName() + "`")) {
try (ResultSet rs = ps.executeQuery()) { try (ResultSet rs = ps.executeQuery()) {