diff --git a/common/src/main/java/net/william278/husksync/database/MySqlDatabase.java b/common/src/main/java/net/william278/husksync/database/MySqlDatabase.java index c6f1260b..2de6a27e 100644 --- a/common/src/main/java/net/william278/husksync/database/MySqlDatabase.java +++ b/common/src/main/java/net/william278/husksync/database/MySqlDatabase.java @@ -121,7 +121,7 @@ public class MySqlDatabase extends Database { @Override public CompletableFuture ensureUser(@NotNull User user) { - return CompletableFuture.runAsync(() -> getUser(user.uuid).thenAccept(optionalUser -> + return getUser(user.uuid).thenAccept(optionalUser -> optionalUser.ifPresentOrElse(existingUser -> { if (!existingUser.username.equals(user.username)) { // Update a user's name if it has changed in the database @@ -155,7 +155,7 @@ public class MySqlDatabase extends Database { } catch (SQLException e) { getLogger().log(Level.SEVERE, "Failed to insert a user into the database", e); } - }))); + })); } @Override