diff --git a/src/main/java/fr/xephi/authme/process/email/AsyncAddEmail.java b/src/main/java/fr/xephi/authme/process/email/AsyncAddEmail.java
index c7673f70..9dace0f2 100644
--- a/src/main/java/fr/xephi/authme/process/email/AsyncAddEmail.java
+++ b/src/main/java/fr/xephi/authme/process/email/AsyncAddEmail.java
@@ -46,10 +46,12 @@ public class AsyncAddEmail {
                 messages.send(player, MessageKey.INVALID_EMAIL);
             } else if (dataSource.isEmailStored(email)) {
                 messages.send(player, MessageKey.EMAIL_ALREADY_USED_ERROR);
-            } else {
+            } else if (dataSource.updateEmail(auth)) {
                 auth.setEmail(email);
                 playerCache.updatePlayer(auth);
                 messages.send(player, MessageKey.EMAIL_ADDED_SUCCESS);
+            } else {
+                messages.send(player, MessageKey.ERROR);
             }
         } else {
             sendUnloggedMessage(dataSource);