|
|
@ -121,7 +121,7 @@ public class MySqlDatabase extends Database {
|
|
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
@Override
|
|
|
|
public CompletableFuture<Void> ensureUser(@NotNull User user) {
|
|
|
|
public CompletableFuture<Void> ensureUser(@NotNull User user) {
|
|
|
|
return CompletableFuture.runAsync(() -> getUser(user.uuid).thenAccept(optionalUser ->
|
|
|
|
return getUser(user.uuid).thenAccept(optionalUser ->
|
|
|
|
optionalUser.ifPresentOrElse(existingUser -> {
|
|
|
|
optionalUser.ifPresentOrElse(existingUser -> {
|
|
|
|
if (!existingUser.username.equals(user.username)) {
|
|
|
|
if (!existingUser.username.equals(user.username)) {
|
|
|
|
// Update a user's name if it has changed in the database
|
|
|
|
// Update a user's name if it has changed in the database
|
|
|
@ -155,7 +155,7 @@ public class MySqlDatabase extends Database {
|
|
|
|
} catch (SQLException e) {
|
|
|
|
} catch (SQLException e) {
|
|
|
|
getLogger().log(Level.SEVERE, "Failed to insert a user into the database", e);
|
|
|
|
getLogger().log(Level.SEVERE, "Failed to insert a user into the database", e);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
})));
|
|
|
|
}));
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
@Override
|
|
|
|